streams2: Handle pipeChunkSize properly