ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Дмитрий Рябов <somefire...@gmail.com>
Subject Re: IgniteFuture adapters
Date Mon, 27 Mar 2017 12:18:23 GMT
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 <bsideup@gmail.com>:

> It doesn't :)
>
> It returns another IgniteFuture where I want to transform it to completely
> different type.
>
> On Mon, Mar 27, 2017 at 1:41 PM Дмитрий Рябов <somefireone@gmail.com>
> wrote:
>
> > IgniteFuture have method
> >
> > public <T> IgniteFuture<T> chain(IgniteClosure<? super IgniteFuture<V>,
> T>
> > doneCb);
> >
> > which do this.
> >
> > 2017-03-27 13:30 GMT+03:00 Sergei Egorov <bsideup@gmail.com>:
> >
> > > Hi!
> > >
> > > Would be nice if igniteFuture would provide a small but very usable
> > method:
> > >
> > >     public <R> R to(Function<IgniteFuture<T>, 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 static <T> Function<IgniteFuture<T>, Observable<T>>
rx()
> > >
> > >
> > > WDYT?
> > >
> >
> >
> > 2017-03-27 13:30 GMT+03:00 Sergei Egorov <bsideup@gmail.com>:
> >
> > > Hi!
> > >
> > > Would be nice if igniteFuture would provide a small but very usable
> > method:
> > >
> > >     public <R> R to(Function<IgniteFuture<T>, 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 static <T> Function<IgniteFuture<T>, Observable<T>>
rx()
> > >
> > >
> > > WDYT?
> > >
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message