com.hazelcast.client.impl

Class ClientDelegatingFuture<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>

Type Parameters:

V - Value type that the user expects

All Implemented Interfaces:

CompletionStage<V>, Future<V>

Direct Known Subclasses:

ClientInterceptingDelegatingFuture, IExecutorDelegatingFuture

public class ClientDelegatingFuture<V>
extends DelegatingCompletableFuture<V>

The Client Delegating Future is used to delegate ClientInvocationFuture to a user type to be used with further computation stages or get(). It converts ClientMessage coming from ClientInvocationFuture to a user object.

Nested Class Summary

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

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor and Description
ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture, SerializationService serializationService, ClientMessageDecoder clientMessageDecoder)
ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture, SerializationService serializationService, ClientMessageDecoder clientMessageDecoder, boolean deserializeResponse)
ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture, SerializationService serializationService, ClientMessageDecoder clientMessageDecoder, V defaultValue)
ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture, SerializationService serializationService, ClientMessageDecoder clientMessageDecoder, V defaultValue, boolean deserializeResponse)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	acceptEither(CompletionStage<? extends V> other, Consumer<? super V> action)
CompletableFuture<Void>	acceptEitherAsync(CompletionStage<? extends V> other, Consumer<? super V> action)
CompletableFuture<Void>	acceptEitherAsync(CompletionStage<? extends V> other, Consumer<? super V> action, Executor executor)
<U> CompletableFuture<U>	applyToEither(CompletionStage<? extends V> other, Function<? super V,U> fn)
<U> CompletableFuture<U>	applyToEitherAsync(CompletionStage<? extends V> other, Function<? super V,U> fn)
<U> CompletableFuture<U>	applyToEitherAsync(CompletionStage<? extends V> other, Function<? super V,U> fn, Executor executor)
boolean	cancel(boolean mayInterruptIfRunning)
CompletableFuture<V>	exceptionally(Function<Throwable,? extends V> fn)
V	get()
V	get(long timeout, TimeUnit unit)
protected ClientInvocationFuture	getFuture()
int	getNumberOfDependents()
<U> CompletableFuture<U>	handle(BiFunction<? super V,Throwable,? extends U> fn)
<U> CompletableFuture<U>	handleAsync(BiFunction<? super V,Throwable,? extends U> fn)
<U> CompletableFuture<U>	handleAsync(BiFunction<? super V,Throwable,? extends U> fn, Executor executor)
boolean	isCancelled()
boolean	isCompletedExceptionally()
V	join()
V	joinInternal() Similarly to CompletableFuture.join(), returns the value when complete or throws an unchecked exception if completed exceptionally.
void	obtrudeException(Throwable ex)
void	obtrudeValue(V value)
protected V	resolveResponse(ClientMessage clientMessage, boolean deserialize)
CompletableFuture<Void>	runAfterBoth(CompletionStage<?> other, Runnable action)
CompletableFuture<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action)
CompletableFuture<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor)
CompletableFuture<Void>	runAfterEither(CompletionStage<?> other, Runnable action)
CompletableFuture<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action)
CompletableFuture<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor)
CompletableFuture<Void>	thenAccept(Consumer<? super V> action)
CompletableFuture<Void>	thenAcceptAsync(Consumer<? super V> action)
CompletableFuture<Void>	thenAcceptAsync(Consumer<? super V> action, Executor executor)
<U> CompletableFuture<Void>	thenAcceptBoth(CompletionStage<? extends U> other, BiConsumer<? super V,? super U> action)
<U> CompletableFuture<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super V,? super U> action)
<U> CompletableFuture<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super V,? super U> action, Executor executor)
<U> CompletableFuture<U>	thenApply(Function<? super V,? extends U> fn)
<U> CompletableFuture<U>	thenApplyAsync(Function<? super V,? extends U> fn)
<U> CompletableFuture<U>	thenApplyAsync(Function<? super V,? extends U> fn, Executor executor)
<U,V1> CompletableFuture<V1>	thenCombine(CompletionStage<? extends U> other, BiFunction<? super V,? super U,? extends V1> fn)
<U,V1> CompletableFuture<V1>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super V,? super U,? extends V1> fn)
<U,V1> CompletableFuture<V1>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super V,? super U,? extends V1> fn, Executor executor)
<U> CompletableFuture<U>	thenCompose(Function<? super V,? extends CompletionStage<U>> fn)
<U> CompletableFuture<U>	thenComposeAsync(Function<? super V,? extends CompletionStage<U>> fn)
<U> CompletableFuture<U>	thenComposeAsync(Function<? super V,? extends CompletionStage<U>> fn, Executor executor)
CompletableFuture<Void>	thenRun(Runnable action)
CompletableFuture<Void>	thenRunAsync(Runnable action)
CompletableFuture<Void>	thenRunAsync(Runnable action, Executor executor)
CompletableFuture<V>	toCompletableFuture()
String	toString()
CompletableFuture<V>	whenComplete(BiConsumer<? super V,? super Throwable> action)
CompletableFuture<V>	whenCompleteAsync(BiConsumer<? super V,? super Throwable> action)
CompletableFuture<V>	whenCompleteAsync(BiConsumer<? super V,? super Throwable> action, Executor executor)

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

