Похоже ошибка в том, что 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-...