/*Thin wrapper that makes setting up streams a bit easier.Defaults to objectMode on read and write streams. You can override options by including a config.options object.*/varEasy=require("easy-stream");//creates a read streamvareasyReadStream=Easy({_read: function(){varsomeData={easy: "stream"};this.push(someData);},options: {}//using default options.});//now create a corresponding writable stream with easy-stream.vareasyWriteStream=Easy({_write: function(obj,encoding,next){//obj is the json object {easy: "stream"}console.log(obj);next();}});easyReadStream.pipe(easyWriteStream);//creating a duplex stream is easy.varstream=Easy({_write: function(){},_read: function(){}});//so is creating a transform streamvarstream=Easy({_transform: function(){}_flush: function(){}});//you can subclass any function toofunctionSomeFunction(){}SomeFunction.prototype.someMethod=function(){};vareasyDuplexStream=Easy({_read: function(){},_write: function(){},createUsing: SomeFunction})