Added stream.pipe