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 <bsid...@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 <bsid...@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? >
