@kingmob i've been working on a stream thing too... and after having looked at the reactive-streams stuff and the rxjava stuff concluded that manifold's approach to backpressure was much more elegant
I haven’t looked at RxJava as much, but it seemed like it was more aligned with Manifold, and should therefore be easier to adapt. I was surprised there wasn’t already a Manifold adapter for it