如何使用streamparsing缓冲区中的行?

所以,我从STDIN中得到一个带有换行符的文件stream,但是这个stream提供了换行符的缓冲区消失。

我将如何处理/parsingStream方法?

 util.inherits(Parser,Transform);

 Parser.prototype._transform = function(data,encoding,done){
  的console.log(data.toString());
   this.push(this._parseRow(数据));
   ()完成;
 };

 //将数据行parsing为一个对象
 Parser.prototype._parseRow = function(row){
   var result = row.toString()。split(“\ r”);
   var fields = result.toString()。split(“;”);
   var bank = {a:fields [0],b:fields [1] .trim()};
  返回bank.toString();
 };

但输出有随机的换行符。

您可以使用拆分模块。

 var split = require('split'); process.stdin.pipe(split()).pipe(process.stdout); 

请注意,拆分实际上会删除换行符,因此如果要保留换行符,则必须重新添加换行符。