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] [Commented] (IGNITE-815) Reactive Streams Compatibility
Date Mon, 28 Sep 2015 15:42: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 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:

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


(sorry but I'm using RxJava concepts as I'm more familiar with those).

What do you think?

> 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

View raw message