Package io.deephaven.util

Interface CompletionStageFuture<T>

Type Parameters:

T - The result type returned by this future's Future.get()

All Superinterfaces:

CompletionStage<T>, Future<T>

All Known Implementing Classes:

CompletionStageFutureImpl

public interface CompletionStageFuture<T>
extends Future<T>, CompletionStage<T>

A safe version of CompletableFuture that does not expose the completion API.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	CompletionStageFuture.Resolver<T>

Method Summary

Modifier and Type	Method	Description
CompletionStageFuture<Void>	acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)
CompletionStageFuture<Void>	acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)
CompletionStageFuture<Void>	acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
<U> CompletionStageFuture<U>	applyToEither(CompletionStage<? extends T> other, Function<? super T,U> fn)
<U> CompletionStageFuture<U>	applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T,U> fn)
<U> CompletionStageFuture<U>	applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T,U> fn, Executor executor)
static <U> CompletionStageFuture<U>	completedFuture(U value)	Returns a new CompletionStageFuture that is already completed with the given value.
CompletionStageFuture<T>	exceptionally(Function<Throwable,? extends T> fn)
static <U> CompletionStageFuture<U>	failedFuture(Throwable ex)	Returns a new CompletionStageFuture that is already completed exceptionally with the given exception.
<U> CompletionStageFuture<U>	handle(BiFunction<? super T,Throwable,? extends U> fn)
<U> CompletionStageFuture<U>	handleAsync(BiFunction<? super T,Throwable,? extends U> fn)
<U> CompletionStageFuture<U>	handleAsync(BiFunction<? super T,Throwable,? extends U> fn, Executor executor)
static <T> CompletionStageFuture.Resolver<T>	make()	Create a new incomplete future.
CompletionStageFuture<Void>	runAfterBoth(CompletionStage<?> other, Runnable action)
CompletionStageFuture<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action)
CompletionStageFuture<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor)
CompletionStageFuture<Void>	runAfterEither(CompletionStage<?> other, Runnable action)
CompletionStageFuture<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action)
CompletionStageFuture<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor)
CompletionStageFuture<Void>	thenAccept(Consumer<? super T> action)
CompletionStageFuture<Void>	thenAcceptAsync(Consumer<? super T> action)
CompletionStageFuture<Void>	thenAcceptAsync(Consumer<? super T> action, Executor executor)
<U> CompletionStageFuture<Void>	thenAcceptBoth(CompletionStage<? extends U> other, BiConsumer<? super T,? super U> action)
<U> CompletionStageFuture<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T,? super U> action)
<U> CompletionStageFuture<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T,? super U> action, Executor executor)
<U> CompletionStageFuture<U>	thenApply(Function<? super T,? extends U> fn)
<U> CompletionStageFuture<U>	thenApplyAsync(Function<? super T,? extends U> fn)
<U> CompletionStageFuture<U>	thenApplyAsync(Function<? super T,? extends U> fn, Executor executor)
<U, V> CompletionStageFuture<V>	thenCombine(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn)
<U, V> CompletionStageFuture<V>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn)
<U, V> CompletionStageFuture<V>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn, Executor executor)
<U> CompletionStageFuture<U>	thenCompose(Function<? super T,? extends CompletionStage<U>> fn)
<U> CompletionStageFuture<U>	thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn)
<U> CompletionStageFuture<U>	thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn, Executor executor)
CompletionStageFuture<Void>	thenRun(Runnable action)
CompletionStageFuture<Void>	thenRunAsync(Runnable action)
CompletionStageFuture<Void>	thenRunAsync(Runnable action, Executor executor)
CompletionStageFuture<T>	whenComplete(BiConsumer<? super T,? super Throwable> action)
CompletionStageFuture<T>	whenCompleteAsync(BiConsumer<? super T,? super Throwable> action)
CompletionStageFuture<T>	whenCompleteAsync(BiConsumer<? super T,? super Throwable> action, Executor executor)

