pipe_opts like highWaterMark