genstream.js

var Readable = require('stream').Readable;
var util = require('util');

function Source(options, generator) {
  if (typeof options === 'function') {
    generator = options;
    options = {};
  }
  this._generator = generator();
  Readable.call(this, options);
}

util.inherits(Source, Readable);

Source.prototype._read = function () {
  while (true) {
    // console.log('GET NEXT');
    var next = this._generator.next();
    // console.log('NEXT WAS', next);
    var shouldContinue = this.push(next.value);
    if (next.done) {
      this.push(null);
      break;
    } else if (!shouldContinue) {
      break;
    }
  }
};


new Source(function* () {
  yield "hello";
  yield "word";
  yield "boom";
}).pipe(process.stdout);