Methods inherited from interface java.util.concurrent.CompletionStage

exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, toCompletableFuture

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Method Details

make

static <T> CompletionStageFuture.Resolver<T> make()

Create a new incomplete future.

Type Parameters:

T - The result type returned by this future's Future.get()

Returns:

a resolver for the future

completedFuture

static <U> CompletionStageFuture<U> completedFuture(U value)

Returns a new CompletionStageFuture that is already completed with the given value.

Type Parameters:

U - the type of the value

Parameters:

value - the value

Returns:

the completed CompletionStageFuture

See Also:

• CompletableFuture.completedFuture(Object)

failedFuture

static <U> CompletionStageFuture<U> failedFuture(Throwable ex)

Returns a new CompletionStageFuture that is already completed exceptionally with the given exception.

Type Parameters:

U - the type of the value

Parameters:

ex - the exception

Returns:

the exceptionally completed CompletionStageFuture

See Also:

• CompletableFuture.failedFuture(Throwable)

thenApply

<U> CompletionStageFuture<U> thenApply(Function<? super T,? extends U> fn)

Specified by:

thenApply in interface CompletionStage<T>

thenApplyAsync

<U> CompletionStageFuture<U> thenApplyAsync(Function<? super T,? extends U> fn)

Specified by:

thenApplyAsync in interface CompletionStage<T>

thenApplyAsync

<U> CompletionStageFuture<U> thenApplyAsync(Function<? super T,? extends U> fn,
 Executor executor)

Specified by:

thenApplyAsync in interface CompletionStage<T>

thenAccept

CompletionStageFuture<Void> thenAccept(Consumer<? super T> action)

Specified by:

thenAccept in interface CompletionStage<T>

thenAcceptAsync

CompletionStageFuture<Void> thenAcceptAsync(Consumer<? super T> action)

Specified by:

thenAcceptAsync in interface CompletionStage<T>

thenAcceptAsync

CompletionStageFuture<Void> thenAcceptAsync(Consumer<? super T> action,
 Executor executor)

Specified by:

thenAcceptAsync in interface CompletionStage<T>

thenRun

CompletionStageFuture<Void> thenRun(Runnable action)

Specified by:

thenRun in interface CompletionStage<T>

thenRunAsync

CompletionStageFuture<Void> thenRunAsync(Runnable action)

Specified by:

thenRunAsync in interface CompletionStage<T>

thenRunAsync

CompletionStageFuture<Void> thenRunAsync(Runnable action,
 Executor executor)

Specified by:

thenRunAsync in interface CompletionStage<T>

thenCombine

<U,
V> CompletionStageFuture<V> thenCombine(CompletionStage<? extends U> other,
 BiFunction<? super T,? super U,? extends V> fn)

Specified by:

thenCombine in interface CompletionStage<T>

thenCombineAsync

<U,
V> CompletionStageFuture<V> thenCombineAsync(CompletionStage<? extends U> other,
 BiFunction<? super T,? super U,? extends V> fn)

Specified by:

thenCombineAsync in interface CompletionStage<T>

thenCombineAsync

<U,
V> CompletionStageFuture<V> thenCombineAsync(CompletionStage<? extends U> other,
 BiFunction<? super T,? super U,? extends V> fn,
 Executor executor)

Specified by:

thenCombineAsync in interface CompletionStage<T>

thenAcceptBoth

<U> CompletionStageFuture<Void> thenAcceptBoth(CompletionStage<? extends U> other,
 BiConsumer<? super T,? super U> action)

Specified by:

thenAcceptBoth in interface CompletionStage<T>

thenAcceptBothAsync

<U> CompletionStageFuture<Void> thenAcceptBothAsync(CompletionStage<? extends U> other,
 BiConsumer<? super T,? super U> action)

Specified by:

thenAcceptBothAsync in interface CompletionStage<T>

thenAcceptBothAsync

