why not use the real Stream#pipe function from node - a lot of development work went into getting it right.