有一次我认为你可以告诉 Node.js 子进程按换行符对数据进行分块。如下所示,子进程的 stderr 数据事件针对字符和单词而不是行触发。理想情况下,我可以传递一个标志来告诉流仅在一行数据准备就绪时触发数据事件。难道就没有办法做到这一点吗?
我有这个:
const sh = spawn('sh', [ b ], {
cwd: cwd,
});
sh.stdout.pipe(fs.createWriteStream('/dev/null'));
var stderr = '';
var line = '';
sh.stderr.setEncoding('utf8');
sh.stderr.on('data', function (d) {
//trying to split by newlines, but this is hairy logic
const lines = String(d).split('\n');
line += lines.shift();
if(lines.length > 0){
if (!String(d).match(/npm/ig) && !String(d).match(/npm/ig)) {
stderr += d;
process.stderr.write.apply(process.stderr, arguments);
}
}
});
并且此处理程序中返回的数据不是整行
sh.stderr.on('data', function (d) {
// d is chunks of data but not whole lines
});
有没有办法告诉 stderr 在触发“data”事件之前等待换行符?
您可以使用变换流 https://nodejs.org/api/stream.html#stream_class_stream_transform为了那个原因。
实现并不是那么简单,所以我建议使用像这样的库split2 https://github.com/mcollina/split2.
这是基本思想:
const Transform = require('stream').Transform;
const StringDecoder = require('string_decoder').StringDecoder;
const decoder = new StringDecoder('utf8');
const myTransform = new Transform({
transform(chunk, encoding, cb) {
if ( this._last === undefined ) { this._last = "" }
this._last += decoder.write(chunk);
var list = this._last.split(/\n/);
this._last = list.pop();
for (var i = 0; i < list.length; i++) {
this.push( list[i] );
}
cb();
},
flush(cb) {
this._last += decoder.end()
if (this._last) { this.push(this._last) }
cb()
}
});
sh.stderr.pipe( myTransform )
.on('data', function (line) {
console.log("[" + line + "]");
});
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)