<U> CompletionStageFuture<Void> thenAcceptBothAsync(CompletionStage<? extends U> other,
 BiConsumer<? super T,? super U> action,
 Executor executor)

Specified by:

thenAcceptBothAsync in interface CompletionStage<T>

runAfterBoth

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

Specified by:

runAfterBoth in interface CompletionStage<T>

runAfterBothAsync

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

Specified by:

runAfterBothAsync in interface CompletionStage<T>

runAfterBothAsync

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

Specified by:

runAfterBothAsync in interface CompletionStage<T>

applyToEither

<U> CompletionStageFuture<U> applyToEither(CompletionStage<? extends T> other,
 Function<? super T,U> fn)

Specified by:

applyToEither in interface CompletionStage<T>

applyToEitherAsync

<U> CompletionStageFuture<U> applyToEitherAsync(CompletionStage<? extends T> other,
 Function<? super T,U> fn)

Specified by:

applyToEitherAsync in interface CompletionStage<T>

applyToEitherAsync

<U> CompletionStageFuture<U> applyToEitherAsync(CompletionStage<? extends T> other,
 Function<? super T,U> fn,
 Executor executor)

Specified by:

applyToEitherAsync in interface CompletionStage<T>

acceptEither

CompletionStageFuture<Void> acceptEither(CompletionStage<? extends T> other,
 Consumer<? super T> action)

Specified by:

acceptEither in interface CompletionStage<T>

acceptEitherAsync

CompletionStageFuture<Void> acceptEitherAsync(CompletionStage<? extends T> other,
 Consumer<? super T> action)

Specified by:

acceptEitherAsync in interface CompletionStage<T>

acceptEitherAsync

CompletionStageFuture<Void> acceptEitherAsync(CompletionStage<? extends T> other,
 Consumer<? super T> action,
 Executor executor)

Specified by:

acceptEitherAsync in interface CompletionStage<T>

runAfterEither

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

Specified by:

runAfterEither in interface CompletionStage<T>

runAfterEitherAsync

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

Specified by:

runAfterEitherAsync in interface CompletionStage<T>

runAfterEitherAsync

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

Specified by:

runAfterEitherAsync in interface CompletionStage<T>

thenCompose

<U> CompletionStageFuture<U> thenCompose(Function<? super T,? extends CompletionStage<U>> fn)

Specified by:

thenCompose in interface CompletionStage<T>

thenComposeAsync

<U> CompletionStageFuture<U> thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn)

Specified by:

thenComposeAsync in interface CompletionStage<T>

thenComposeAsync

<U> CompletionStageFuture<U> thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn,
 Executor executor)

Specified by:

thenComposeAsync in interface CompletionStage<T>

handle

<U> CompletionStageFuture<U> handle(BiFunction<? super T,Throwable,? extends U> fn)

Specified by:

handle in interface CompletionStage<T>

handleAsync

<U> CompletionStageFuture<U> handleAsync(BiFunction<? super T,Throwable,? extends U> fn)

Specified by:

handleAsync in interface CompletionStage<T>

handleAsync

<U> CompletionStageFuture<U> handleAsync(BiFunction<? super T,Throwable,? extends U> fn,
 Executor executor)

Specified by:

handleAsync in interface CompletionStage<T>

whenComplete

CompletionStageFuture<T> whenComplete(BiConsumer<? super T,? super Throwable> action)

Specified by:

whenComplete in interface CompletionStage<T>

whenCompleteAsync

CompletionStageFuture<T> whenCompleteAsync(BiConsumer<? super T,? super Throwable> action)

Specified by:

whenCompleteAsync in interface CompletionStage<T>

whenCompleteAsync

CompletionStageFuture<T> whenCompleteAsync(BiConsumer<? super T,? super Throwable> action,
 Executor executor)

Specified by:

whenCompleteAsync in interface CompletionStage<T>

exceptionally

CompletionStageFuture<T> exceptionally(Function<Throwable,? extends T> fn)

Specified by:

exceptionally in interface CompletionStage<T>