function InStream(){ stream.Readable.call(this); } module.exports = InStream; var util = require("util"); var stream = require("stream"); util.inherits(InStream, stream.Readable); InStream.prototype._read = function (size){ } ; InStream.prototype.addData = function (data){ this.push(data); } ; InStream.prototype.end = function (){ this.push(null ); } ;