oracle.pgx.api

Class PgxFuture<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

oracle.pgx.api.PgxFuture<T>

All Implemented Interfaces:

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

public class PgxFuture<T>
extends java.util.concurrent.CompletableFuture<T>

A PGX-specific extension of CompletableFuture

Nested Class Summary

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

java.util.concurrent.CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor and Description
PgxFuture()

Method Summary

Modifier and Type	Method and Description
static <T> PgxFuture<java.lang.Void>	allOf(java.util.List<PgxFuture<T>> promises)
boolean	cancel()
PgxFuture<T>	cancelOn(PgxFuture promise) If given promise completes exceptionally because it was canceled, cancel() gets called on this promise as well.
static <T> PgxFuture<T>	completedFuture(T arg)
static <T> PgxFuture<T>	exceptionallyCompletedFuture(java.lang.Throwable throwable)
T	get()
T	get(long timeout, java.util.concurrent.TimeUnit unit)
T	getNow(T valueIfAbsent)
boolean	isConsumed()
T	join()
PgxFuture<java.lang.Void>	thenAccept(java.util.function.Consumer<? super T> block)
<U> PgxFuture<U>	thenApply(java.util.function.Function<? super T,? extends U> function)
<U> PgxFuture<U>	thenApplyAsync(java.util.function.Function<? super T,? extends U> function, java.util.concurrent.Executor executor)
<U,V> PgxFuture<V>	thenCombine(java.util.concurrent.CompletableFuture<? extends U> other, java.util.function.BiFunction<? super T,? super U,? extends V> function)
PgxFuture<T>	thenComplete(PgxFuture<T> promise) completes the given promise whenever this completes.
PgxFuture<T>	thenComplete(PgxFuture<T> promise, java.lang.Runnable cleanup) completes the given promise whenever this completes.
<U> PgxFuture<U>	thenCompose(java.util.function.Function<? super T,? extends java.util.concurrent.CompletionStage<U>> function)

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeExceptionally, exceptionally, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, obtrudeException, obtrudeValue, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PgxFuture

public PgxFuture()

Method Detail

allOf

public static <T> PgxFuture<java.lang.Void> allOf(java.util.List<PgxFuture<T>> promises)

cancel

public boolean cancel()

cancelOn

public PgxFuture<T> cancelOn(PgxFuture promise)

If given promise completes exceptionally because it was canceled, cancel() gets called on this promise as well.

Parameters:

promise - If given promise completes exceptionally because it was canceled, cancel() gets called on this promise as well. If given promise completes exceptionally (regardless of the causing exception) and this promise has started or is done, rollback() gets called on this promise.

Returns:

this

completedFuture

public static <T> PgxFuture<T> completedFuture(T arg)

exceptionallyCompletedFuture

public static <T> PgxFuture<T> exceptionallyCompletedFuture(java.lang.Throwable throwable)

get

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

Specified by:

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

Overrides:

get in class java.util.concurrent.CompletableFuture<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>

Overrides:

get in class java.util.concurrent.CompletableFuture<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

getNow

public T getNow(T valueIfAbsent)

Overrides:

getNow in class java.util.concurrent.CompletableFuture<T>

isConsumed

public boolean isConsumed()

join

public T join()

Overrides:

join in class java.util.concurrent.CompletableFuture<T>

thenAccept

public PgxFuture<java.lang.Void> thenAccept(java.util.function.Consumer<? super T> block)

Specified by:

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

Overrides:

thenAccept in class java.util.concurrent.CompletableFuture<T>

thenApply

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

Specified by:

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

Overrides:

thenApply in class java.util.concurrent.CompletableFuture<T>

thenApplyAsync

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

Specified by:

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

Overrides:

thenApplyAsync in class java.util.concurrent.CompletableFuture<T>

thenCombine

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

thenComplete

public PgxFuture<T> thenComplete(PgxFuture<T> promise)

completes the given promise whenever this completes.

If this completes exceptionally, the given promise is completed exceptionally as well.

Parameters:

promise - the promise

Returns:

the pgx future

thenComplete

public PgxFuture<T> thenComplete(PgxFuture<T> promise,
                                 java.lang.Runnable cleanup)

completes the given promise whenever this completes.

If this completes exceptionally, the given promise is completed exceptionally as well.

Parameters:

promise -

cleanup - to be run upon completion (can be null)

Returns:

the given promise

thenCompose

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

Specified by:

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

Overrides:

thenCompose in class java.util.concurrent.CompletableFuture<T>