<div dir="ltr">I was thinking more about [1] and I find that I was going to implement basically reactive streams. What we have now in github is similar but it uses a very crude method of blocking the thread to prevent back pressure. This can then cause severe issues as many users have found out when they don&#39;t close iterator.<div><br></div><div>Unfortunately reactive streams is just a spec. I am proposing to add RxJava [2] as a dependency [2] in the core module to provide access to reactive streams and the various conversion methods. This library adds a bunch of support for built in back pressure, transformations and much more which would reduce the amount of code I would need to write substantially.</div><div><br></div><div>In regards to timing, I am thinking this is too close for 9.1, so maybe 9.2 or higher.</div><div><br></div><div>What do you guys think?<br><div><br></div><div>[1] <a href="https://issues.jboss.org/browse/ISPN-7865">https://issues.jboss.org/browse/ISPN-7865</a></div></div><div>[2] <a href="https://github.com/ReactiveX/RxJava">https://github.com/ReactiveX/RxJava</a></div><div>[3] <a href="https://mvnrepository.com/artifact/io.reactivex.rxjava2/rxjava/2.1.0">https://mvnrepository.com/artifact/io.reactivex.rxjava2/rxjava/2.1.0</a></div></div>