Fix backpressure implementation and test.