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

// jshint esnext:true

var chan = require('..')
var co   = require('co')
var wait = require('co-wait')
var ch   = chan()

co(function *() {
  var n

  while ((n = yield ch)) {
    console.log(n)
  }
})()

co(function *() {
  var n = 50

  while (n-- > 0) {
    yield wait(100)
    ch(n)
  }
})()