Transform a Readable objects stream into a buffer stream with a Transform stream.

streams2.js

var stream = require('stream');

var through = stream.Transform();
through._writableState.objectMode = true;
through._transform = function (chunk, encoding, done) {
  this.push(JSON.stringify(chunk));
  this.push('\n');
  done();
};

var Readable = ream.Readable;
var rs = Readable({ objectMode: true });
var c = 97 - 1;
rs._read = function () {
    if (c >= 'z'.charCodeAt(0)) return rs.push(null);

    setTimeout(function () {
        rs.push({ ops: String.fromCharCode(++c)});
    }, 100);
};

rs.pipe(through).pipe(process.stdout);