Great rundown on using streams properly to let backpressure do its thing. I encountered the same issue as Kieran, but luckily, as my use case was smaller, I was able to use a simpler workaround by leveraging synchronous stream internals.