ClientDelegatingFuture

public ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
                              SerializationService serializationService,
                              ClientMessageDecoder clientMessageDecoder,
                              V defaultValue,
                              boolean deserializeResponse)

ClientDelegatingFuture

public ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
                              SerializationService serializationService,
                              ClientMessageDecoder clientMessageDecoder,
                              V defaultValue)

ClientDelegatingFuture

public ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
                              SerializationService serializationService,
                              ClientMessageDecoder clientMessageDecoder)

ClientDelegatingFuture

public ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
                              SerializationService serializationService,
                              ClientMessageDecoder clientMessageDecoder,
                              boolean deserializeResponse)

Method Detail

get

public V get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<V>

Overrides:

get in class DelegatingCompletableFuture<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 DelegatingCompletableFuture<V>

Throws:

InterruptedException

ExecutionException

TimeoutException

join

public V join()

Overrides:

join in class DelegatingCompletableFuture<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 DelegatingCompletableFuture<V>

Returns:

the result

resolveResponse

protected V resolveResponse(ClientMessage clientMessage,
                            boolean deserialize)

getFuture

protected ClientInvocationFuture getFuture()

thenApply

public <U> CompletableFuture<U> thenApply(Function<? super V,? extends U> fn)

Specified by:

thenApply in interface CompletionStage<V>

Overrides:

thenApply in class DelegatingCompletableFuture<V>

thenApplyAsync

public <U> CompletableFuture<U> thenApplyAsync(Function<? super V,? extends U> fn)

Specified by:

thenApplyAsync in interface CompletionStage<V>

Overrides:

thenApplyAsync in class DelegatingCompletableFuture<V>

thenApplyAsync

public <U> CompletableFuture<U> thenApplyAsync(Function<? super V,? extends U> fn,
                                               Executor executor)

Specified by:

thenApplyAsync in interface CompletionStage<V>

Overrides:

thenApplyAsync in class DelegatingCompletableFuture<V>

thenAccept

public CompletableFuture<Void> thenAccept(Consumer<? super V> action)

Specified by:

thenAccept in interface CompletionStage<V>

Overrides:

thenAccept in class DelegatingCompletableFuture<V>

thenAcceptAsync

public CompletableFuture<Void> thenAcceptAsync(Consumer<? super V> action)

Specified by:

thenAcceptAsync in interface CompletionStage<V>

Overrides:

thenAcceptAsync in class DelegatingCompletableFuture<V>

thenAcceptAsync

public CompletableFuture<Void> thenAcceptAsync(Consumer<? super V> action,
                                               Executor executor)

Specified by:

thenAcceptAsync in interface CompletionStage<V>

Overrides:

thenAcceptAsync in class DelegatingCompletableFuture<V>

thenRun

public CompletableFuture<Void> thenRun(Runnable action)

Specified by:

thenRun in interface CompletionStage<V>

Overrides:

thenRun in class DelegatingCompletableFuture<V>

thenRunAsync

public CompletableFuture<Void> thenRunAsync(Runnable action)

Specified by:

thenRunAsync in interface CompletionStage<V>

Overrides:

thenRunAsync in class DelegatingCompletableFuture<V>

thenRunAsync

public CompletableFuture<Void> thenRunAsync(Runnable action,
                                            Executor executor)

Specified by:

thenRunAsync in interface CompletionStage<V>

Overrides:

thenRunAsync in class DelegatingCompletableFuture<V>

thenCombine

public <U,V1> CompletableFuture<V1> thenCombine(CompletionStage<? extends U> other,
                                                BiFunction<? super V,? super U,? extends V1> fn)

Specified by:

thenCombine in interface CompletionStage<V>

Overrides:

thenCombine in class DelegatingCompletableFuture<V>

thenCombineAsync

