stream.pipeline(streams[, options])#>>>>>>>>>>>