CompletionStage
interface CompletionStage<T : Any!>
java.util.concurrent.CompletionStage |
A stage of a possibly asynchronous computation, that performs an action or computes a value when another CompletionStage completes. A stage completes upon termination of its computation, but this may in turn trigger other dependent stages. The functionality defined in this interface takes only a few basic forms, which expand out to a larger set of methods to capture a range of usage styles:
- The computation performed by a stage may be expressed as a Function, Consumer, or Runnable (using methods with names including apply, accept, or run, respectively) depending on whether it requires arguments and/or produces results. For example:
An additional form (compose) allows the construction of computation pipelines from functions returning completion stages.<code>stage.thenApply(x -> square(x)) .thenAccept(x -> System.out.print(x)) .thenRun(() -> System.out.println());</code>
Any argument to a stage's computation is the outcome of a triggering stage's computation.
- One stage's execution may be triggered by completion of a single stage, or both of two stages, or either of two stages. Dependencies on a single stage are arranged using methods with prefix then. Those triggered by completion of both of two stages may combine their results or effects, using correspondingly named methods. Those triggered by either of two stages make no guarantees about which of the results or effects are used for the dependent stage's computation.
- Dependencies among stages control the triggering of computations, but do not otherwise guarantee any particular ordering. Additionally, execution of a new stage's computations may be arranged in any of three ways: default execution, default asynchronous execution (using methods with suffix async that employ the stage's default asynchronous execution facility), or custom (via a supplied
Executor
). The execution properties of default and async modes are specified by CompletionStage implementations, not this interface. Methods with explicit Executor arguments may have arbitrary execution properties, and might not even support concurrent execution, but are arranged for processing in a way that accommodates asynchrony. - Two method forms (
handle
andwhenComplete
) support unconditional computation whether the triggering stage completed normally or exceptionally. Methodexceptionally
supports computation only when the triggering stage completes exceptionally, computing a replacement result, similarly to the javacatch
keyword. In all other cases, if a stage's computation terminates abruptly with an (unchecked) exception or error, then all dependent stages requiring its completion complete exceptionally as well, with aCompletionException
holding the exception as its cause. If a stage is dependent on both of two stages, and both complete exceptionally, then the CompletionException may correspond to either one of these exceptions. If a stage is dependent on either of two others, and only one of them completes exceptionally, no guarantees are made about whether the dependent stage completes normally or exceptionally. In the case of methodwhenComplete
, when the supplied action itself encounters an exception, then the stage completes exceptionally with this exception unless the source stage also completed exceptionally, in which case the exceptional completion from the source stage is given preference and propagated to the dependent stage.
All methods adhere to the above triggering, execution, and exceptional completion specifications (which are not repeated in individual method specifications). Additionally, while arguments used to pass a completion result (that is, for parameters of type T
) for methods accepting them may be null, passing a null value for any other parameter will result in a NullPointerException
being thrown.
Method form handle
is the most general way of creating a continuation stage, unconditionally performing a computation that is given both the result and exception (if any) of the triggering CompletionStage, and computing an arbitrary result. Method whenComplete
is similar, but preserves the result of the triggering stage instead of computing a new one. Because a stage's normal result may be null
, both methods should have a computation structured thus:
<code>(result, exception) -> { if (exception == null) { // triggering stage completed normally } else { // triggering stage completed exceptionally } }</code>
This interface does not define methods for initially creating, forcibly completing normally or exceptionally, probing completion status or results, or awaiting completion of a stage. Implementations of CompletionStage may provide means of achieving such effects, as appropriate. Method toCompletableFuture
enables interoperability among different implementations of this interface by providing a common conversion type.
Summary
Public methods | |
---|---|
abstract CompletionStage<Void!>! |
acceptEither(other: CompletionStage<out T>!, action: Consumer<in T>!) Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed with the corresponding result as argument to the supplied action. |
abstract CompletionStage<Void!>! |
acceptEitherAsync(other: CompletionStage<out T>!, action: Consumer<in T>!) Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using this stage's default asynchronous execution facility, with the corresponding result as argument to the supplied action. |
abstract CompletionStage<Void!>! |
acceptEitherAsync(other: CompletionStage<out T>!, action: Consumer<in T>!, executor: Executor!) Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using the supplied executor, with the corresponding result as argument to the supplied action. |
abstract CompletionStage<U>! |
applyToEither(other: CompletionStage<out T>!, fn: Function<in T, U>!) Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed with the corresponding result as argument to the supplied function. |
abstract CompletionStage<U>! |
applyToEitherAsync(other: CompletionStage<out T>!, fn: Function<in T, U>!) Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using this stage's default asynchronous execution facility, with the corresponding result as argument to the supplied function. |
abstract CompletionStage<U>! |
applyToEitherAsync(other: CompletionStage<out T>!, fn: Function<in T, U>!, executor: Executor!) Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using the supplied executor, with the corresponding result as argument to the supplied function. |
abstract CompletionStage<T>! |
exceptionally(fn: Function<Throwable!, out T>!) Returns a new CompletionStage that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied function. |
open CompletionStage<T>! |
exceptionallyAsync(fn: Function<Throwable!, out T>!) Returns a new CompletionStage that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied function, using this stage's default asynchronous execution facility. |
open CompletionStage<T>! |
exceptionallyAsync(fn: Function<Throwable!, out T>!, executor: Executor!) Returns a new CompletionStage that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied function, using the supplied Executor. |
open CompletionStage<T>! |
exceptionallyCompose(fn: Function<Throwable!, out CompletionStage<T>!>!) Returns a new CompletionStage that, when this stage completes exceptionally, is composed using the results of the supplied function applied to this stage's exception. |
open CompletionStage<T>! |
exceptionallyComposeAsync(fn: Function<Throwable!, out CompletionStage<T>!>!) Returns a new CompletionStage that, when this stage completes exceptionally, is composed using the results of the supplied function applied to this stage's exception, using this stage's default asynchronous execution facility. |
open CompletionStage<T>! |
exceptionallyComposeAsync(fn: Function<Throwable!, out CompletionStage<T>!>!, executor: Executor!) Returns a new CompletionStage that, when this stage completes exceptionally, is composed using the results of the supplied function applied to this stage's exception, using the supplied Executor. |
abstract CompletionStage<U>! |
handle(fn: BiFunction<in T, Throwable!, out U>!) Returns a new CompletionStage that, when this stage completes either normally or exceptionally, is executed with this stage's result and exception as arguments to the supplied function. |
abstract CompletionStage<U>! |
handleAsync(fn: BiFunction<in T, Throwable!, out U>!) Returns a new CompletionStage that, when this stage completes either normally or exceptionally, is executed using this stage's default asynchronous execution facility, with this stage's result and exception as arguments to the supplied function. |
abstract CompletionStage<U>! |
handleAsync(fn: BiFunction<in T, Throwable!, out U>!, executor: Executor!) Returns a new CompletionStage that, when this stage completes either normally or exceptionally, is executed using the supplied executor, with this stage's result and exception as arguments to the supplied function. |
abstract CompletionStage<Void!>! |
runAfterBoth(other: CompletionStage<*>!, action: Runnable!) Returns a new CompletionStage that, when this and the other given stage both complete normally, executes the given action. |
abstract CompletionStage<Void!>! |
runAfterBothAsync(other: CompletionStage<*>!, action: Runnable!) Returns a new CompletionStage that, when this and the other given stage both complete normally, executes the given action using this stage's default asynchronous execution facility. |
abstract CompletionStage<Void!>! |
runAfterBothAsync(other: CompletionStage<*>!, action: Runnable!, executor: Executor!) Returns a new CompletionStage that, when this and the other given stage both complete normally, executes the given action using the supplied executor. |
abstract CompletionStage<Void!>! |
runAfterEither(other: CompletionStage<*>!, action: Runnable!) Returns a new CompletionStage that, when either this or the other given stage complete normally, executes the given action. |
abstract CompletionStage<Void!>! |
runAfterEitherAsync(other: CompletionStage<*>!, action: Runnable!) Returns a new CompletionStage that, when either this or the other given stage complete normally, executes the given action using this stage's default asynchronous execution facility. |
abstract CompletionStage<Void!>! |
runAfterEitherAsync(other: CompletionStage<*>!, action: Runnable!, executor: Executor!) Returns a new CompletionStage that, when either this or the other given stage complete normally, executes the given action using the supplied executor. |
abstract CompletionStage<Void!>! |
thenAccept(action: Consumer<in T>!) Returns a new CompletionStage that, when this stage completes normally, is executed with this stage's result as the argument to the supplied action. |
abstract CompletionStage<Void!>! |
thenAcceptAsync(action: Consumer<in T>!) Returns a new CompletionStage that, when this stage completes normally, is executed using this stage's default asynchronous execution facility, with this stage's result as the argument to the supplied action. |
abstract CompletionStage<Void!>! |
thenAcceptAsync(action: Consumer<in T>!, executor: Executor!) Returns a new CompletionStage that, when this stage completes normally, is executed using the supplied Executor, with this stage's result as the argument to the supplied action. |
abstract CompletionStage<Void!>! |
thenAcceptBoth(other: CompletionStage<out U>!, action: BiConsumer<in T, in U>!) Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed with the two results as arguments to the supplied action. |
abstract CompletionStage<Void!>! |
thenAcceptBothAsync(other: CompletionStage<out U>!, action: BiConsumer<in T, in U>!) Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed using this stage's default asynchronous execution facility, with the two results as arguments to the supplied action. |
abstract CompletionStage<Void!>! |
thenAcceptBothAsync(other: CompletionStage<out U>!, action: BiConsumer<in T, in U>!, executor: Executor!) Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed using the supplied executor, with the two results as arguments to the supplied action. |
abstract CompletionStage<U>! |
Returns a new CompletionStage that, when this stage completes normally, is executed with this stage's result as the argument to the supplied function. |
abstract CompletionStage<U>! |
thenApplyAsync(fn: Function<in T, out U>!) Returns a new CompletionStage that, when this stage completes normally, is executed using this stage's default asynchronous execution facility, with this stage's result as the argument to the supplied function. |
abstract CompletionStage<U>! |
thenApplyAsync(fn: Function<in T, out U>!, executor: Executor!) Returns a new CompletionStage that, when this stage completes normally, is executed using the supplied Executor, with this stage's result as the argument to the supplied function. |
abstract CompletionStage<V>! |
thenCombine(other: CompletionStage<out U>!, fn: BiFunction<in T, in U, out V>!) Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed with the two results as arguments to the supplied function. |
abstract CompletionStage<V>! |
thenCombineAsync(other: CompletionStage<out U>!, fn: BiFunction<in T, in U, out V>!) Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed using this stage's default asynchronous execution facility, with the two results as arguments to the supplied function. |
abstract CompletionStage<V>! |
thenCombineAsync(other: CompletionStage<out U>!, fn: BiFunction<in T, in U, out V>!, executor: Executor!) Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed using the supplied executor, with the two results as arguments to the supplied function. |
abstract CompletionStage<U>! |
thenCompose(fn: Function<in T, out CompletionStage<U>!>!) Returns a new CompletionStage that is completed with the same value as the CompletionStage returned by the given function. |
abstract CompletionStage<U>! |
thenComposeAsync(fn: Function<in T, out CompletionStage<U>!>!) Returns a new CompletionStage that is completed with the same value as the CompletionStage returned by the given function, executed using this stage's default asynchronous execution facility. |
abstract CompletionStage<U>! |
thenComposeAsync(fn: Function<in T, out CompletionStage<U>!>!, executor: Executor!) Returns a new CompletionStage that is completed with the same value as the CompletionStage returned by the given function, executed using the supplied Executor. |
abstract CompletionStage<Void!>! |
Returns a new CompletionStage that, when this stage completes normally, executes the given action. |
abstract CompletionStage<Void!>! |
thenRunAsync(action: Runnable!) Returns a new CompletionStage that, when this stage completes normally, executes the given action using this stage's default asynchronous execution facility. |
abstract CompletionStage<Void!>! |
thenRunAsync(action: Runnable!, executor: Executor!) Returns a new CompletionStage that, when this stage completes normally, executes the given action using the supplied Executor. |
abstract CompletableFuture<T>! |
Returns a |
abstract CompletionStage<T>! |
whenComplete(action: BiConsumer<in T, in Throwable!>!) Returns a new CompletionStage with the same result or exception as this stage, that executes the given action when this stage completes. |
abstract CompletionStage<T>! |
whenCompleteAsync(action: BiConsumer<in T, in Throwable!>!) Returns a new CompletionStage with the same result or exception as this stage, that executes the given action using this stage's default asynchronous execution facility when this stage completes. |
abstract CompletionStage<T>! |
whenCompleteAsync(action: BiConsumer<in T, in Throwable!>!, executor: Executor!) Returns a new CompletionStage with the same result or exception as this stage, that executes the given action using the supplied Executor when this stage completes. |
Public methods
acceptEither
abstract fun acceptEither(
other: CompletionStage<out T>!,
action: Consumer<in T>!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed with the corresponding result as argument to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out T>!: the other CompletionStage |
action |
Consumer<in T>!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
acceptEitherAsync
abstract fun acceptEitherAsync(
other: CompletionStage<out T>!,
action: Consumer<in T>!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using this stage's default asynchronous execution facility, with the corresponding result as argument to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out T>!: the other CompletionStage |
action |
Consumer<in T>!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
acceptEitherAsync
abstract fun acceptEitherAsync(
other: CompletionStage<out T>!,
action: Consumer<in T>!,
executor: Executor!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using the supplied executor, with the corresponding result as argument to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out T>!: the other CompletionStage |
action |
Consumer<in T>!: the action to perform before completing the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
applyToEither
abstract fun <U : Any!> applyToEither(
other: CompletionStage<out T>!,
fn: Function<in T, U>!
): CompletionStage<U>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed with the corresponding result as argument to the supplied function. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out T>!: the other CompletionStage |
fn |
Function<in T, U>!: the function to use to compute the value of the returned CompletionStage |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
applyToEitherAsync
abstract fun <U : Any!> applyToEitherAsync(
other: CompletionStage<out T>!,
fn: Function<in T, U>!
): CompletionStage<U>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using this stage's default asynchronous execution facility, with the corresponding result as argument to the supplied function. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out T>!: the other CompletionStage |
fn |
Function<in T, U>!: the function to use to compute the value of the returned CompletionStage |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
applyToEitherAsync
abstract fun <U : Any!> applyToEitherAsync(
other: CompletionStage<out T>!,
fn: Function<in T, U>!,
executor: Executor!
): CompletionStage<U>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using the supplied executor, with the corresponding result as argument to the supplied function. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out T>!: the other CompletionStage |
fn |
Function<in T, U>!: the function to use to compute the value of the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
exceptionally
abstract fun exceptionally(fn: Function<Throwable!, out T>!): CompletionStage<T>!
Returns a new CompletionStage that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied function. Otherwise, if this stage completes normally, then the returned stage also completes normally with the same value.
Parameters | |
---|---|
fn |
Function<Throwable!, out T>!: the function to use to compute the value of the returned CompletionStage if this CompletionStage completed exceptionally |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |
exceptionallyAsync
open fun exceptionallyAsync(fn: Function<Throwable!, out T>!): CompletionStage<T>!
Returns a new CompletionStage that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied function, using this stage's default asynchronous execution facility. Otherwise, if this stage completes normally, then the returned stage also completes normally with the same value.
Parameters | |
---|---|
fn |
Function<Throwable!, out T>!: the function to use to compute the value of the returned CompletionStage if this CompletionStage completed exceptionally |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |
exceptionallyAsync
open fun exceptionallyAsync(
fn: Function<Throwable!, out T>!,
executor: Executor!
): CompletionStage<T>!
Returns a new CompletionStage that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied function, using the supplied Executor. Otherwise, if this stage completes normally, then the returned stage also completes normally with the same value.
Parameters | |
---|---|
fn |
Function<Throwable!, out T>!: the function to use to compute the value of the returned CompletionStage if this CompletionStage completed exceptionally |
executor |
Executor!: the executor to use for asynchronous execution |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |
exceptionallyCompose
open fun exceptionallyCompose(fn: Function<Throwable!, out CompletionStage<T>!>!): CompletionStage<T>!
Returns a new CompletionStage that, when this stage completes exceptionally, is composed using the results of the supplied function applied to this stage's exception.
Parameters | |
---|---|
fn |
Function<Throwable!, out CompletionStage<T>!>!: the function to use to compute the returned CompletionStage if this CompletionStage completed exceptionally |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |
exceptionallyComposeAsync
open fun exceptionallyComposeAsync(fn: Function<Throwable!, out CompletionStage<T>!>!): CompletionStage<T>!
Returns a new CompletionStage that, when this stage completes exceptionally, is composed using the results of the supplied function applied to this stage's exception, using this stage's default asynchronous execution facility.
Parameters | |
---|---|
fn |
Function<Throwable!, out CompletionStage<T>!>!: the function to use to compute the returned CompletionStage if this CompletionStage completed exceptionally |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |
exceptionallyComposeAsync
open fun exceptionallyComposeAsync(
fn: Function<Throwable!, out CompletionStage<T>!>!,
executor: Executor!
): CompletionStage<T>!
Returns a new CompletionStage that, when this stage completes exceptionally, is composed using the results of the supplied function applied to this stage's exception, using the supplied Executor.
Parameters | |
---|---|
fn |
Function<Throwable!, out CompletionStage<T>!>!: the function to use to compute the returned CompletionStage if this CompletionStage completed exceptionally |
executor |
Executor!: the executor to use for asynchronous execution |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |
handle
abstract fun <U : Any!> handle(fn: BiFunction<in T, Throwable!, out U>!): CompletionStage<U>!
Returns a new CompletionStage that, when this stage completes either normally or exceptionally, is executed with this stage's result and exception as arguments to the supplied function.
When this stage is complete, the given function is invoked with the result (or null
if none) and the exception (or null
if none) of this stage as arguments, and the function's result is used to complete the returned stage.
Parameters | |
---|---|
fn |
BiFunction<in T, Throwable!, out U>!: the function to use to compute the value of the returned CompletionStage |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
handleAsync
abstract fun <U : Any!> handleAsync(fn: BiFunction<in T, Throwable!, out U>!): CompletionStage<U>!
Returns a new CompletionStage that, when this stage completes either normally or exceptionally, is executed using this stage's default asynchronous execution facility, with this stage's result and exception as arguments to the supplied function.
When this stage is complete, the given function is invoked with the result (or null
if none) and the exception (or null
if none) of this stage as arguments, and the function's result is used to complete the returned stage.
Parameters | |
---|---|
fn |
BiFunction<in T, Throwable!, out U>!: the function to use to compute the value of the returned CompletionStage |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
handleAsync
abstract fun <U : Any!> handleAsync(
fn: BiFunction<in T, Throwable!, out U>!,
executor: Executor!
): CompletionStage<U>!
Returns a new CompletionStage that, when this stage completes either normally or exceptionally, is executed using the supplied executor, with this stage's result and exception as arguments to the supplied function.
When this stage is complete, the given function is invoked with the result (or null
if none) and the exception (or null
if none) of this stage as arguments, and the function's result is used to complete the returned stage.
Parameters | |
---|---|
fn |
BiFunction<in T, Throwable!, out U>!: the function to use to compute the value of the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
runAfterBoth
abstract fun runAfterBoth(
other: CompletionStage<*>!,
action: Runnable!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, executes the given action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<*>!: the other CompletionStage |
action |
Runnable!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
runAfterBothAsync
abstract fun runAfterBothAsync(
other: CompletionStage<*>!,
action: Runnable!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, executes the given action using this stage's default asynchronous execution facility. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<*>!: the other CompletionStage |
action |
Runnable!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
runAfterBothAsync
abstract fun runAfterBothAsync(
other: CompletionStage<*>!,
action: Runnable!,
executor: Executor!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, executes the given action using the supplied executor. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<*>!: the other CompletionStage |
action |
Runnable!: the action to perform before completing the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
runAfterEither
abstract fun runAfterEither(
other: CompletionStage<*>!,
action: Runnable!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, executes the given action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<*>!: the other CompletionStage |
action |
Runnable!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
runAfterEitherAsync
abstract fun runAfterEitherAsync(
other: CompletionStage<*>!,
action: Runnable!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, executes the given action using this stage's default asynchronous execution facility. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<*>!: the other CompletionStage |
action |
Runnable!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
runAfterEitherAsync
abstract fun runAfterEitherAsync(
other: CompletionStage<*>!,
action: Runnable!,
executor: Executor!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when either this or the other given stage complete normally, executes the given action using the supplied executor. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<*>!: the other CompletionStage |
action |
Runnable!: the action to perform before completing the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenAccept
abstract fun thenAccept(action: Consumer<in T>!): CompletionStage<Void!>!
Returns a new CompletionStage that, when this stage completes normally, is executed with this stage's result as the argument to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
action |
Consumer<in T>!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenAcceptAsync
abstract fun thenAcceptAsync(action: Consumer<in T>!): CompletionStage<Void!>!
Returns a new CompletionStage that, when this stage completes normally, is executed using this stage's default asynchronous execution facility, with this stage's result as the argument to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
action |
Consumer<in T>!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenAcceptAsync
abstract fun thenAcceptAsync(
action: Consumer<in T>!,
executor: Executor!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when this stage completes normally, is executed using the supplied Executor, with this stage's result as the argument to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
action |
Consumer<in T>!: the action to perform before completing the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenAcceptBoth
abstract fun <U : Any!> thenAcceptBoth(
other: CompletionStage<out U>!,
action: BiConsumer<in T, in U>!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed with the two results as arguments to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out U>!: the other CompletionStage |
action |
BiConsumer<in T, in U>!: the action to perform before completing the returned CompletionStage |
<U> |
the type of the other CompletionStage's result |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenAcceptBothAsync
abstract fun <U : Any!> thenAcceptBothAsync(
other: CompletionStage<out U>!,
action: BiConsumer<in T, in U>!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed using this stage's default asynchronous execution facility, with the two results as arguments to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out U>!: the other CompletionStage |
action |
BiConsumer<in T, in U>!: the action to perform before completing the returned CompletionStage |
<U> |
the type of the other CompletionStage's result |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenAcceptBothAsync
abstract fun <U : Any!> thenAcceptBothAsync(
other: CompletionStage<out U>!,
action: BiConsumer<in T, in U>!,
executor: Executor!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed using the supplied executor, with the two results as arguments to the supplied action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out U>!: the other CompletionStage |
action |
BiConsumer<in T, in U>!: the action to perform before completing the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
<U> |
the type of the other CompletionStage's result |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenApply
abstract fun <U : Any!> thenApply(fn: Function<in T, out U>!): CompletionStage<U>!
Returns a new CompletionStage that, when this stage completes normally, is executed with this stage's result as the argument to the supplied function.
This method is analogous to Optional.map
and Stream.map
.
See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
fn |
Function<in T, out U>!: the function to use to compute the value of the returned CompletionStage |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
thenApplyAsync
abstract fun <U : Any!> thenApplyAsync(fn: Function<in T, out U>!): CompletionStage<U>!
Returns a new CompletionStage that, when this stage completes normally, is executed using this stage's default asynchronous execution facility, with this stage's result as the argument to the supplied function. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
fn |
Function<in T, out U>!: the function to use to compute the value of the returned CompletionStage |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
thenApplyAsync
abstract fun <U : Any!> thenApplyAsync(
fn: Function<in T, out U>!,
executor: Executor!
): CompletionStage<U>!
Returns a new CompletionStage that, when this stage completes normally, is executed using the supplied Executor, with this stage's result as the argument to the supplied function. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
fn |
Function<in T, out U>!: the function to use to compute the value of the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
<U> |
the function's return type |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
thenCombine
abstract fun <U : Any!, V : Any!> thenCombine(
other: CompletionStage<out U>!,
fn: BiFunction<in T, in U, out V>!
): CompletionStage<V>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed with the two results as arguments to the supplied function. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out U>!: the other CompletionStage |
fn |
BiFunction<in T, in U, out V>!: the function to use to compute the value of the returned CompletionStage |
<U> |
the type of the other CompletionStage's result |
<V> |
the function's return type |
Return | |
---|---|
CompletionStage<V>! |
the new CompletionStage |
thenCombineAsync
abstract fun <U : Any!, V : Any!> thenCombineAsync(
other: CompletionStage<out U>!,
fn: BiFunction<in T, in U, out V>!
): CompletionStage<V>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed using this stage's default asynchronous execution facility, with the two results as arguments to the supplied function. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out U>!: the other CompletionStage |
fn |
BiFunction<in T, in U, out V>!: the function to use to compute the value of the returned CompletionStage |
<U> |
the type of the other CompletionStage's result |
<V> |
the function's return type |
Return | |
---|---|
CompletionStage<V>! |
the new CompletionStage |
thenCombineAsync
abstract fun <U : Any!, V : Any!> thenCombineAsync(
other: CompletionStage<out U>!,
fn: BiFunction<in T, in U, out V>!,
executor: Executor!
): CompletionStage<V>!
Returns a new CompletionStage that, when this and the other given stage both complete normally, is executed using the supplied executor, with the two results as arguments to the supplied function. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
other |
CompletionStage<out U>!: the other CompletionStage |
fn |
BiFunction<in T, in U, out V>!: the function to use to compute the value of the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
<U> |
the type of the other CompletionStage's result |
<V> |
the function's return type |
Return | |
---|---|
CompletionStage<V>! |
the new CompletionStage |
thenCompose
abstract fun <U : Any!> thenCompose(fn: Function<in T, out CompletionStage<U>!>!): CompletionStage<U>!
Returns a new CompletionStage that is completed with the same value as the CompletionStage returned by the given function.
When this stage completes normally, the given function is invoked with this stage's result as the argument, returning another CompletionStage. When that stage completes normally, the CompletionStage returned by this method is completed with the same value.
To ensure progress, the supplied function must arrange eventual completion of its result.
This method is analogous to Optional.flatMap
and Stream.flatMap
.
See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
fn |
Function<in T, out CompletionStage<U>!>!: the function to use to compute another CompletionStage |
<U> |
the type of the returned CompletionStage's result |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
thenComposeAsync
abstract fun <U : Any!> thenComposeAsync(fn: Function<in T, out CompletionStage<U>!>!): CompletionStage<U>!
Returns a new CompletionStage that is completed with the same value as the CompletionStage returned by the given function, executed using this stage's default asynchronous execution facility.
When this stage completes normally, the given function is invoked with this stage's result as the argument, returning another CompletionStage. When that stage completes normally, the CompletionStage returned by this method is completed with the same value.
To ensure progress, the supplied function must arrange eventual completion of its result.
See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
fn |
Function<in T, out CompletionStage<U>!>!: the function to use to compute another CompletionStage |
<U> |
the type of the returned CompletionStage's result |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
thenComposeAsync
abstract fun <U : Any!> thenComposeAsync(
fn: Function<in T, out CompletionStage<U>!>!,
executor: Executor!
): CompletionStage<U>!
Returns a new CompletionStage that is completed with the same value as the CompletionStage returned by the given function, executed using the supplied Executor.
When this stage completes normally, the given function is invoked with this stage's result as the argument, returning another CompletionStage. When that stage completes normally, the CompletionStage returned by this method is completed with the same value.
To ensure progress, the supplied function must arrange eventual completion of its result.
See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
fn |
Function<in T, out CompletionStage<U>!>!: the function to use to compute another CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
<U> |
the type of the returned CompletionStage's result |
Return | |
---|---|
CompletionStage<U>! |
the new CompletionStage |
thenRun
abstract fun thenRun(action: Runnable!): CompletionStage<Void!>!
Returns a new CompletionStage that, when this stage completes normally, executes the given action. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
action |
Runnable!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenRunAsync
abstract fun thenRunAsync(action: Runnable!): CompletionStage<Void!>!
Returns a new CompletionStage that, when this stage completes normally, executes the given action using this stage's default asynchronous execution facility. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
action |
Runnable!: the action to perform before completing the returned CompletionStage |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
thenRunAsync
abstract fun thenRunAsync(
action: Runnable!,
executor: Executor!
): CompletionStage<Void!>!
Returns a new CompletionStage that, when this stage completes normally, executes the given action using the supplied Executor. See the CompletionStage
documentation for rules covering exceptional completion.
Parameters | |
---|---|
action |
Runnable!: the action to perform before completing the returned CompletionStage |
executor |
Executor!: the executor to use for asynchronous execution |
Return | |
---|---|
CompletionStage<Void!>! |
the new CompletionStage |
toCompletableFuture
abstract fun toCompletableFuture(): CompletableFuture<T>!
Returns a CompletableFuture
maintaining the same completion properties as this stage. If this stage is already a CompletableFuture, this method may return this stage itself. Otherwise, invocation of this method may be equivalent in effect to thenApply(x -> x)
, but returning an instance of type CompletableFuture
.
Return | |
---|---|
CompletableFuture<T>! |
the CompletableFuture |
whenComplete
abstract fun whenComplete(action: BiConsumer<in T, in Throwable!>!): CompletionStage<T>!
Returns a new CompletionStage with the same result or exception as this stage, that executes the given action when this stage completes.
When this stage is complete, the given action is invoked with the result (or null
if none) and the exception (or null
if none) of this stage as arguments. The returned stage is completed when the action returns.
Unlike method handle
, this method is not designed to translate completion outcomes, so the supplied action should not throw an exception. However, if it does, the following rules apply: if this stage completed normally but the supplied action throws an exception, then the returned stage completes exceptionally with the supplied action's exception. Or, if this stage completed exceptionally and the supplied action throws an exception, then the returned stage completes exceptionally with this stage's exception.
Parameters | |
---|---|
action |
BiConsumer<in T, in Throwable!>!: the action to perform |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |
whenCompleteAsync
abstract fun whenCompleteAsync(action: BiConsumer<in T, in Throwable!>!): CompletionStage<T>!
Returns a new CompletionStage with the same result or exception as this stage, that executes the given action using this stage's default asynchronous execution facility when this stage completes.
When this stage is complete, the given action is invoked with the result (or null
if none) and the exception (or null
if none) of this stage as arguments. The returned stage is completed when the action returns.
Unlike method handleAsync
, this method is not designed to translate completion outcomes, so the supplied action should not throw an exception. However, if it does, the following rules apply: If this stage completed normally but the supplied action throws an exception, then the returned stage completes exceptionally with the supplied action's exception. Or, if this stage completed exceptionally and the supplied action throws an exception, then the returned stage completes exceptionally with this stage's exception.
Parameters | |
---|---|
action |
BiConsumer<in T, in Throwable!>!: the action to perform |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |
whenCompleteAsync
abstract fun whenCompleteAsync(
action: BiConsumer<in T, in Throwable!>!,
executor: Executor!
): CompletionStage<T>!
Returns a new CompletionStage with the same result or exception as this stage, that executes the given action using the supplied Executor when this stage completes.
When this stage is complete, the given action is invoked with the result (or null
if none) and the exception (or null
if none) of this stage as arguments. The returned stage is completed when the action returns.
Unlike method handleAsync
, this method is not designed to translate completion outcomes, so the supplied action should not throw an exception. However, if it does, the following rules apply: If this stage completed normally but the supplied action throws an exception, then the returned stage completes exceptionally with the supplied action's exception. Or, if this stage completed exceptionally and the supplied action throws an exception, then the returned stage completes exceptionally with this stage's exception.
Parameters | |
---|---|
action |
BiConsumer<in T, in Throwable!>!: the action to perform |
executor |
Executor!: the executor to use for asynchronous execution |
Return | |
---|---|
CompletionStage<T>! |
the new CompletionStage |