Implement some backpressure handling