[
https://issues.apache.org/jira/browse/IGNITE-815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933463#comment-14933463
]
Raúl Kripalani commented on IGNITE-815:
---------------------------------------
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)
