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 Дмитрий Рябов <somefire...@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 <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? > > >
