Uses of Class
space.arim.omnibus.util.concurrent.CentralisedFuture

Packages that use CentralisedFuture

Package	Description
space.arim.omnibus.util.concurrent	Core interfaces for concurrency-related classes.
space.arim.omnibus.util.concurrent.impl	Contains base implementations for interfaces from the concurrency frameworks defined by space.arim.omnibus.util.concurrent

Uses of CentralisedFuture in space.arim.omnibus.util.concurrent

Methods in space.arim.omnibus.util.concurrent that return CentralisedFuture

Modifier and Type	Method	Description
CentralisedFuture<Void>	CentralisedFuture.acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)
CentralisedFuture<Void>	CentralisedFuture.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)
CentralisedFuture<Void>	CentralisedFuture.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
abstract CentralisedFuture<Void>	CentralisedFuture.acceptEitherSync(CompletionStage<? extends T> other, Consumer<? super T> action)
<T> CentralisedFuture<?>	FactoryOfTheFuture.allOf(Collection<? extends CentralisedFuture<T>> futures)	Creates a future which completes when all of the specified futures complete.
CentralisedFuture<?>	FactoryOfTheFuture.allOf(CentralisedFuture<?>... futures)	Creates a future which completes when all of the specified futures complete.
<U> CentralisedFuture<U>	CentralisedFuture.applyToEither(CompletionStage<? extends T> other, Function<? super T, U> fn)
<U> CentralisedFuture<U>	CentralisedFuture.applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T, U> fn)
<U> CentralisedFuture<U>	CentralisedFuture.applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor)
abstract <U> CentralisedFuture<U>	CentralisedFuture.applyToEitherSync(CompletionStage<? extends T> other, Function<? super T, U> fn)
CentralisedFuture<T>	CentralisedFuture.completeAsync(Supplier<? extends T> supplier)
CentralisedFuture<T>	CentralisedFuture.completeAsync(Supplier<? extends T> supplier, Executor executor)
<T> CentralisedFuture<T>	FactoryOfTheFuture.completedFuture(T value)	Creates a precompleted future which has completed normally with the given value.
CentralisedFuture<T>	CentralisedFuture.completeOnTimeout(T value, long timeout, TimeUnit unit)
abstract CentralisedFuture<T>	CentralisedFuture.completeSync(Supplier<? extends T> supplier)
CentralisedFuture<T>	CentralisedFuture.copy()
<T> CentralisedFuture<T>	FactoryOfTheFuture.copyFuture(CompletableFuture<T> completableFuture)	Copies a CompletableFuture to a CentralisedFuture.
CentralisedFuture<T>	CentralisedFuture.exceptionally(Function<Throwable, ? extends T> fn)
<T> CentralisedFuture<T>	FactoryOfTheFuture.failedFuture(Throwable ex)	Creates a precompleted future which has completed exceptionally with the given exception.
<U> CentralisedFuture<U>	CentralisedFuture.handle(BiFunction<? super T, Throwable, ? extends U> fn)
<U> CentralisedFuture<U>	CentralisedFuture.handleAsync(BiFunction<? super T, Throwable, ? extends U> fn)
<U> CentralisedFuture<U>	CentralisedFuture.handleAsync(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor)
abstract <U> CentralisedFuture<U>	CentralisedFuture.handleSync(BiFunction<? super T, Throwable, ? extends U> fn)
abstract <U> CentralisedFuture<U>	CentralisedFuture.newIncompleteFuture()
<T> CentralisedFuture<T>	FactoryOfTheFuture.newIncompleteFuture()	Creates an incomplete future.
CentralisedFuture<T>	CentralisedFuture.orTimeout(long timeout, TimeUnit unit)
CentralisedFuture<Void>	CentralisedFuture.runAfterBoth(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	CentralisedFuture.runAfterBothAsync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	CentralisedFuture.runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor)
abstract CentralisedFuture<Void>	CentralisedFuture.runAfterBothSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	CentralisedFuture.runAfterEither(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	CentralisedFuture.runAfterEitherAsync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	CentralisedFuture.runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor)
abstract CentralisedFuture<Void>	CentralisedFuture.runAfterEitherSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<?>	FactoryOfTheFuture.runAsync(Runnable command)	Runs a Runnable asynchronously and returns a future indicating its progress.
CentralisedFuture<?>	FactoryOfTheFuture.runAsync(Runnable command, Executor executor)	Runs a Runnable asynchronously using the provided Executor and returns a future indicating its progress.
CentralisedFuture<?>	FactoryOfTheFuture.runSync(Runnable command)	Runs a Runnable on the main thread if a main thread exists, else appropriately, per the specifications of SynchronousExecutor.executeSync(Runnable).
<T> CentralisedFuture<T>	FactoryOfTheFuture.supplyAsync(Supplier<T> supplier)	Supplies a value asynchronously and returns a future indicating its progress.
<T> CentralisedFuture<T>	FactoryOfTheFuture.supplyAsync(Supplier<T> supplier, Executor executor)	Supplies a value asynchronously using the provided Executor and returns a future indicating its progress.
<T> CentralisedFuture<T>	FactoryOfTheFuture.supplySync(Supplier<T> supplier)	Supplies a value on the main thread if a main thread exists, else appropriately, per the specifications of SynchronousExecutor.executeSync(Runnable).
CentralisedFuture<Void>	CentralisedFuture.thenAccept(Consumer<? super T> action)
CentralisedFuture<Void>	CentralisedFuture.thenAcceptAsync(Consumer<? super T> action)
CentralisedFuture<Void>	CentralisedFuture.thenAcceptAsync(Consumer<? super T> action, Executor executor)
<U> CentralisedFuture<Void>	CentralisedFuture.thenAcceptBoth(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
<U> CentralisedFuture<Void>	CentralisedFuture.thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
<U> CentralisedFuture<Void>	CentralisedFuture.thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor)
abstract <U> CentralisedFuture<Void>	CentralisedFuture.thenAcceptBothSync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
abstract CentralisedFuture<Void>	CentralisedFuture.thenAcceptSync(Consumer<? super T> action)
<U> CentralisedFuture<U>	CentralisedFuture.thenApply(Function<? super T, ? extends U> fn)
<U> CentralisedFuture<U>	CentralisedFuture.thenApplyAsync(Function<? super T, ? extends U> fn)
<U> CentralisedFuture<U>	CentralisedFuture.thenApplyAsync(Function<? super T, ? extends U> fn, Executor executor)
abstract <U> CentralisedFuture<U>	CentralisedFuture.thenApplySync(Function<? super T, ? extends U> fn)
<U,V> CentralisedFuture<V>	CentralisedFuture.thenCombine(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U,V> CentralisedFuture<V>	CentralisedFuture.thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U,V> CentralisedFuture<V>	CentralisedFuture.thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn, Executor executor)
abstract <U,V> CentralisedFuture<V>	CentralisedFuture.thenCombineSync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U> CentralisedFuture<U>	CentralisedFuture.thenCompose(Function<? super T, ? extends CompletionStage<U>> fn)
<U> CentralisedFuture<U>	CentralisedFuture.thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn)
<U> CentralisedFuture<U>	CentralisedFuture.thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor)
abstract <U> CentralisedFuture<U>	CentralisedFuture.thenComposeSync(Function<? super T, ? extends CompletionStage<U>> fn)
CentralisedFuture<Void>	CentralisedFuture.thenRun(Runnable action)
CentralisedFuture<Void>	CentralisedFuture.thenRunAsync(Runnable action)
CentralisedFuture<Void>	CentralisedFuture.thenRunAsync(Runnable action, Executor executor)
abstract CentralisedFuture<Void>	CentralisedFuture.thenRunSync(Runnable action)
CentralisedFuture<T>	CentralisedFuture.toCompletableFuture()
CentralisedFuture<T>	ReactionStage.toCompletableFuture()	Converts to an equivalent CentralisedFuture with the same completion properties as this.
CentralisedFuture<T>	CentralisedFuture.whenComplete(BiConsumer<? super T, ? super Throwable> action)
CentralisedFuture<T>	CentralisedFuture.whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action)
CentralisedFuture<T>	CentralisedFuture.whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor)
abstract CentralisedFuture<T>	CentralisedFuture.whenCompleteSync(BiConsumer<? super T, ? super Throwable> action)