public <U,V1> CompletableFuture<V1> thenCombineAsync(CompletionStage<? extends U> other,
                                                     BiFunction<? super V,? super U,? extends V1> fn)

Specified by:

thenCombineAsync in interface CompletionStage<V>

Overrides:

thenCombineAsync in class DelegatingCompletableFuture<V>

thenCombineAsync

public <U,V1> CompletableFuture<V1> thenCombineAsync(CompletionStage<? extends U> other,
                                                     BiFunction<? super V,? super U,? extends V1> fn,
                                                     Executor executor)

Specified by:

thenCombineAsync in interface CompletionStage<V>

Overrides:

thenCombineAsync in class DelegatingCompletableFuture<V>

thenAcceptBoth

public <U> CompletableFuture<Void> thenAcceptBoth(CompletionStage<? extends U> other,
                                                  BiConsumer<? super V,? super U> action)

Specified by:

thenAcceptBoth in interface CompletionStage<V>

Overrides:

thenAcceptBoth in class DelegatingCompletableFuture<V>

thenAcceptBothAsync

public <U> CompletableFuture<Void> thenAcceptBothAsync(CompletionStage<? extends U> other,
                                                       BiConsumer<? super V,? super U> action)

Specified by:

thenAcceptBothAsync in interface CompletionStage<V>

Overrides:

thenAcceptBothAsync in class DelegatingCompletableFuture<V>

thenAcceptBothAsync

public <U> CompletableFuture<Void> thenAcceptBothAsync(CompletionStage<? extends U> other,
                                                       BiConsumer<? super V,? super U> action,
                                                       Executor executor)

Specified by:

thenAcceptBothAsync in interface CompletionStage<V>

Overrides:

thenAcceptBothAsync in class DelegatingCompletableFuture<V>

runAfterBoth

public CompletableFuture<Void> runAfterBoth(CompletionStage<?> other,
                                            Runnable action)

Specified by:

runAfterBoth in interface CompletionStage<V>

Overrides:

runAfterBoth in class DelegatingCompletableFuture<V>

runAfterBothAsync

public CompletableFuture<Void> runAfterBothAsync(CompletionStage<?> other,
                                                 Runnable action)

Specified by:

runAfterBothAsync in interface CompletionStage<V>

Overrides:

runAfterBothAsync in class DelegatingCompletableFuture<V>

runAfterBothAsync

public CompletableFuture<Void> runAfterBothAsync(CompletionStage<?> other,
                                                 Runnable action,
                                                 Executor executor)

Specified by:

runAfterBothAsync in interface CompletionStage<V>

Overrides:

runAfterBothAsync in class DelegatingCompletableFuture<V>

applyToEitherAsync

public <U> CompletableFuture<U> applyToEitherAsync(CompletionStage<? extends V> other,
                                                   Function<? super V,U> fn)

Specified by:

applyToEitherAsync in interface CompletionStage<V>

Overrides:

applyToEitherAsync in class DelegatingCompletableFuture<V>

applyToEither

public <U> CompletableFuture<U> applyToEither(CompletionStage<? extends V> other,
                                              Function<? super V,U> fn)

Specified by:

applyToEither in interface CompletionStage<V>

Overrides:

applyToEither in class DelegatingCompletableFuture<V>

applyToEitherAsync

public <U> CompletableFuture<U> applyToEitherAsync(CompletionStage<? extends V> other,
                                                   Function<? super V,U> fn,
                                                   Executor executor)

Specified by:

applyToEitherAsync in interface CompletionStage<V>

Overrides:

applyToEitherAsync in class DelegatingCompletableFuture<V>

acceptEither

public CompletableFuture<Void> acceptEither(CompletionStage<? extends V> other,
                                            Consumer<? super V> action)

Specified by:

acceptEither in interface CompletionStage<V>

Overrides:

acceptEither in class DelegatingCompletableFuture<V>

acceptEitherAsync

public CompletableFuture<Void> acceptEitherAsync(CompletionStage<? extends V> other,
                                                 Consumer<? super V> action)

Specified by:

acceptEitherAsync in interface CompletionStage<V>

Overrides:

acceptEitherAsync in class DelegatingCompletableFuture<V>

acceptEitherAsync

public CompletableFuture<Void> acceptEitherAsync(CompletionStage<? extends V> other,
                                                 Consumer<? super V> action,
                                                 Executor executor)

Specified by:

acceptEitherAsync in interface CompletionStage<V>

Overrides:

acceptEitherAsync in class DelegatingCompletableFuture<V>

runAfterEither

public CompletableFuture<Void> runAfterEither(CompletionStage<?> other,
                                              Runnable action)

