Похоже ошибка в том, что pipe по умолчанию закрывает стрим. В таком случае, исправлением будет добавить {end:false} как опцию

https://nodejs.org/api/stream.html#stream_readable...

readable.pipe(destination[, options])#

Added in: v0.9.4
destination The destination for writing data
options Pipe options
end End the writer when the reader ends. Defaults to true.

Гугл кстати подсказывает
stackoverflow.com/questions/39804007/how-to-write-...