writing non-blocking stream processing, respecting the back pressure feedback