ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Raúl Kripalani (JIRA) <j...@apache.org>
Subject [jira] [Comment Edited] (IGNITE-815) Reactive Streams Compatibility
Date Mon, 28 Sep 2015 15:44:04 GMT

    [ 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)

Mime
View raw message