[
https://issues.apache.org/jira/browse/IGNITE-815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933463#comment-14933463
]
Raúl Kripalani edited comment on IGNITE-815 at 9/28/15 3:43 PM:
----------------------------------------------------------------
Hey [~lalitj], I had a look at the notes. Detailed and referenced, excellent!
Do you have an account in the ASF Wiki? If not, please create one and ping the
dev@ mailing list so someone can give you write permission.
My idea for the 'reactive' module consisted in offering many fluent wrappers:
probably one per Ignite functionality we want to support with reactive. For
example, for ContinuousQueries:
{code}
ContinuousQuery contQuery1 = new ContinuousQuery<>();
ContinuousQuery contQuery2 = new ContinuousQuery<>();
// set up the continuous queries
// ...
contQuery1 = IgniteReactive.wrapContinuousQuery(contQuery1); // this would
return an object of a class extending ContinuousQuery and providing a
toObservable method
contQuery2 = IgniteReactive.wrapContinuousQuery(contQuery2);
cache.query(contQuery1);
cache.query(contQuery2);
contQuery1.toObservable()
.merge(contQuery2.toObservable())
.subscribe(...);
{code}
(sorry but I'm using RxJava concepts as I'm more familiar with those).
What do you think?
Raúl.
was (Author: raulvk):
Hey [~lalitj], I had a look at the notes. Detailed and referenced, excellent!
Do you have an account in the ASF Wiki? If not, please create one and ping the
dev@ mailing list so someone can give you write permission.
My idea for the 'reactive' module consisted in offering many fluent wrappers:
probably one per Ignite functionality we want to support with reactive. For
example, for ContinuousQueries:
{code}
ContinuousQuery contQuery = new ContinuousQuery<>();
// set up the continuous query
// ...
contQuery = IgniteReactive.wrapContinuousQuery(contQuery); // this would
return an object of a class extending ContinuousQuery and providing a
toObservable method
cache.query(contQuery);
contQuery.toObservable().subscribe(...);
{code}
(sorry but I'm using RxJava concepts as I'm more familiar with those).
What do you think?
Raúl.
> Reactive Streams Compatibility
> ------------------------------
>
> Key: IGNITE-815
> URL: https://issues.apache.org/jira/browse/IGNITE-815
> Project: Ignite
> Issue Type: New Feature
> Reporter: Suminda Dharmasena
>
> http://www.reactive-streams.org/
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
