Handle backpressure accordingly