V
- public class ClientInterceptingDelegatingFuture<V> extends ClientDelegatingFuture<V>
ClientDelegatingFuture
that allows to set an interceptor to be executed
from user thread on get()
, join()
or joinInternal()
.CompletableFuture.AsynchronousCompletionTask
Constructor and Description |
---|
ClientInterceptingDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
SerializationService serializationService,
ClientMessageDecoder clientMessageDecoder,
BiConsumer<V,Throwable> interceptor) |
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. |
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
complete, completeExceptionally, getDelegate, getNow, isDone, resolve
completedExceptionally, completedExceptionally, completingCallback, newCompletedFuture, newCompletedFuture, newCompletedFuture, newCompletedFuture, newDelegatingFuture, withExecutor
allOf, anyOf, completedFuture, runAsync, runAsync, supplyAsync, supplyAsync
public ClientInterceptingDelegatingFuture(ClientInvocationFuture clientInvocationFuture, SerializationService serializationService, ClientMessageDecoder clientMessageDecoder, BiConsumer<V,Throwable> interceptor)
public V get() throws InterruptedException, ExecutionException
get
in interface Future<V>
get
in class ClientDelegatingFuture<V>
InterruptedException
ExecutionException
public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
get
in interface Future<V>
get
in class ClientDelegatingFuture<V>
InterruptedException
ExecutionException
TimeoutException
public V join()
join
in class ClientDelegatingFuture<V>
public V joinInternal()
InternalCompletableFuture
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 HazelcastException
s.joinInternal
in class ClientDelegatingFuture<V>
Copyright © 2019 Hazelcast, Inc.. All rights reserved.