<html><head><meta http-equiv="Content-Type" content="text/html charset=utf-8"></head><body style="word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-line-break: after-white-space;" class="">You’re thinking about a pure implementation play, correct? RxJava or the Reactive Stream constructs would not be exposed to the user as API. Am I correct?<div class="">Also for posterity, we had backchannel chats about it and you said you felt vert.x was not necessarily addressing your needs. Could you elaborate a bit here?</div><div class=""><br class=""></div><div class="">Emmanuel</div><div class=""><br class=""></div><div class=""><div><blockquote type="cite" class=""><div class="">On 15 Jun 2017, at 23:20, William Burns <<a href="mailto:mudokonman@gmail.com" class="">mudokonman@gmail.com</a>> wrote:</div><br class="Apple-interchange-newline"><div class=""><div dir="ltr" class="">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't close iterator.<div class=""><br class=""></div><div class="">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 class=""><br class=""></div><div class="">In regards to timing, I am thinking this is too close for 9.1, so maybe 9.2 or higher.</div><div class=""><br class=""></div><div class="">What do you guys think?<br class=""><div class=""><br class=""></div><div class="">[1] <a href="https://issues.jboss.org/browse/ISPN-7865" class="">https://issues.jboss.org/browse/ISPN-7865</a></div></div><div class="">[2] <a href="https://github.com/ReactiveX/RxJava" class="">https://github.com/ReactiveX/RxJava</a></div><div class="">[3] <a href="https://mvnrepository.com/artifact/io.reactivex.rxjava2/rxjava/2.1.0" class="">https://mvnrepository.com/artifact/io.reactivex.rxjava2/rxjava/2.1.0</a></div></div>
_______________________________________________<br class="">infinispan-dev mailing list<br class=""><a href="mailto:infinispan-dev@lists.jboss.org" class="">infinispan-dev@lists.jboss.org</a><br class="">https://lists.jboss.org/mailman/listinfo/infinispan-dev</div></blockquote></div><br class=""></div></body></html>