2016-10-01 2 views
1

В NodeJS У меня это с помощью ExpressJS (где res является потоком с возможностью записи)Как написать поток после трубопровода?

const readableStream = someAsyncTask(); 
readableStream.pipe(res); 
readableStrean.on('end',() => { 
    res.write('a bit more'); 
    res.end(); 
}); 

Это приводит к следующему:

uncaught exception Error: write after end

поэтому я полагаю, труба в результате чего поток для записи, чтобы закрыть. Как я могу подключить читаемый поток к выходу, а затем, когда этот поток закончится, поток дополнительных данных на выход?

+0

Damn, который был вроде очевидно, не так. Вы хотите опубликовать это как ответ? – Andrew

ответ

0

documentation От

readable.pipe(destination[, options])

  • destination<stream.Writable> The destination for writing data
  • options <Object> Pipe options
    end<Boolean> End the writer when the reader ends. Defaults to true.
    ...

Если вы не хотите, чтобы это закончится, когда трубопровод, проходят {end : false} в качестве опции

readableStream.pipe(res, { end: false }); 
Смежные вопросы