1

我正在尝试创建一个返回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...)但我想将该部分保留为模块的一部分。

4

0 回答 0