Backpressure

Our ```.pipe``` doesn't do backpressure, we should fix that.