Include pause stream dependency
Fix backpressure handling