Node.js streams
123456789101112131415
var stream = require("stream");
var rstream = (function() {
var i = 0;
var rstream = new stream.Readable();
rstream._read = function(){
return this.push(++i > 2 ? "" : ["hello","world"][i-1]);
};
return rstream
})();
var wstream = new stream.Writable();
wstream._write = function(chunk, enc, next){
console.log("w", chunk.toString());
return next();
};
rstream.pipe(wstream);
JavaScript
INFO