It's like a pool. Upstream can fast pipe into it, and don't depend on the downstream.
$ npm install pool_stream
You can pipe it like other streams.
var PoolStream = require'pool_stream';var readable = fscreateReadStream'a_file';var pool = ;var writable = fscreateWriteStream'b_file';readablepipepoolpipewritable;// following events will tell you why need pool.readableon'end'console.log'readable end time is: %s' ;;poolon'end'console.log'pool end time is: %s' ;;poolon'finish'console.log'pool finish time is: %s' ;;writableon'finish'console.log'writable finish time is: %s' ;;
The MIT license.