Guys, I think you are digging too deep in implementation possibilities right away, may be lets start from simpler things? I don't know much about reactive streams and probably not everyone in the community that educated as well :)
It would be nice to start with a quick overview of what are they and why in makes sense to to add such a functionality to Ignite? What real use cases do you see? How can Ignite be useful for reactive streams users and vice versa? Lets get clear answers to these questions first to avoid writing useless code. Sergi 2015-09-20 18:55 GMT+03:00 Raul Kripalani <r...@evosent.com>: > Yeah, the idea would be to wrap RxJava 1.0 with the adapter and only use > the Reactive Streams API where possible from within Ignite. > > Nevertheless, the ReactiveX API would also be accessible in case we want to > do stuff with Hystrix too. > > Raúl. > On 20 Sep 2015 16:39, "Vishal Garg" <gargv...@gmail.com> wrote: > > > https://github.com/ReactiveX/RxJava/wiki/R > > eactive-Streams > > +1 on your approach ( if we are wrapping 1.0 with adapters??) > > Raul it looks like there is a path to convergence in RxJava 2.0, but > above > > link mentions that you could use the standard + integration modules with > > wrappers on core 1.0 Apis. Where the modules could be Akka or RxJava > > Vishal > > > > > > > > Sent from my iPhone > > > > > On Sep 20, 2015, at 7:03 AM, Gianfranco Murador < > > murador.gianfra...@gmail.com> wrote: > > > > > > Hy Raul, it could be a valid extension of the Service Grid of Ignite ( > > if I > > > understand the point), imho. > > > > > > 2015-09-20 14:37 GMT+02:00 Raul Kripalani <ra...@apache.org>: > > > > > >> Hey Igniters, > > >> > > >> Lalit Kumar Jha expressed interest [1] in contributing to ticket > > IGNITE-815 > > >> [2] which aims to bring in Reactive Streams to Ignite. > > >> > > >> I wanted to start a brainstorm about which functionalities we'd like > to > > >> cover. > > >> > > >> Off the top of my head, I can think of merging, filtering, sorting, > > >> batching, grouping, etc. on Data Streams, Ignite Messages and Events. > > Also, > > >> integration with Continuous Queries would be useful. > > >> > > >> Furthermore, I wanted to ask the community if at this point we feel > > >> comfortable with Reactive Streams per-se or we prefer to go with > RxJava > > for > > >> now. Reactive Streams is a proposed standard whose main Java > > implementation > > >> and is slowly gaining traction (e.g. vert.x [3] and MongoDB > integrations > > >> [4]), whereas RxJava is an already mature and production-tested > > >> implementation of the initial ReactiveX design by Microsoft [5] with > > 7000+ > > >> stars on GitHub. > > >> > > >> RxJava is the foundation of Hystrix [6], a powerful library for > latency > > and > > >> fault tolerance management. RxJava does not implement Reactive Streams > > as > > >> of 1.x (as they predated it), but they've vowed support for 2.x [7]. > > >> Moreover, there's already an adapter which passes the TCK [8]. > > >> > > >> My take is as follows. I'd like to follow the Reactive Streams > standard, > > >> but I wouldn't like to lose support for Hystrix (hopefully it'll > > eventually > > >> be migrated to Reactive Streams too). So an option is to go with the > > RxJava > > >> + adapter design for now to get the best of both worlds. Once RxJava > > 2.0 is > > >> out, we can drop the adapter out of the picture. > > >> > > >> Thoughts? > > >> > > >> [1] > > >> > > >> > > > http://apache-ignite-developers.2346864.n4.nabble.com/Hello-Apache-Ignite-Dev-tp3137p3315.html > > >> [2] https://issues.apache.org/jira/browse/IGNITE-815 > > >> [3] http://vertx.io/docs/vertx-reactive-streams/java/ > > >> [4] https://mongodb.github.io/mongo-java-driver-reactivestreams/ > > >> [5] https://msdn.microsoft.com/en-us/data/gg577609.aspx > > >> [6] https://github.com/Netflix/Hystrix > > >> [7] https://github.com/ReactiveX/RxJava/wiki/Reactive-Streams > > >> [8] https://github.com/ReactiveX/RxJavaReactiveStreams > > >> > > >> Regards, > > >> > > >> *Raúl Kripalani* > > >> Apache Camel PMC Member & Committer | Enterprise Architect, Open > Source > > >> Integration specialist > > >> http://about.me/raulkripalani | > > http://www.linkedin.com/in/raulkripalani > > >> http://blog.raulkr.net | twitter: @raulvk > > >> > > >
