ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sergei Egorov <bsid...@gmail.com>
Subject IgniteFuture adapters
Date Mon, 27 Mar 2017 10:30:41 GMT
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