stream2のWritableStreamを書いてみました。 var stream = require('stream'), util = require('util'); function WStream(options) { options || (options = {}); stream.Writable.call(this, options); } util.inherits(WStream, stream.Writable); WStrea…

stream2のReadableStreamを書いてみました。 var stream = require('stream'), util = require('util'); function SpecialStream(options) { options || (options = {}); options.objectMode = true; stream.Readable.call(this, options); this.count = 0; …