ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sergei Egorov <bsid...@gmail.com>
Subject Re: IgniteFuture adapters
Date Mon, 27 Mar 2017 10:43:19 GMT
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