buffered.js
357 字节
// 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()
})()