Start to put in some support for backpressure from the pipe
Start to put in some support for backpressure from the pipe

(If the pipe stream is read slowly we'll let the processing results pile up, which is probably not good)

Logicalshift/desync