Don't immediately poll for a new value from the stream until the old one has finished processing
Don't immediately poll for a new value from the stream until the old one has finished processing

This creates backpressure when the function is running, which is a thing we want

Logicalshift/desync