我正在尝试创建一个返回Transform
流的 Nodejs 模块。它将一个可读流作为其输入。但是,我希望输出在返回之前通过另一个流传递。例如:
const { Transform } = require('stream')
const JSONStream = require('JSONStream')
let myTransform = new Transform({
objectMode: true,
transform: function(chunk, encoding, callback) {
callback(null, chunk.foo + 1)
}
})
module.exports = myTransform.pipe(JSONStream.stringify('[', ',', ']'))
当我这样做时,流myTransform
被忽略。例如,我意识到我可以将管道移动到JSONStream
其他地方,request('https://...').pipe(myTranform).pipe(JSONStream...)
但我想将该部分保留为模块的一部分。