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?
