= io: optimize BackPressureHandling: keep track of length instead of calling Queue.length
= io: BackPressureHandling: make sure Acks never slip through to the pipeline
Merge pull request #332 from jrudolph/back-pressure-optimizations

Back pressure optimizations