CompletableFuture is part of java 8.
--Yakov
2017-08-31 4:46 GMT+03:00 Dmitriy Setrakyan <dsetrak...@apache.org>:
> 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;
>
