es6-stream

through streams with generators, inspired by this comment by @Qard. Requries harmony flags.

npm install es6-stream;

api

var splitStream = es6Stream(function * (read, write) {
    var chunk, i, len;
    while ((chunk = yield read())) {
      chunk = chunk.toString().split(' ');
      i = -1;
      len = chunk.length;
      while (++i < len) {
        yield write(chunk[i]);
      }
    }\
  })
var upcaseStream = es6Stream(function* (read, write) {
  var bytes = 1024
  var chunk
  while ((chunk = yield read(bytes))) {
    yield write(chunk.toString().toUpperCase())
  }
})

or use it for readable and writable streams

co(function *() {
	var read = es6Stream.read(readableStream);
	while ((chunk = yield read())) {
		//do something with chunk;
	}
});

co(function *() {
	var write = es6Stream.write(writableStream);
	var i = -1;
	var len = stuff.length;
	while (++i < len) {
		yield write(stuff[i]);
	}
});