1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
| // jshint esnext:true
|
| var chan = require('..')
| var co = require('co')
| var wait = require('co-wait')
| var ch = chan(5)
|
| co(function *() {
| var n
| while (!ch.done()) {
| yield wait(100)
| console.log('<-- ' + (yield ch))
| }
| })()
|
|
| co(function *() {
| var n = 10
| while (n-- > 0) {
| yield ch(n)
| console.log(n + ' -->')
| }
| ch.close()
| })()
|
|
