com.vmware.vapi.bindings

Class CompletionStageFuture<T>

java.lang.Object

com.vmware.vapi.bindings.CompletionStageFuture<T>

Type Parameters:

T - The result type returned by the get() methods and the return type of various CompletionStage operations.

All Implemented Interfaces:

java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<T>

public class CompletionStageFuture<T>
extends java.lang.Object
implements java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<T>

This class exposes the Future and CompletionStage abstractions for binding clients.

Clients can consume the result of operation invocations as traditional blocking future or use it in event driven way through the CompletionStage.

This class delegates its functionality to CompletableFuture.

Constructor Summary

Constructors

Constructor and Description
CompletionStageFuture(java.util.concurrent.CompletableFuture<T> future)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletionStage<java.lang.Void>	acceptEither(java.util.concurrent.CompletionStage<? extends T> other, java.util.function.Consumer<? super T> action)
java.util.concurrent.CompletionStage<java.lang.Void>	acceptEitherAsync(java.util.concurrent.CompletionStage<? extends T> other, java.util.function.Consumer<? super T> action)
java.util.concurrent.CompletionStage<java.lang.Void>	acceptEitherAsync(java.util.concurrent.CompletionStage<? extends T> other, java.util.function.Consumer<? super T> action, java.util.concurrent.Executor executor)
<U> java.util.concurrent.CompletionStage<U>	applyToEither(java.util.concurrent.CompletionStage<? extends T> other, java.util.function.Function<? super T,U> fn)
<U> java.util.concurrent.CompletionStage<U>	applyToEitherAsync(java.util.concurrent.CompletionStage<? extends T> other, java.util.function.Function<? super T,U> fn)
<U> java.util.concurrent.CompletionStage<U>	applyToEitherAsync(java.util.concurrent.CompletionStage<? extends T> other, java.util.function.Function<? super T,U> fn, java.util.concurrent.Executor executor)
boolean	cancel(boolean mayInterruptIfRunning)
java.util.concurrent.CompletionStage<T>	exceptionally(java.util.function.Function<java.lang.Throwable,? extends T> fn)
T	get()
T	get(long timeout, java.util.concurrent.TimeUnit unit)
<U> java.util.concurrent.CompletionStage<U>	handle(java.util.function.BiFunction<? super T,java.lang.Throwable,? extends U> fn)
<U> java.util.concurrent.CompletionStage<U>	handleAsync(java.util.function.BiFunction<? super T,java.lang.Throwable,? extends U> fn)
<U> java.util.concurrent.CompletionStage<U>	handleAsync(java.util.function.BiFunction<? super T,java.lang.Throwable,? extends U> fn, java.util.concurrent.Executor executor)
boolean	isCancelled()
boolean	isDone()
java.util.concurrent.CompletionStage<java.lang.Void>	runAfterBoth(java.util.concurrent.CompletionStage<?> other, java.lang.Runnable action)
java.util.concurrent.CompletionStage<java.lang.Void>	runAfterBothAsync(java.util.concurrent.CompletionStage<?> other, java.lang.Runnable action)
java.util.concurrent.CompletionStage<java.lang.Void>	runAfterBothAsync(java.util.concurrent.CompletionStage<?> other, java.lang.Runnable action, java.util.concurrent.Executor executor)
java.util.concurrent.CompletionStage<java.lang.Void>	runAfterEither(java.util.concurrent.CompletionStage<?> other, java.lang.Runnable action)
java.util.concurrent.CompletionStage<java.lang.Void>	runAfterEitherAsync(java.util.concurrent.CompletionStage<?> other, java.lang.Runnable action)
java.util.concurrent.CompletionStage<java.lang.Void>	runAfterEitherAsync(java.util.concurrent.CompletionStage<?> other, java.lang.Runnable action, java.util.concurrent.Executor executor)
java.util.concurrent.CompletionStage<java.lang.Void>	thenAccept(java.util.function.Consumer<? super T> action)
java.util.concurrent.CompletionStage<java.lang.Void>	thenAcceptAsync(java.util.function.Consumer<? super T> action)
java.util.concurrent.CompletionStage<java.lang.Void>	thenAcceptAsync(java.util.function.Consumer<? super T> action, java.util.concurrent.Executor executor)
<U> java.util.concurrent.CompletionStage<java.lang.Void>	thenAcceptBoth(java.util.concurrent.CompletionStage<? extends U> other, java.util.function.BiConsumer<? super T,? super U> action)
<U> java.util.concurrent.CompletionStage<java.lang.Void>	thenAcceptBothAsync(java.util.concurrent.CompletionStage<? extends U> other, java.util.function.BiConsumer<? super T,? super U> action)
<U> java.util.concurrent.CompletionStage<java.lang.Void>	thenAcceptBothAsync(java.util.concurrent.CompletionStage<? extends U> other, java.util.function.BiConsumer<? super T,? super U> action, java.util.concurrent.Executor executor)
<U> java.util.concurrent.CompletionStage<U>	thenApply(java.util.function.Function<? super T,? extends U> fn)
<U> java.util.concurrent.CompletionStage<U>	thenApplyAsync(java.util.function.Function<? super T,? extends U> fn)
<U> java.util.concurrent.CompletionStage<U>	thenApplyAsync(java.util.function.Function<? super T,? extends U> fn, java.util.concurrent.Executor executor)
<U,V> java.util.concurrent.CompletionStage<V>	thenCombine(java.util.concurrent.CompletionStage<? extends U> other, java.util.function.BiFunction<? super T,? super U,? extends V> fn)
<U,V> java.util.concurrent.CompletionStage<V>	thenCombineAsync(java.util.concurrent.CompletionStage<? extends U> other, java.util.function.BiFunction<? super T,? super U,? extends V> fn)
<U,V> java.util.concurrent.CompletionStage<V>	thenCombineAsync(java.util.concurrent.CompletionStage<? extends U> other, java.util.function.BiFunction<? super T,? super U,? extends V> fn, java.util.concurrent.Executor executor)
<U> java.util.concurrent.CompletionStage<U>	thenCompose(java.util.function.Function<? super T,? extends java.util.concurrent.CompletionStage<U>> fn)
<U> java.util.concurrent.CompletionStage<U>	thenComposeAsync(java.util.function.Function<? super T,? extends java.util.concurrent.CompletionStage<U>> fn)
<U> java.util.concurrent.CompletionStage<U>	thenComposeAsync(java.util.function.Function<? super T,? extends java.util.concurrent.CompletionStage<U>> fn, java.util.concurrent.Executor executor)
java.util.concurrent.CompletionStage<java.lang.Void>	thenRun(java.lang.Runnable action)
java.util.concurrent.CompletionStage<java.lang.Void>	thenRunAsync(java.lang.Runnable action)
java.util.concurrent.CompletionStage<java.lang.Void>	thenRunAsync(java.lang.Runnable action, java.util.concurrent.Executor executor)
java.util.concurrent.CompletableFuture<T>	toCompletableFuture() Returns the CompletableFuture delegate used to implement this CompletionStageFuture.
java.util.concurrent.CompletionStage<T>	whenComplete(java.util.function.BiConsumer<? super T,? super java.lang.Throwable> action)
java.util.concurrent.CompletionStage<T>	whenCompleteAsync(java.util.function.BiConsumer<? super T,? super java.lang.Throwable> action)
java.util.concurrent.CompletionStage<T>	whenCompleteAsync(java.util.function.BiConsumer<? super T,? super java.lang.Throwable> action, java.util.concurrent.Executor executor)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompletionStageFuture

public CompletionStageFuture(java.util.concurrent.CompletableFuture<T> future)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<T>

get

public T get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public T get(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

thenApply

public <U> java.util.concurrent.CompletionStage<U> thenApply(java.util.function.Function<? super T,? extends U> fn)

Specified by:

thenApply in interface java.util.concurrent.CompletionStage<T>

thenApplyAsync

public <U> java.util.concurrent.CompletionStage<U> thenApplyAsync(java.util.function.Function<? super T,? extends U> fn)

Specified by:

thenApplyAsync in interface java.util.concurrent.CompletionStage<T>

thenApplyAsync

public <U> java.util.concurrent.CompletionStage<U> thenApplyAsync(java.util.function.Function<? super T,? extends U> fn,
                                                                  java.util.concurrent.Executor executor)

Specified by:

thenApplyAsync in interface java.util.concurrent.CompletionStage<T>

thenAccept

public java.util.concurrent.CompletionStage<java.lang.Void> thenAccept(java.util.function.Consumer<? super T> action)

Specified by:

thenAccept in interface java.util.concurrent.CompletionStage<T>

thenAcceptAsync

public java.util.concurrent.CompletionStage<java.lang.Void> thenAcceptAsync(java.util.function.Consumer<? super T> action)

Specified by:

thenAcceptAsync in interface java.util.concurrent.CompletionStage<T>

thenAcceptAsync

public java.util.concurrent.CompletionStage<java.lang.Void> thenAcceptAsync(java.util.function.Consumer<? super T> action,
                                                                            java.util.concurrent.Executor executor)

Specified by:

thenAcceptAsync in interface java.util.concurrent.CompletionStage<T>

thenRun

public java.util.concurrent.CompletionStage<java.lang.Void> thenRun(java.lang.Runnable action)

Specified by:

thenRun in interface java.util.concurrent.CompletionStage<T>

thenRunAsync

public java.util.concurrent.CompletionStage<java.lang.Void> thenRunAsync(java.lang.Runnable action)

Specified by:

thenRunAsync in interface java.util.concurrent.CompletionStage<T>

thenRunAsync

public java.util.concurrent.CompletionStage<java.lang.Void> thenRunAsync(java.lang.Runnable action,
                                                                         java.util.concurrent.Executor executor)

Specified by:

thenRunAsync in interface java.util.concurrent.CompletionStage<T>

thenCombine

public <U,V> java.util.concurrent.CompletionStage<V> thenCombine(java.util.concurrent.CompletionStage<? extends U> other,
                                                                 java.util.function.BiFunction<? super T,? super U,? extends V> fn)

Specified by:

thenCombine in interface java.util.concurrent.CompletionStage<T>

thenCombineAsync

public <U,V> java.util.concurrent.CompletionStage<V> thenCombineAsync(java.util.concurrent.CompletionStage<? extends U> other,
                                                                      java.util.function.BiFunction<? super T,? super U,? extends V> fn)

Specified by:

thenCombineAsync in interface java.util.concurrent.CompletionStage<T>

thenCombineAsync

public <U,V> java.util.concurrent.CompletionStage<V> thenCombineAsync(java.util.concurrent.CompletionStage<? extends U> other,
                                                                      java.util.function.BiFunction<? super T,? super U,? extends V> fn,
                                                                      java.util.concurrent.Executor executor)

Specified by:

thenCombineAsync in interface java.util.concurrent.CompletionStage<T>

thenAcceptBoth

public <U> java.util.concurrent.CompletionStage<java.lang.Void> thenAcceptBoth(java.util.concurrent.CompletionStage<? extends U> other,
                                                                               java.util.function.BiConsumer<? super T,? super U> action)

Specified by:

thenAcceptBoth in interface java.util.concurrent.CompletionStage<T>

thenAcceptBothAsync

public <U> java.util.concurrent.CompletionStage<java.lang.Void> thenAcceptBothAsync(java.util.concurrent.CompletionStage<? extends U> other,
                                                                                    java.util.function.BiConsumer<? super T,? super U> action)

Specified by:

thenAcceptBothAsync in interface java.util.concurrent.CompletionStage<T>

thenAcceptBothAsync

public <U> java.util.concurrent.CompletionStage<java.lang.Void> thenAcceptBothAsync(java.util.concurrent.CompletionStage<? extends U> other,
                                                                                    java.util.function.BiConsumer<? super T,? super U> action,
                                                                                    java.util.concurrent.Executor executor)

Specified by:

thenAcceptBothAsync in interface java.util.concurrent.CompletionStage<T>

runAfterBoth

public java.util.concurrent.CompletionStage<java.lang.Void> runAfterBoth(java.util.concurrent.CompletionStage<?> other,
                                                                         java.lang.Runnable action)

Specified by:

runAfterBoth in interface java.util.concurrent.CompletionStage<T>

runAfterBothAsync

public java.util.concurrent.CompletionStage<java.lang.Void> runAfterBothAsync(java.util.concurrent.CompletionStage<?> other,
                                                                              java.lang.Runnable action)

Specified by:

runAfterBothAsync in interface java.util.concurrent.CompletionStage<T>

runAfterBothAsync

public java.util.concurrent.CompletionStage<java.lang.Void> runAfterBothAsync(java.util.concurrent.CompletionStage<?> other,
                                                                              java.lang.Runnable action,
                                                                              java.util.concurrent.Executor executor)

Specified by:

runAfterBothAsync in interface java.util.concurrent.CompletionStage<T>

applyToEither

public <U> java.util.concurrent.CompletionStage<U> applyToEither(java.util.concurrent.CompletionStage<? extends T> other,
                                                                 java.util.function.Function<? super T,U> fn)

Specified by:

applyToEither in interface java.util.concurrent.CompletionStage<T>

applyToEitherAsync

public <U> java.util.concurrent.CompletionStage<U> applyToEitherAsync(java.util.concurrent.CompletionStage<? extends T> other,
                                                                      java.util.function.Function<? super T,U> fn)

Specified by:

applyToEitherAsync in interface java.util.concurrent.CompletionStage<T>

applyToEitherAsync

public <U> java.util.concurrent.CompletionStage<U> applyToEitherAsync(java.util.concurrent.CompletionStage<? extends T> other,
                                                                      java.util.function.Function<? super T,U> fn,
                                                                      java.util.concurrent.Executor executor)

Specified by:

applyToEitherAsync in interface java.util.concurrent.CompletionStage<T>

acceptEither

public java.util.concurrent.CompletionStage<java.lang.Void> acceptEither(java.util.concurrent.CompletionStage<? extends T> other,
                                                                         java.util.function.Consumer<? super T> action)

Specified by:

acceptEither in interface java.util.concurrent.CompletionStage<T>

acceptEitherAsync

public java.util.concurrent.CompletionStage<java.lang.Void> acceptEitherAsync(java.util.concurrent.CompletionStage<? extends T> other,
                                                                              java.util.function.Consumer<? super T> action)

Specified by:

acceptEitherAsync in interface java.util.concurrent.CompletionStage<T>

acceptEitherAsync

public java.util.concurrent.CompletionStage<java.lang.Void> acceptEitherAsync(java.util.concurrent.CompletionStage<? extends T> other,
                                                                              java.util.function.Consumer<? super T> action,
                                                                              java.util.concurrent.Executor executor)

Specified by:

acceptEitherAsync in interface java.util.concurrent.CompletionStage<T>

runAfterEither

public java.util.concurrent.CompletionStage<java.lang.Void> runAfterEither(java.util.concurrent.CompletionStage<?> other,
                                                                           java.lang.Runnable action)

Specified by:

runAfterEither in interface java.util.concurrent.CompletionStage<T>

runAfterEitherAsync

public java.util.concurrent.CompletionStage<java.lang.Void> runAfterEitherAsync(java.util.concurrent.CompletionStage<?> other,
                                                                                java.lang.Runnable action)

Specified by:

runAfterEitherAsync in interface java.util.concurrent.CompletionStage<T>

runAfterEitherAsync

public java.util.concurrent.CompletionStage<java.lang.Void> runAfterEitherAsync(java.util.concurrent.CompletionStage<?> other,
                                                                                java.lang.Runnable action,
                                                                                java.util.concurrent.Executor executor)

Specified by:

runAfterEitherAsync in interface java.util.concurrent.CompletionStage<T>

thenCompose

public <U> java.util.concurrent.CompletionStage<U> thenCompose(java.util.function.Function<? super T,? extends java.util.concurrent.CompletionStage<U>> fn)

Specified by:

thenCompose in interface java.util.concurrent.CompletionStage<T>

thenComposeAsync

public <U> java.util.concurrent.CompletionStage<U> thenComposeAsync(java.util.function.Function<? super T,? extends java.util.concurrent.CompletionStage<U>> fn)

Specified by:

thenComposeAsync in interface java.util.concurrent.CompletionStage<T>

thenComposeAsync

public <U> java.util.concurrent.CompletionStage<U> thenComposeAsync(java.util.function.Function<? super T,? extends java.util.concurrent.CompletionStage<U>> fn,
                                                                    java.util.concurrent.Executor executor)

Specified by:

thenComposeAsync in interface java.util.concurrent.CompletionStage<T>

exceptionally

public java.util.concurrent.CompletionStage<T> exceptionally(java.util.function.Function<java.lang.Throwable,? extends T> fn)

Specified by:

exceptionally in interface java.util.concurrent.CompletionStage<T>

whenComplete

public java.util.concurrent.CompletionStage<T> whenComplete(java.util.function.BiConsumer<? super T,? super java.lang.Throwable> action)

Specified by:

whenComplete in interface java.util.concurrent.CompletionStage<T>

whenCompleteAsync

public java.util.concurrent.CompletionStage<T> whenCompleteAsync(java.util.function.BiConsumer<? super T,? super java.lang.Throwable> action)

Specified by:

whenCompleteAsync in interface java.util.concurrent.CompletionStage<T>

whenCompleteAsync

public java.util.concurrent.CompletionStage<T> whenCompleteAsync(java.util.function.BiConsumer<? super T,? super java.lang.Throwable> action,
                                                                 java.util.concurrent.Executor executor)

Specified by:

whenCompleteAsync in interface java.util.concurrent.CompletionStage<T>

handle

public <U> java.util.concurrent.CompletionStage<U> handle(java.util.function.BiFunction<? super T,java.lang.Throwable,? extends U> fn)

Specified by:

handle in interface java.util.concurrent.CompletionStage<T>

handleAsync

public <U> java.util.concurrent.CompletionStage<U> handleAsync(java.util.function.BiFunction<? super T,java.lang.Throwable,? extends U> fn)

Specified by:

handleAsync in interface java.util.concurrent.CompletionStage<T>

handleAsync

public <U> java.util.concurrent.CompletionStage<U> handleAsync(java.util.function.BiFunction<? super T,java.lang.Throwable,? extends U> fn,
                                                               java.util.concurrent.Executor executor)

Specified by:

handleAsync in interface java.util.concurrent.CompletionStage<T>

toCompletableFuture

public java.util.concurrent.CompletableFuture<T> toCompletableFuture()

Returns the CompletableFuture delegate used to implement this CompletionStageFuture.

Specified by:

toCompletableFuture in interface java.util.concurrent.CompletionStage<T>

Returns:

the CompletableFuture