Allows a muxrpc source to have normal pull-stream backpressure - View it on GitHub