Uses of Interface
space.arim.omnibus.util.concurrent.ReactionStage

Packages that use ReactionStage

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 ReactionStage in space.arim.omnibus.util.concurrent

Classes in space.arim.omnibus.util.concurrent that implement ReactionStage

Modifier and Type	Class	Description
class	CentralisedFuture<T>	An extended CompletableFuture API implementing ReactionStage.

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

Modifier and Type	Method	Description
ReactionStage<Void>	ReactionStage.acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)
ReactionStage<Void>	ReactionStage.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)
ReactionStage<Void>	ReactionStage.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
ReactionStage<Void>	ReactionStage.acceptEitherSync(CompletionStage<? extends T> other, Consumer<? super T> action)
<U> ReactionStage<U>	ReactionStage.applyToEither(CompletionStage<? extends T> other, Function<? super T, U> fn)
<U> ReactionStage<U>	ReactionStage.applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T, U> fn)
<U> ReactionStage<U>	ReactionStage.applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor)
<U> ReactionStage<U>	ReactionStage.applyToEitherSync(CompletionStage<? extends T> other, Function<? super T, U> fn)
<T> ReactionStage<T>	FactoryOfTheFuture.completedStage(T value)	Creates a precompleted stage which has completed normally with the given value.
<T> ReactionStage<T>	FactoryOfTheFuture.copyStage(CompletionStage<T> completionStage)	Copies a CompletionStage to a ReactionStage.
ReactionStage<T>	ReactionStage.exceptionally(Function<Throwable, ? extends T> fn)
<T> ReactionStage<T>	FactoryOfTheFuture.failedStage(Throwable ex)	Creates a precompleted stage which has completed exceptionally with the given exception.
<U> ReactionStage<U>	ReactionStage.handle(BiFunction<? super T, Throwable, ? extends U> fn)
<U> ReactionStage<U>	ReactionStage.handleAsync(BiFunction<? super T, Throwable, ? extends U> fn)
<U> ReactionStage<U>	ReactionStage.handleAsync(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor)
<U> ReactionStage<U>	ReactionStage.handleSync(BiFunction<? super T, Throwable, ? extends U> fn)
abstract ReactionStage<T>	CentralisedFuture.minimalCompletionStage()
ReactionStage<Void>	ReactionStage.runAfterBoth(CompletionStage<?> other, Runnable action)
ReactionStage<Void>	ReactionStage.runAfterBothAsync(CompletionStage<?> other, Runnable action)
ReactionStage<Void>	ReactionStage.runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor)
ReactionStage<Void>	ReactionStage.runAfterBothSync(CompletionStage<?> other, Runnable action)
ReactionStage<Void>	ReactionStage.runAfterEither(CompletionStage<?> other, Runnable action)
ReactionStage<Void>	ReactionStage.runAfterEitherAsync(CompletionStage<?> other, Runnable action)
ReactionStage<Void>	ReactionStage.runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor)
ReactionStage<Void>	ReactionStage.runAfterEitherSync(CompletionStage<?> other, Runnable action)
ReactionStage<Void>	ReactionStage.thenAccept(Consumer<? super T> action)
ReactionStage<Void>	ReactionStage.thenAcceptAsync(Consumer<? super T> action)
ReactionStage<Void>	ReactionStage.thenAcceptAsync(Consumer<? super T> action, Executor executor)
<U> ReactionStage<Void>	ReactionStage.thenAcceptBoth(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
<U> ReactionStage<Void>	ReactionStage.thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
<U> ReactionStage<Void>	ReactionStage.thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor)
<U> ReactionStage<Void>	ReactionStage.thenAcceptBothSync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)
ReactionStage<Void>	ReactionStage.thenAcceptSync(Consumer<? super T> action)
<U> ReactionStage<U>	ReactionStage.thenApply(Function<? super T, ? extends U> fn)
<U> ReactionStage<U>	ReactionStage.thenApplyAsync(Function<? super T, ? extends U> fn)
<U> ReactionStage<U>	ReactionStage.thenApplyAsync(Function<? super T, ? extends U> fn, Executor executor)
<U> ReactionStage<U>	ReactionStage.thenApplySync(Function<? super T, ? extends U> fn)
<U,V> ReactionStage<V>	ReactionStage.thenCombine(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U,V> ReactionStage<V>	ReactionStage.thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U,V> ReactionStage<V>	ReactionStage.thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn, Executor executor)
<U,V> ReactionStage<V>	ReactionStage.thenCombineSync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn)
<U> ReactionStage<U>	ReactionStage.thenCompose(Function<? super T, ? extends CompletionStage<U>> fn)
<U> ReactionStage<U>	ReactionStage.thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn)
<U> ReactionStage<U>	ReactionStage.thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor)
<U> ReactionStage<U>	ReactionStage.thenComposeSync(Function<? super T, ? extends CompletionStage<U>> fn)
ReactionStage<Void>	ReactionStage.thenRun(Runnable action)
ReactionStage<Void>	ReactionStage.thenRunAsync(Runnable action)
ReactionStage<Void>	ReactionStage.thenRunAsync(Runnable action, Executor executor)
ReactionStage<Void>	ReactionStage.thenRunSync(Runnable action)
ReactionStage<T>	ReactionStage.whenComplete(BiConsumer<? super T, ? super Throwable> action)
ReactionStage<T>	ReactionStage.whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action)
ReactionStage<T>	ReactionStage.whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor)
ReactionStage<T>	ReactionStage.whenCompleteSync(BiConsumer<? super T, ? super Throwable> action)

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

Classes in space.arim.omnibus.util.concurrent.impl that implement ReactionStage

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 ReactionStage

Modifier and Type	Method	Description
<T> ReactionStage<T>	AbstractFactoryOfTheFuture.completedStage(T value)
<T> ReactionStage<T>	AbstractFactoryOfTheFuture.copyStage(CompletionStage<T> completionStage)
<T> ReactionStage<T>	AbstractFactoryOfTheFuture.failedStage(Throwable ex)
ReactionStage<T>	BaseCentralisedFuture.minimalCompletionStage()
ReactionStage<T>	IndifferentCentralisedFuture.minimalCompletionStage()