es.fork

[tblobaum]

I would like to be able to fork a stream so it can be piped to two places at the same time, is there an easy way to do this already? In consuming a stream I'd like to fork it one direction to save the data in a temporary place until the other fork has been successfully processed.

[Raynos]

stream.pipe(one)
stream.pipe(two)

[dominictarr]

the code you give here will just work, unless there is an error.

if you are worried about an error maybe you could do this:

stream.pipe(one)
stream.pipe(two)
one.removeAllListeners('error')
one.on('error', function () {
  //do what you gotta do.
  one.destroy() //cleanup one...
})

this will dump one but keep streaming to two. note: one must set writable=false just before it emits "error"

currently pipe always assigns an error listener, I've been wandering if that should be optional.
I'll be interesting to investigate your use-case to see if a good case can be made for optional error handling.