Class BaseCentralisedFuture<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

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

space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture<T>

Type Parameters:

T - the result type of the future

All Implemented Interfaces:

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

public class BaseCentralisedFuture<T>
extends CentralisedFuture<T>

Implementation of CentralisedFuture using a SynchronousExecutor for Sync methods.

Author:

A248

Nested Class Summary

Nested classes/interfaces inherited from class CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor	Description
BaseCentralisedFuture(SynchronousExecutor syncExecutor)	Creates a new incomplete future, with a SynchronousExecutor to use for executing tasks synchronously to the main thread.

Method Summary

Modifier and Type	Method	Description
CentralisedFuture<Void>	acceptEitherSync(CompletionStage<? extends T> other, Consumer<? super T> action)
<U> CentralisedFuture<U>	applyToEitherSync(CompletionStage<? extends T> other, Function<? super T, U> fn)
CentralisedFuture<T>	completeSync(Supplier<? extends T> supplier)
<U> CentralisedFuture<U>	handleSync(BiFunction<? super T, Throwable, ? extends U> fn)
ReactionStage<T>	minimalCompletionStage()
<U> CentralisedFuture<U>	newIncompleteFuture()
CentralisedFuture<Void>	runAfterBothSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	runAfterEitherSync(CompletionStage<?> other, Runnable action)
<U> CentralisedFuture<Void>	thenAcceptBothSync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
CentralisedFuture<Void>	thenAcceptSync(Consumer<? super T> action)
<U> CentralisedFuture<U>	thenApplySync(Function<? super T, ? extends U> fn)
<U,V> CentralisedFuture<V>	thenCombineSync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U> CentralisedFuture<U>	thenComposeSync(Function<? super T, ? extends CompletionStage<U>> fn)
CentralisedFuture<Void>	thenRunSync(Runnable action)
CentralisedFuture<T>	whenCompleteSync(BiConsumer<? super T, ? super Throwable> action)

Methods inherited from class CentralisedFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, completeAsync, completeAsync, completeOnTimeout, copy, exceptionally, handle, handleAsync, handleAsync, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync

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

BaseCentralisedFuture

public BaseCentralisedFuture(SynchronousExecutor syncExecutor)

Creates a new incomplete future, with a SynchronousExecutor to use for executing tasks synchronously to the main thread.

Parameters:

syncExecutor - the synchronous executor to use for Sync tasks

Method Details

newIncompleteFuture

public <U> CentralisedFuture<U> newIncompleteFuture()

Specified by:

newIncompleteFuture in class CentralisedFuture<T>

minimalCompletionStage

public ReactionStage<T> minimalCompletionStage()

Specified by:

minimalCompletionStage in class CentralisedFuture<T>

thenApplySync

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

Specified by:

thenApplySync in interface ReactionStage<T>

Specified by:

thenApplySync in class CentralisedFuture<T>

thenAcceptSync

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

Specified by:

thenAcceptSync in interface ReactionStage<T>

Specified by:

thenAcceptSync in class CentralisedFuture<T>

thenRunSync

public CentralisedFuture<Void> thenRunSync(Runnable action)

Specified by:

thenRunSync in interface ReactionStage<T>

Specified by:

thenRunSync in class CentralisedFuture<T>

thenCombineSync

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

Specified by:

thenCombineSync in interface ReactionStage<T>

Specified by:

thenCombineSync in class CentralisedFuture<T>

thenAcceptBothSync

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

Specified by:

thenAcceptBothSync in interface ReactionStage<T>

Specified by:

thenAcceptBothSync in class CentralisedFuture<T>

runAfterBothSync

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

Specified by:

runAfterBothSync in interface ReactionStage<T>

Specified by:

runAfterBothSync in class CentralisedFuture<T>

applyToEitherSync

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

Specified by:

applyToEitherSync in interface ReactionStage<T>

Specified by:

applyToEitherSync in class CentralisedFuture<T>

acceptEitherSync

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

Specified by:

acceptEitherSync in interface ReactionStage<T>

Specified by:

acceptEitherSync in class CentralisedFuture<T>

runAfterEitherSync

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

Specified by:

runAfterEitherSync in interface ReactionStage<T>

Specified by:

runAfterEitherSync in class CentralisedFuture<T>

thenComposeSync

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

Specified by:

thenComposeSync in interface ReactionStage<T>

Specified by:

thenComposeSync in class CentralisedFuture<T>

whenCompleteSync

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

Specified by:

whenCompleteSync in interface ReactionStage<T>

Specified by:

whenCompleteSync in class CentralisedFuture<T>

handleSync

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

Specified by:

handleSync in interface ReactionStage<T>

Specified by:

handleSync in class CentralisedFuture<T>

completeSync

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

Specified by:

completeSync in class CentralisedFuture<T>