Модуль 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...) но я хотел бы сохранить эту часть как часть модуля.

0 ответов

Другие вопросы по тегам