ut(5_000).subscribe();
>
>
>
> 2017-03-27 15:54 GMT+03:00 Sergei Egorov :
>
> > Take a look at my initial code.
> >
> > public IgniteFuture chain(IgniteClosure > IgniteFuture, T> doneCb);
> >
> > vs
> >
> > public R to(IgniteClo
Rx's Observable, Reactor's Mono, etc...
On Mon, Mar 27, 2017 at 3:18 PM Дмитрий Рябов wrote:
> Em... When you get result of your future, closure will produce new future
> with completely different type.
>
> 2017-03-27 13:43 GMT+03:00 Sergei Egorov :
>
> > It doesn&
> 2017-03-27 13:30 GMT+03:00 Sergei Egorov :
>
> > Hi!
> >
> > Would be nice if igniteFuture would provide a small but very usable
> method:
> >
> > public R to(Function, R> transformer)
> >
> > it will allow to chain it like:
> >
>
Cool!
Please check my neighboring thread about special .to() method on
IgniteFuture to make it even better :)
On Mon, Mar 27, 2017 at 1:32 PM Vladimir Ozerov
wrote:
> Igniters,
>
> I am glad to announce that old async-style is finally deprecated and now
> all asynchronous methods are defined ex
Hi!
Would be nice if igniteFuture would provide a small but very usable method:
public R to(Function, R> transformer)
it will allow to chain it like:
compute.runAsync(runnable).to(rx()).timeout(5_000).subscribe()
Where rx() is just a static function with something like:
public sta
Hi all,
I'm going to implement Reactive bindings.
I see a task for RxJava: https://issues.apache.org/jira/browse/IGNITE-2331
Has anyone started it already?
BR,
Sergei
