项目原始demo,不改动
Nevar pievienot vairāk kā 25 tēmas Tēmai ir jāsākas ar burtu vai ciparu, tā var saturēt domu zīmes ('-') un var būt līdz 35 simboliem gara.
Repozitorijs ir arhivēts. Tam var aplūkot failus un to var klonēt, bet nevar iesūtīt jaunas izmaiņas, kā arī atvērt jaunas problēmas/izmaiņu pieprasījumus.
 
 
 
 

21 rinda
502 B

  1. module.exports = Stream;
  2. var Parser = require("./Parser.js"),
  3. WritableStream = require("stream").Writable || require("readable-stream").Writable;
  4. function Stream(cbs, options){
  5. var parser = this._parser = new Parser(cbs, options);
  6. WritableStream.call(this, {decodeStrings: false});
  7. this.once("finish", function(){
  8. parser.end();
  9. });
  10. }
  11. require("util").inherits(Stream, WritableStream);
  12. WritableStream.prototype._write = function(chunk, encoding, cb){
  13. this._parser.write(chunk);
  14. cb();
  15. };