backpressure respecting pipe
Merge pull request #6 from quarterto/6-backpressure

Backpressure