module.exports = Stream;
var Parser = require(“./Parser.js”),
WritableStream = require("stream").Writable || require("readable-stream").Writable, StringDecoder = require("string_decoder").StringDecoder, Buffer = require("buffer").Buffer;
function Stream(cbs, options){
var parser = this._parser = new Parser(cbs, options); var decoder = this._decoder = new StringDecoder(); WritableStream.call(this, {decodeStrings: false}); this.once("finish", function(){ parser.end(decoder.end()); });
}
require(“inherits”)(Stream, WritableStream);
WritableStream.prototype._write = function(chunk, encoding, cb){
if(chunk instanceof Buffer) chunk = this._decoder.write(chunk); this._parser.write(chunk); cb();
};