stream: backpressure control