Class CentralisedFuture<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

space.arim.omnibus.util.concurrent.CentralisedFuture<T>

Type Parameters:

T - the result type of the future

All Implemented Interfaces:

CompletionStage<T>, Future<T>, ReactionStage<T>

Direct Known Subclasses:

BaseCentralisedFuture, IndifferentCentralisedFuture

public abstract class CentralisedFuture<T>
extends CompletableFuture<T>
implements ReactionStage<T>

An extended CompletableFuture API implementing ReactionStage. This future is centralised in that its construction is intended to be undertaken by FactoryOfTheFuture implementations.

Author:

A248

Nested Class Summary

Nested classes/interfaces inherited from class CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor	Description
CentralisedFuture()

Method Summary

Modifier and Type	Method	Description
CentralisedFuture<Void>	acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)
CentralisedFuture<Void>	acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)
CentralisedFuture<Void>	acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
abstract CentralisedFuture<Void>	acceptEitherSync(CompletionStage<? extends T> other, Consumer<? super T> action)
<U> CentralisedFuture<U>	applyToEither(CompletionStage<? extends T> other, Function<? super T, U> fn)
<U> CentralisedFuture<U>	applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T, U> fn)
<U> CentralisedFuture<U>	applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor)
abstract <U> CentralisedFuture<U>	applyToEitherSync(CompletionStage<? extends T> other, Function<? super T, U> fn)
CentralisedFuture<T>	completeAsync(Supplier<? extends T> supplier)
CentralisedFuture<T>	completeAsync(Supplier<? extends T> supplier, Executor executor)
CentralisedFuture<T>	completeOnTimeout(T value, long timeout, TimeUnit unit)
abstract CentralisedFuture<T>	completeSync(Supplier<? extends T> supplier)
CentralisedFuture<T>	copy()
CentralisedFuture<T>	exceptionally(Function<Throwable, ? extends T> fn)
<U> CentralisedFuture<U>	handle(BiFunction<? super T, Throwable, ? extends U> fn)
<U> CentralisedFuture<U>	handleAsync(BiFunction<? super T, Throwable, ? extends U> fn)
<U> CentralisedFuture<U>	handleAsync(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor)
abstract <U> CentralisedFuture<U>	handleSync(BiFunction<? super T, Throwable, ? extends U> fn)
abstract ReactionStage<T>	minimalCompletionStage()
abstract <U> CentralisedFuture<U>	newIncompleteFuture()
CentralisedFuture<T>	orTimeout(long timeout, TimeUnit unit)
CentralisedFuture<Void>	runAfterBoth(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor)
abstract CentralisedFuture<Void>	runAfterBothSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	runAfterEither(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor)
abstract CentralisedFuture<Void>	runAfterEitherSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	thenAccept(Consumer<? super T> action)
CentralisedFuture<Void>	thenAcceptAsync(Consumer<? super T> action)
CentralisedFuture<Void>	thenAcceptAsync(Consumer<? super T> action, Executor executor)
<U> CentralisedFuture<Void>	thenAcceptBoth(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
<U> CentralisedFuture<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
<U> CentralisedFuture<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor)
abstract <U> CentralisedFuture<Void>	thenAcceptBothSync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
abstract CentralisedFuture<Void>	thenAcceptSync(Consumer<? super T> action)
<U> CentralisedFuture<U>	thenApply(Function<? super T, ? extends U> fn)
<U> CentralisedFuture<U>	thenApplyAsync(Function<? super T, ? extends U> fn)
<U> CentralisedFuture<U>	thenApplyAsync(Function<? super T, ? extends U> fn, Executor executor)
abstract <U> CentralisedFuture<U>	thenApplySync(Function<? super T, ? extends U> fn)
<U,V> CentralisedFuture<V>	thenCombine(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U,V> CentralisedFuture<V>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U,V> CentralisedFuture<V>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn, Executor executor)
abstract <U,V> CentralisedFuture<V>	thenCombineSync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U> CentralisedFuture<U>	thenCompose(Function<? super T, ? extends CompletionStage<U>> fn)
<U> CentralisedFuture<U>	thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn)
<U> CentralisedFuture<U>	thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor)
abstract <U> CentralisedFuture<U>	thenComposeSync(Function<? super T, ? extends CompletionStage<U>> fn)
CentralisedFuture<Void>	thenRun(Runnable action)
CentralisedFuture<Void>	thenRunAsync(Runnable action)
CentralisedFuture<Void>	thenRunAsync(Runnable action, Executor executor)
abstract CentralisedFuture<Void>	thenRunSync(Runnable action)
CentralisedFuture<T>	toCompletableFuture()	Converts to an equivalent CentralisedFuture with the same completion properties as this.
CentralisedFuture<T>	whenComplete(BiConsumer<? super T, ? super Throwable> action)
CentralisedFuture<T>	whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action)
CentralisedFuture<T>	whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor)
abstract CentralisedFuture<T>	whenCompleteSync(BiConsumer<? super T, ? super Throwable> action)

