ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yakov Zhdanov <yzhda...@apache.org>
Subject Re: IgniteFuture -> CompletableFuture
Date Thu, 31 Aug 2017 08:03:42 GMT
CompletableFuture is part of java 8.

--Yakov

2017-08-31 4:46 GMT+03:00 Dmitriy Setrakyan <dsetrakyan@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;
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message