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?