Handle backpressure up to incoming streams with _.pipeline

This is causing one of the old tests to fail, I cannot for the life of me figure out why.