Methods in space.arim.omnibus.util.concurrent with parameters of type CentralisedFuture

Modifier and Type	Method	Description
CentralisedFuture<?>	FactoryOfTheFuture.allOf(CentralisedFuture<?>... futures)	Creates a future which completes when all of the specified futures complete.

Method parameters in space.arim.omnibus.util.concurrent with type arguments of type CentralisedFuture

Modifier and Type	Method	Description
<T> CentralisedFuture<?>	FactoryOfTheFuture.allOf(Collection<? extends CentralisedFuture<T>> futures)	Creates a future which completes when all of the specified futures complete.

Uses of CentralisedFuture in space.arim.omnibus.util.concurrent.impl

Subclasses of CentralisedFuture in space.arim.omnibus.util.concurrent.impl

Modifier and Type	Class	Description
class	BaseCentralisedFuture<T>	Implementation of CentralisedFuture using a SynchronousExecutor for Sync methods.
class	IndifferentCentralisedFuture<T>	CentralisedFuture implementation which regards Sync method calls as identical to Async calls using the default executor.

Methods in space.arim.omnibus.util.concurrent.impl that return CentralisedFuture

Modifier and Type	Method	Description
CentralisedFuture<Void>	BaseCentralisedFuture.acceptEitherSync(CompletionStage<? extends T> other, Consumer<? super T> action)
CentralisedFuture<Void>	IndifferentCentralisedFuture.acceptEitherSync(CompletionStage<? extends T> other, Consumer<? super T> action)
<T> CentralisedFuture<?>	AbstractFactoryOfTheFuture.allOf(Collection<? extends CentralisedFuture<T>> futures)
CentralisedFuture<?>	AbstractFactoryOfTheFuture.allOf(CentralisedFuture<?>... futures)
<U> CentralisedFuture<U>	BaseCentralisedFuture.applyToEitherSync(CompletionStage<? extends T> other, Function<? super T, U> fn)
<U> CentralisedFuture<U>	IndifferentCentralisedFuture.applyToEitherSync(CompletionStage<? extends T> other, Function<? super T, U> fn)
<T> CentralisedFuture<T>	AbstractFactoryOfTheFuture.completedFuture(T value)
CentralisedFuture<T>	BaseCentralisedFuture.completeSync(Supplier<? extends T> supplier)
CentralisedFuture<T>	IndifferentCentralisedFuture.completeSync(Supplier<? extends T> supplier)
<T> CentralisedFuture<T>	AbstractFactoryOfTheFuture.copyFuture(CompletableFuture<T> completableFuture)
<T> CentralisedFuture<T>	AbstractFactoryOfTheFuture.failedFuture(Throwable ex)
<U> CentralisedFuture<U>	BaseCentralisedFuture.handleSync(BiFunction<? super T, Throwable, ? extends U> fn)
<U> CentralisedFuture<U>	IndifferentCentralisedFuture.handleSync(BiFunction<? super T, Throwable, ? extends U> fn)
abstract <U> CentralisedFuture<U>	AbstractFactoryOfTheFuture.newIncompleteFuture()	Creates a new, incomplete future.
<U> CentralisedFuture<U>	BaseCentralisedFuture.newIncompleteFuture()
<U> CentralisedFuture<U>	IndifferentCentralisedFuture.newIncompleteFuture()
<U> CentralisedFuture<U>	IndifferentFactoryOfTheFuture.newIncompleteFuture()
CentralisedFuture<Void>	BaseCentralisedFuture.runAfterBothSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	IndifferentCentralisedFuture.runAfterBothSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	BaseCentralisedFuture.runAfterEitherSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<Void>	IndifferentCentralisedFuture.runAfterEitherSync(CompletionStage<?> other, Runnable action)
CentralisedFuture<?>	AbstractFactoryOfTheFuture.runAsync(Runnable command)
CentralisedFuture<?>	AbstractFactoryOfTheFuture.runAsync(Runnable command, Executor executor)
CentralisedFuture<?>	AbstractFactoryOfTheFuture.runSync(Runnable command)
<T> CentralisedFuture<T>	AbstractFactoryOfTheFuture.supplyAsync(Supplier<T> supplier)
<T> CentralisedFuture<T>	AbstractFactoryOfTheFuture.supplyAsync(Supplier<T> supplier, Executor executor)
<T> CentralisedFuture<T>	AbstractFactoryOfTheFuture.supplySync(Supplier<T> supplier)
<U> CentralisedFuture<Void>	BaseCentralisedFuture.thenAcceptBothSync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
<U> CentralisedFuture<Void>	IndifferentCentralisedFuture.thenAcceptBothSync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
CentralisedFuture<Void>	BaseCentralisedFuture.thenAcceptSync(Consumer<? super T> action)
CentralisedFuture<Void>	IndifferentCentralisedFuture.thenAcceptSync(Consumer<? super T> action)
<U> CentralisedFuture<U>	BaseCentralisedFuture.thenApplySync(Function<? super T, ? extends U> fn)
<U> CentralisedFuture<U>	IndifferentCentralisedFuture.thenApplySync(Function<? super T, ? extends U> fn)
<U,V> CentralisedFuture<V>	BaseCentralisedFuture.thenCombineSync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U,V> CentralisedFuture<V>	IndifferentCentralisedFuture.thenCombineSync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U> CentralisedFuture<U>	BaseCentralisedFuture.thenComposeSync(Function<? super T, ? extends CompletionStage<U>> fn)
<U> CentralisedFuture<U>	IndifferentCentralisedFuture.thenComposeSync(Function<? super T, ? extends CompletionStage<U>> fn)
CentralisedFuture<Void>	BaseCentralisedFuture.thenRunSync(Runnable action)
CentralisedFuture<Void>	IndifferentCentralisedFuture.thenRunSync(Runnable action)
CentralisedFuture<T>	BaseCentralisedFuture.whenCompleteSync(BiConsumer<? super T, ? super Throwable> action)
CentralisedFuture<T>	IndifferentCentralisedFuture.whenCompleteSync(BiConsumer<? super T, ? super Throwable> action)

Methods in space.arim.omnibus.util.concurrent.impl with parameters of type CentralisedFuture

Modifier and Type	Method	Description
CentralisedFuture<?>	AbstractFactoryOfTheFuture.allOf(CentralisedFuture<?>... futures)

Method parameters in space.arim.omnibus.util.concurrent.impl with type arguments of type CentralisedFuture

Modifier and Type	Method	Description
<T> CentralisedFuture<?>	AbstractFactoryOfTheFuture.allOf(Collection<? extends CentralisedFuture<T>> futures)