Methods inherited from class CompletableFuture

allOf, anyOf, cancel, complete, completedFuture, completedStage, completeExceptionally, defaultExecutor, delayedExecutor, delayedExecutor, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, isCancelled, isCompletedExceptionally, isDone, join, obtrudeException, obtrudeValue, runAsync, runAsync, supplyAsync, supplyAsync, toString

Methods inherited from class Object

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

Constructor Details

CentralisedFuture

public CentralisedFuture()

Method Details

newIncompleteFuture

public abstract <U> CentralisedFuture<U> newIncompleteFuture()

Overrides:

newIncompleteFuture in class CompletableFuture<T>

minimalCompletionStage

public abstract ReactionStage<T> minimalCompletionStage()

Overrides:

minimalCompletionStage in class CompletableFuture<T>

thenApply

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

Specified by:

thenApply in interface CompletionStage<T>

Specified by:

thenApply in interface ReactionStage<T>

Overrides:

thenApply in class CompletableFuture<T>

thenApplyAsync

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

Specified by:

thenApplyAsync in interface CompletionStage<T>

Specified by:

thenApplyAsync in interface ReactionStage<T>

Overrides:

thenApplyAsync in class CompletableFuture<T>

thenApplyAsync

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

Specified by:

thenApplyAsync in interface CompletionStage<T>

Specified by:

thenApplyAsync in interface ReactionStage<T>

Overrides:

thenApplyAsync in class CompletableFuture<T>

thenApplySync

public abstract <U> CentralisedFuture<U> thenApplySync(Function<? super T, ? extends U> fn)

Specified by:

thenApplySync in interface ReactionStage<T>

thenAccept

public CentralisedFuture<Void> thenAccept(Consumer<? super T> action)

Specified by:

thenAccept in interface CompletionStage<T>

Specified by:

thenAccept in interface ReactionStage<T>

Overrides:

thenAccept in class CompletableFuture<T>

thenAcceptAsync

public CentralisedFuture<Void> thenAcceptAsync(Consumer<? super T> action)

Specified by:

thenAcceptAsync in interface CompletionStage<T>

Specified by:

thenAcceptAsync in interface ReactionStage<T>

Overrides:

thenAcceptAsync in class CompletableFuture<T>

thenAcceptAsync

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

Specified by:

thenAcceptAsync in interface CompletionStage<T>

Specified by:

thenAcceptAsync in interface ReactionStage<T>

Overrides:

thenAcceptAsync in class CompletableFuture<T>

thenAcceptSync

public abstract CentralisedFuture<Void> thenAcceptSync(Consumer<? super T> action)

Specified by:

thenAcceptSync in interface ReactionStage<T>

thenRun

public CentralisedFuture<Void> thenRun(Runnable action)

Specified by:

thenRun in interface CompletionStage<T>

Specified by:

thenRun in interface ReactionStage<T>

Overrides:

thenRun in class CompletableFuture<T>

thenRunAsync

public CentralisedFuture<Void> thenRunAsync(Runnable action)

Specified by:

thenRunAsync in interface CompletionStage<T>

Specified by:

thenRunAsync in interface ReactionStage<T>

Overrides:

thenRunAsync in class CompletableFuture<T>

thenRunAsync

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

Specified by:

thenRunAsync in interface CompletionStage<T>

Specified by:

thenRunAsync in interface ReactionStage<T>

Overrides:

thenRunAsync in class CompletableFuture<T>

thenRunSync

public abstract CentralisedFuture<Void> thenRunSync(Runnable action)

Specified by:

thenRunSync in interface ReactionStage<T>

thenCombine

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

Specified by:

thenCombine in interface CompletionStage<T>

Specified by:

thenCombine in interface ReactionStage<T>

Overrides:

thenCombine in class CompletableFuture<T>

thenCombineAsync

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

Specified by:

thenCombineAsync in interface CompletionStage<T>

Specified by:

thenCombineAsync in interface ReactionStage<T>

Overrides:

thenCombineAsync in class CompletableFuture<T>

thenCombineAsync

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

Specified by:

thenCombineAsync in interface CompletionStage<T>

