UNPKG

666 Btext/coffeescriptView Raw
1Director = require "./director"
2
3module.exports = (router) ->
4
5 ###
6 ###
7
8 director = new Director("push", router)
9
10 ###
11 ###
12
13 name: director.name
14
15 ###
16 ###
17
18 director: director
19
20 ###
21 ###
22
23 newListener: (listener) ->
24
25 router.request('new/listener').tag('private',true).query(listener).push();
26
27 ###
28 ###
29
30 router:
31
32 push: (channel, query, headers) -> @request(channel, query, headers).push null
33
34 ###
35 ###
36
37 message:
38
39 push: (data) ->
40
41 # no error handler? add a blank func
42 # if not @error()
43 # @error ->
44
45 writer = @dispatch director.name
46
47
48 # if data exists, then we're done.
49 writer.end data if !!arguments.length
50
51 writer
52
53