com.hazelcast.spi.impl

Class DelegatingCompletableFuture<V>

java.lang.Object

java.util.concurrent.CompletableFuture<V>

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

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

Type Parameters:

V -

All Implemented Interfaces:

CompletionStage<V>, Future<V>

Direct Known Subclasses:

ClientDelegatingFuture

public class DelegatingCompletableFuture<V>
extends InternalCompletableFuture<V>

A InternalCompletableFuture implementation that delegates the real logic to an underlying InternalCompletableFuture and decorates it with additional behavior:

1. change the returned value by setting the result
2. caching the deserialized content so that a deserialization only happens once. This should be used with care since this could lead to unexpected sharing of object instances if the same future is shared between threads.

Nested Class Summary

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

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor and Description
DelegatingCompletableFuture(SerializationService serializationService, CompletableFuture future)
DelegatingCompletableFuture(SerializationService serializationService, CompletableFuture future, V result)

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)
boolean	complete(V value)
boolean	completeExceptionally(Throwable ex)
CompletableFuture<V>	exceptionally(Function<Throwable,? extends V> fn)
V	get()
V	get(long timeout, TimeUnit unit)
Future	getDelegate()
V	getNow(V valueIfAbsent)
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()
boolean	isDone()
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	resolve(Object object)
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.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

DelegatingCompletableFuture

public DelegatingCompletableFuture(@Nonnull
                                   SerializationService serializationService,
                                   @Nonnull
                                   CompletableFuture future)

DelegatingCompletableFuture

public DelegatingCompletableFuture(@Nonnull
                                   SerializationService serializationService,
                                   @Nonnull
                                   CompletableFuture future,
                                   V result)

Method Detail

get

public V get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<V>

Overrides:

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

Throws:

InterruptedException

ExecutionException

TimeoutException

getNow

public V getNow(V valueIfAbsent)

Overrides:

getNow in class CompletableFuture<V>

join

public V join()

Overrides:

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

Returns:

the result

getDelegate

public Future getDelegate()

resolve

protected V resolve(Object object)

isDone

public boolean isDone()

Specified by:

isDone in interface Future<V>

Overrides:

isDone in class CompletableFuture<V>

complete

public boolean complete(V value)

Overrides:

complete in class CompletableFuture<V>

completeExceptionally

public boolean completeExceptionally(Throwable ex)

Overrides:

completeExceptionally in class CompletableFuture<V>

thenApply

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

Specified by:

thenApply in interface CompletionStage<V>

Overrides:

thenApply in class CompletableFuture<V>

thenApplyAsync

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

Specified by:

thenApplyAsync in interface CompletionStage<V>

Overrides:

thenApplyAsync in class CompletableFuture<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 CompletableFuture<V>

thenAccept

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

Specified by:

thenAccept in interface CompletionStage<V>

Overrides:

thenAccept in class CompletableFuture<V>

thenAcceptAsync

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

Specified by:

thenAcceptAsync in interface CompletionStage<V>

Overrides:

thenAcceptAsync in class CompletableFuture<V>

thenAcceptAsync

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

Specified by:

thenAcceptAsync in interface CompletionStage<V>

Overrides:

thenAcceptAsync in class CompletableFuture<V>

thenRun

public CompletableFuture<Void> thenRun(Runnable action)

Specified by:

thenRun in interface CompletionStage<V>

Overrides:

thenRun in class CompletableFuture<V>

thenRunAsync

public CompletableFuture<Void> thenRunAsync(Runnable action)

Specified by:

thenRunAsync in interface CompletionStage<V>

Overrides:

thenRunAsync in class CompletableFuture<V>

thenRunAsync

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

Specified by:

thenRunAsync in interface CompletionStage<V>

Overrides:

thenRunAsync in class CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<V>

runAfterBoth

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

Specified by:

runAfterBoth in interface CompletionStage<V>

Overrides:

runAfterBoth in class CompletableFuture<V>

runAfterBothAsync

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

Specified by:

runAfterBothAsync in interface CompletionStage<V>

Overrides:

runAfterBothAsync in class CompletableFuture<V>

runAfterBothAsync

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

Specified by:

runAfterBothAsync in interface CompletionStage<V>

Overrides:

runAfterBothAsync in class CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<V>

runAfterEither

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

Specified by:

runAfterEither in interface CompletionStage<V>

Overrides:

runAfterEither in class CompletableFuture<V>

runAfterEitherAsync

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

Specified by:

runAfterEitherAsync in interface CompletionStage<V>

Overrides:

runAfterEitherAsync in class CompletableFuture<V>

runAfterEitherAsync

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

Specified by:

runAfterEitherAsync in interface CompletionStage<V>

Overrides:

runAfterEitherAsync in class CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<V>

whenComplete

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

Specified by:

whenComplete in interface CompletionStage<V>

Overrides:

whenComplete in class CompletableFuture<V>

whenCompleteAsync

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

Specified by:

whenCompleteAsync in interface CompletionStage<V>

Overrides:

whenCompleteAsync in class CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<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 CompletableFuture<V>

toCompletableFuture

public CompletableFuture<V> toCompletableFuture()

Specified by:

toCompletableFuture in interface CompletionStage<V>

Overrides:

toCompletableFuture in class CompletableFuture<V>

exceptionally

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

Specified by:

exceptionally in interface CompletionStage<V>

Overrides:

exceptionally in class CompletableFuture<V>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

Overrides:

cancel in class CompletableFuture<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

Overrides:

isCancelled in class CompletableFuture<V>

isCompletedExceptionally

public boolean isCompletedExceptionally()

Overrides:

isCompletedExceptionally in class CompletableFuture<V>

obtrudeValue

public void obtrudeValue(V value)

Overrides:

obtrudeValue in class CompletableFuture<V>

obtrudeException

public void obtrudeException(Throwable ex)

Overrides:

obtrudeException in class CompletableFuture<V>

getNumberOfDependents

public int getNumberOfDependents()

Overrides:

getNumberOfDependents in class CompletableFuture<V>

toString

public String toString()

Overrides:

toString in class CompletableFuture<V>