Specified by:

thenCombineAsync in interface ReactionStage<T>

Overrides:

thenCombineAsync in class CompletableFuture<T>

thenCombineSync

public abstract <U,V> CentralisedFuture<V> thenCombineSync(CompletionStage<? extends U> other,
 BiFunction<? super T, ? super U, ? extends V> fn)

Specified by:

thenCombineSync in interface ReactionStage<T>

thenAcceptBoth

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

Specified by:

thenAcceptBoth in interface CompletionStage<T>

Specified by:

thenAcceptBoth in interface ReactionStage<T>

Overrides:

thenAcceptBoth in class CompletableFuture<T>

thenAcceptBothAsync

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

Specified by:

thenAcceptBothAsync in interface CompletionStage<T>

Specified by:

thenAcceptBothAsync in interface ReactionStage<T>

Overrides:

thenAcceptBothAsync in class CompletableFuture<T>

thenAcceptBothAsync

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

Specified by:

thenAcceptBothAsync in interface CompletionStage<T>

Specified by:

thenAcceptBothAsync in interface ReactionStage<T>

Overrides:

thenAcceptBothAsync in class CompletableFuture<T>

thenAcceptBothSync

public abstract <U> CentralisedFuture<Void> thenAcceptBothSync(CompletionStage<? extends U> other,
 BiConsumer<? super T, ? super U> action)

Specified by:

thenAcceptBothSync in interface ReactionStage<T>

runAfterBoth

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

Specified by:

runAfterBoth in interface CompletionStage<T>

Specified by:

runAfterBoth in interface ReactionStage<T>

Overrides:

runAfterBoth in class CompletableFuture<T>

runAfterBothAsync

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

Specified by:

runAfterBothAsync in interface CompletionStage<T>

Specified by:

runAfterBothAsync in interface ReactionStage<T>

Overrides:

runAfterBothAsync in class CompletableFuture<T>

runAfterBothAsync

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

Specified by:

runAfterBothAsync in interface CompletionStage<T>

Specified by:

runAfterBothAsync in interface ReactionStage<T>

Overrides:

runAfterBothAsync in class CompletableFuture<T>

runAfterBothSync

public abstract CentralisedFuture<Void> runAfterBothSync(CompletionStage<?> other,
 Runnable action)

Specified by:

runAfterBothSync in interface ReactionStage<T>

applyToEither

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

Specified by:

applyToEither in interface CompletionStage<T>

Specified by:

applyToEither in interface ReactionStage<T>

Overrides:

applyToEither in class CompletableFuture<T>

applyToEitherAsync

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

Specified by:

applyToEitherAsync in interface CompletionStage<T>

Specified by:

applyToEitherAsync in interface ReactionStage<T>

Overrides:

applyToEitherAsync in class CompletableFuture<T>

applyToEitherAsync

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

Specified by:

applyToEitherAsync in interface CompletionStage<T>

Specified by:

applyToEitherAsync in interface ReactionStage<T>

Overrides:

applyToEitherAsync in class CompletableFuture<T>

applyToEitherSync

public abstract <U> CentralisedFuture<U> applyToEitherSync(CompletionStage<? extends T> other,
 Function<? super T, U> fn)

Specified by:

applyToEitherSync in interface ReactionStage<T>

acceptEither

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

Specified by:

acceptEither in interface CompletionStage<T>

Specified by:

acceptEither in interface ReactionStage<T>

Overrides:

acceptEither in class CompletableFuture<T>

acceptEitherAsync

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

Specified by:

acceptEitherAsync in interface CompletionStage<T>

Specified by:

acceptEitherAsync in interface ReactionStage<T>

Overrides:

acceptEitherAsync in class CompletableFuture<T>

acceptEitherAsync

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

Specified by:

acceptEitherAsync in interface CompletionStage<T>

Specified by:

acceptEitherAsync in interface ReactionStage<T>

Overrides:

acceptEitherAsync in class CompletableFuture<T>

acceptEitherSync

public abstract CentralisedFuture<Void> acceptEitherSync(CompletionStage<? extends T> other,
 Consumer<? super T> action)

Specified by:

acceptEitherSync in interface ReactionStage<T>

runAfterEither

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

Specified by:

runAfterEither in interface CompletionStage<T>

Specified by:

runAfterEither in interface ReactionStage<T>

Overrides:

runAfterEither in class CompletableFuture<T>

runAfterEitherAsync

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

Specified by:

runAfterEitherAsync in interface CompletionStage<T>

Specified by:

runAfterEitherAsync in interface ReactionStage<T>

Overrides:

