var mux = require'mux';srcpipemuxdest1dest2dest3pipesomewhereElse
$ npm install mux# or$ component install juliangruber/mux
Creates a new through Stream that pipes all incoming data to each
destination there is a pausable stream connected in-between so that
destination applies backpressure the others aren't slowed down.