1 | Director = require "./director"
|
2 |
|
3 | module.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 |
|
42 |
|
43 |
|
44 |
|
45 | writer = @dispatch director.name
|
46 |
|
47 |
|
48 |
|
49 | writer.end data if !!arguments.length
|
50 |
|
51 | writer
|
52 |
|
53 |
|