pipeThrough: свойство writeable параметра 1 не является WritableStream - PullRequest
0 голосов
/ 12 июня 2019

Я пытаюсь связать синтаксический анализатор 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 {...}

Итак, я не выясняю, как решить эту ошибку

...