1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
| // jshint esnext:true
|
| var fs = require('fs')
| var chan = require('..')
| var co = require('co')
| var split = require('split')
|
| co(function *() {
| var ch = chan()
|
| fs.createReadStream(__dirname + '/../README.markdown')
| .pipe(split())
| .on('data', ch)
| .on('error', ch)
| .on('end', ch.close)
|
| while (!ch.done()) {
| var val = yield ch
| if (val !== ch.empty) {
| console.log('Stream yielded: ' + String(yield ch))
| }
| }
|
| console.log('Stream ended')
| })()
|
|
