我如何创建一个转换流,该转换流唯一会发生的变化是,在输入的可读流的末尾附加一个字符串。
例如,假设input.txt包含abcdef。
fs.createReadStream('input.txt', {encoding: 'utf8'})
.pipe(appendTransform)
.pipe(fs.createWriteStream('output.txt', {encoding: 'utf8'}));
Run Code Online (Sandbox Code Playgroud)
我可以用来做什么appendTransform,例如output.txt包含abcdefghi。
创建一个转换流:
var Transform = require('stream').Transform;
var appendTransform = new Transform({
transform(chunk, encoding, callback) {
callback(null, chunk);
},
flush(callback) {
this.push('ghi');
callback();
}
});
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
791 次 |
| 最近记录: |