Модуль Nodejs, который возвращает поток с каналом
Я пытаюсь создать модуль Nodejs, который возвращает Transform
поток. Он принимает в качестве входных данных читаемый поток. Тем не менее, я хотел бы, чтобы выходные данные были переданы через другой поток перед возвращением. Например:
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...)
но я хотел бы сохранить эту часть как часть модуля.