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 10:33:23 GMT
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