Specified by:

runAfterEither in interface CompletionStage<V>

Overrides:

runAfterEither in class DelegatingCompletableFuture<V>

runAfterEitherAsync

public CompletableFuture<Void> runAfterEitherAsync(CompletionStage<?> other,
                                                   Runnable action)

Specified by:

runAfterEitherAsync in interface CompletionStage<V>

Overrides:

runAfterEitherAsync in class DelegatingCompletableFuture<V>

runAfterEitherAsync

public CompletableFuture<Void> runAfterEitherAsync(CompletionStage<?> other,
                                                   Runnable action,
                                                   Executor executor)

Specified by:

runAfterEitherAsync in interface CompletionStage<V>

Overrides:

runAfterEitherAsync in class DelegatingCompletableFuture<V>

thenCompose

public <U> CompletableFuture<U> thenCompose(Function<? super V,? extends CompletionStage<U>> fn)

Specified by:

thenCompose in interface CompletionStage<V>

Overrides:

thenCompose in class DelegatingCompletableFuture<V>

thenComposeAsync

public <U> CompletableFuture<U> thenComposeAsync(Function<? super V,? extends CompletionStage<U>> fn)

Specified by:

thenComposeAsync in interface CompletionStage<V>

Overrides:

thenComposeAsync in class DelegatingCompletableFuture<V>

thenComposeAsync

public <U> CompletableFuture<U> thenComposeAsync(Function<? super V,? extends CompletionStage<U>> fn,
                                                 Executor executor)

Specified by:

thenComposeAsync in interface CompletionStage<V>

Overrides:

thenComposeAsync in class DelegatingCompletableFuture<V>

whenComplete

public CompletableFuture<V> whenComplete(BiConsumer<? super V,? super Throwable> action)

Specified by:

whenComplete in interface CompletionStage<V>

Overrides:

whenComplete in class DelegatingCompletableFuture<V>

whenCompleteAsync

public CompletableFuture<V> whenCompleteAsync(BiConsumer<? super V,? super Throwable> action)

Specified by:

whenCompleteAsync in interface CompletionStage<V>

Overrides:

whenCompleteAsync in class DelegatingCompletableFuture<V>

whenCompleteAsync

public CompletableFuture<V> whenCompleteAsync(BiConsumer<? super V,? super Throwable> action,
                                              Executor executor)

Specified by:

whenCompleteAsync in interface CompletionStage<V>

Overrides:

whenCompleteAsync in class DelegatingCompletableFuture<V>

handle

public <U> CompletableFuture<U> handle(BiFunction<? super V,Throwable,? extends U> fn)

Specified by:

handle in interface CompletionStage<V>

Overrides:

handle in class DelegatingCompletableFuture<V>

handleAsync

public <U> CompletableFuture<U> handleAsync(BiFunction<? super V,Throwable,? extends U> fn)

Specified by:

handleAsync in interface CompletionStage<V>

Overrides:

handleAsync in class DelegatingCompletableFuture<V>

handleAsync

public <U> CompletableFuture<U> handleAsync(BiFunction<? super V,Throwable,? extends U> fn,
                                            Executor executor)

Specified by:

handleAsync in interface CompletionStage<V>

Overrides:

handleAsync in class DelegatingCompletableFuture<V>

toCompletableFuture

public CompletableFuture<V> toCompletableFuture()

Specified by:

toCompletableFuture in interface CompletionStage<V>

Overrides:

toCompletableFuture in class DelegatingCompletableFuture<V>

exceptionally

public CompletableFuture<V> exceptionally(Function<Throwable,? extends V> fn)

Specified by:

exceptionally in interface CompletionStage<V>

Overrides:

exceptionally in class DelegatingCompletableFuture<V>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

Overrides:

cancel in class DelegatingCompletableFuture<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

Overrides:

isCancelled in class DelegatingCompletableFuture<V>

isCompletedExceptionally

public boolean isCompletedExceptionally()

Overrides:

isCompletedExceptionally in class DelegatingCompletableFuture<V>

obtrudeValue

public void obtrudeValue(V value)

Overrides:

obtrudeValue in class DelegatingCompletableFuture<V>

obtrudeException

public void obtrudeException(Throwable ex)

Overrides:

obtrudeException in class DelegatingCompletableFuture<V>

getNumberOfDependents

public int getNumberOfDependents()

Overrides:

getNumberOfDependents in class DelegatingCompletableFuture<V>

toString

public String toString()

Overrides:

toString in class DelegatingCompletableFuture<V>