An intuitive and safe way to do asynchronous, non-blocking backpressured stream processing.