runAfterEitherAsync in class CompletableFuture<T>

runAfterEitherAsync

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

Specified by:

runAfterEitherAsync in interface CompletionStage<T>

Specified by:

runAfterEitherAsync in interface ReactionStage<T>

Overrides:

runAfterEitherAsync in class CompletableFuture<T>

runAfterEitherSync

public abstract CentralisedFuture<Void> runAfterEitherSync(CompletionStage<?> other,
 Runnable action)

Specified by:

runAfterEitherSync in interface ReactionStage<T>

thenCompose

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

Specified by:

thenCompose in interface CompletionStage<T>

Specified by:

thenCompose in interface ReactionStage<T>

Overrides:

thenCompose in class CompletableFuture<T>

thenComposeAsync

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

Specified by:

thenComposeAsync in interface CompletionStage<T>

Specified by:

thenComposeAsync in interface ReactionStage<T>

Overrides:

thenComposeAsync in class CompletableFuture<T>

thenComposeAsync

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

Specified by:

thenComposeAsync in interface CompletionStage<T>

Specified by:

thenComposeAsync in interface ReactionStage<T>

Overrides:

thenComposeAsync in class CompletableFuture<T>

thenComposeSync

public abstract <U> CentralisedFuture<U> thenComposeSync(Function<? super T, ? extends CompletionStage<U>> fn)

Specified by:

thenComposeSync in interface ReactionStage<T>

whenComplete

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

Specified by:

whenComplete in interface CompletionStage<T>

Specified by:

whenComplete in interface ReactionStage<T>

Overrides:

whenComplete in class CompletableFuture<T>

whenCompleteAsync

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

Specified by:

whenCompleteAsync in interface CompletionStage<T>

Specified by:

whenCompleteAsync in interface ReactionStage<T>

Overrides:

whenCompleteAsync in class CompletableFuture<T>

whenCompleteAsync

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

Specified by:

whenCompleteAsync in interface CompletionStage<T>

Specified by:

whenCompleteAsync in interface ReactionStage<T>

Overrides:

whenCompleteAsync in class CompletableFuture<T>

whenCompleteSync

public abstract CentralisedFuture<T> whenCompleteSync(BiConsumer<? super T, ? super Throwable> action)

Specified by:

whenCompleteSync in interface ReactionStage<T>

handle

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

Specified by:

handle in interface CompletionStage<T>

Specified by:

handle in interface ReactionStage<T>

Overrides:

handle in class CompletableFuture<T>

handleAsync

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

Specified by:

handleAsync in interface CompletionStage<T>

Specified by:

handleAsync in interface ReactionStage<T>

Overrides:

handleAsync in class CompletableFuture<T>

handleAsync

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

Specified by:

handleAsync in interface CompletionStage<T>

Specified by:

handleAsync in interface ReactionStage<T>

Overrides:

handleAsync in class CompletableFuture<T>

handleSync

public abstract <U> CentralisedFuture<U> handleSync(BiFunction<? super T, Throwable, ? extends U> fn)

Specified by:

handleSync in interface ReactionStage<T>

exceptionally

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

Specified by:

exceptionally in interface CompletionStage<T>

Specified by:

exceptionally in interface ReactionStage<T>

Overrides:

exceptionally in class CompletableFuture<T>

copy

public CentralisedFuture<T> copy()

Overrides:

copy in class CompletableFuture<T>

completeAsync

public CentralisedFuture<T> completeAsync(Supplier<? extends T> supplier,
 Executor executor)

Overrides:

completeAsync in class CompletableFuture<T>

completeAsync

public CentralisedFuture<T> completeAsync(Supplier<? extends T> supplier)

Overrides:

completeAsync in class CompletableFuture<T>

completeSync

public abstract CentralisedFuture<T> completeSync(Supplier<? extends T> supplier)

orTimeout

public CentralisedFuture<T> orTimeout(long timeout,
 TimeUnit unit)

Overrides:

orTimeout in class CompletableFuture<T>

completeOnTimeout

public CentralisedFuture<T> completeOnTimeout(T value,
 long timeout,
 TimeUnit unit)

Overrides:

completeOnTimeout in class CompletableFuture<T>

toCompletableFuture

public CentralisedFuture<T> toCompletableFuture()

Description copied from interface: ReactionStage

Converts to an equivalent CentralisedFuture with the same completion properties as this.

Specified by:

toCompletableFuture in interface CompletionStage<T>

Specified by:

toCompletableFuture in interface ReactionStage<T>

Overrides:

toCompletableFuture in class CompletableFuture<T>

Returns:

the centralised future