com.hazelcast.client.impl

Class ClientInterceptingDelegatingFuture<V>

java.lang.Object

java.util.concurrent.CompletableFuture<V>

com.hazelcast.spi.impl.InternalCompletableFuture<V>

com.hazelcast.spi.impl.DelegatingCompletableFuture<V>

com.hazelcast.client.impl.ClientDelegatingFuture<V>

com.hazelcast.client.impl.ClientInterceptingDelegatingFuture<V>

Type Parameters:

V -

All Implemented Interfaces:

CompletionStage<V>, Future<V>

public class ClientInterceptingDelegatingFuture<V>
extends ClientDelegatingFuture<V>

A specialization of ClientDelegatingFuture that allows to set an interceptor to be executed from user thread on get(), join() or joinInternal().

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor and Description
ClientInterceptingDelegatingFuture(ClientInvocationFuture clientInvocationFuture, SerializationService serializationService, ClientMessageDecoder clientMessageDecoder, BiConsumer<V,Throwable> interceptor)

Method Summary

Modifier and Type	Method and Description
V	get()
V	get(long timeout, TimeUnit unit)
V	join()
V	joinInternal() Similarly to CompletableFuture.join(), returns the value when complete or throws an unchecked exception if completed exceptionally.

Methods inherited from class com.hazelcast.client.impl.ClientDelegatingFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, exceptionally, getFuture, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, obtrudeException, obtrudeValue, resolveResponse, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class com.hazelcast.spi.impl.DelegatingCompletableFuture

complete, completeExceptionally, getDelegate, getNow, isDone, resolve

Methods inherited from class com.hazelcast.spi.impl.InternalCompletableFuture

completedExceptionally, completedExceptionally, completingCallback, newCompletedFuture, newCompletedFuture, newCompletedFuture, newCompletedFuture, newDelegatingFuture, withExecutor

Methods inherited from class java.util.concurrent.CompletableFuture

allOf, anyOf, completedFuture, runAsync, runAsync, supplyAsync, supplyAsync

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ClientInterceptingDelegatingFuture

public ClientInterceptingDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
                                          SerializationService serializationService,
                                          ClientMessageDecoder clientMessageDecoder,
                                          BiConsumer<V,Throwable> interceptor)

Method Detail

get

public V get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<V>

Overrides:

get in class ClientDelegatingFuture<V>

Throws:

InterruptedException

ExecutionException

get

public V get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<V>

Overrides:

get in class ClientDelegatingFuture<V>

Throws:

InterruptedException

ExecutionException

TimeoutException

join

public V join()

Overrides:

join in class ClientDelegatingFuture<V>

joinInternal

public V joinInternal()

Description copied from class: InternalCompletableFuture

Similarly to CompletableFuture.join(), returns the value when complete or throws an unchecked exception if completed exceptionally. Unlike CompletableFuture.join(), checked exceptions are not wrapped in CompletionException; rather they are wrapped in HazelcastExceptions.

Overrides:

joinInternal in class ClientDelegatingFuture<V>

Returns:

the result