Igniters,

I received the following proposal in my blog. I think this is useful. Any
thoughts?

Please extend IgniteFuture by conversion method to CompletableFuture. I
> bored to write something like this:


> asyncCache.invoke(key, entryProcessor);
> CompletableFuture completableFuture = new CompletableFuture<>();
> IgniteFuture igniteFuture = asyncCache.future();
> IgniteInClosure> listener = (IgniteInClosure>) completedIgniteFuture -> {
> Throwable exception = null;
> T result = null;
> try {
> result = completedIgniteFuture.get();
> } catch (Throwable t) {
> exception = t;
> }
> if (exception != null) {
> completableFuture.completeExceptionally(exception);
> } else {
> completableFuture.complete(result);
> }
> };
> igniteFuture.listen(listener);
> return completableFuture;

Reply via email to