ysjj-system/node_modules/chan/examples/stream.js

// 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')
})()