Handle backpressure accordingly
Merge pull request #1 from sreuter/master

Implement backpressure handling