Я пытаюсь связать синтаксический анализатор ndjson с потоком тела ответа от запроса на выборку через pipeThrough () как:
fetch(url)
.then(resp => {
const transform = ndjson.parse()
const reader = resp.body.pipeThrough({ 'writable': transform, 'readable':
transform })
reader.on('data', obj => {...}
})
Пока что, pipeThrough
throws:
Не удалось выполнить 'pipeThrough' для 'ReadableStream': свойство writeable для параметра 1 не является WritableStream.
Я уже проверил, что ndjson.parse()
возвращает Transform
экземпляр, который расширяет Duplex
, который, в свою очередь, расширяет Readable
и реализует Writable
, то есть:
class Writable extends Stream implements NodeJS.WritableStream {...}
Итак, я не выясняю, как решить эту ошибку