Top Fields Constructors Methods
org.jooq.lambda

pack-priv final Class SameExecutorCompletionStage<T>

extends Object
implements CompletionStage<T>
Class Inheritance
All Implemented Interfaces
java.util.concurrent.CompletionStage
Imports
java.util.concurrent.CompletableFuture, .CompletionStage, .Executor, java.util.function.BiConsumer, .BiFunction, .Consumer, .Function

Field Summary

Modifier and TypeField and Description
private final Executor
defaultExecutor

private final CompletionStage<T>
delegate

Constructor Summary

AccessConstructor and Description
pack-priv
SameExecutorCompletionStage(CompletionStage<T> delegate, Executor defaultExecutor)

Method Summary

Modifier and TypeMethod and Description
public final CompletionStage<Void>
acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)

Implements java.util.concurrent.CompletionStage.acceptEither.

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.

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

Implements java.util.concurrent.CompletionStage.acceptEitherAsync.

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.

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

Implements java.util.concurrent.CompletionStage.acceptEitherAsync.

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.

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

Implements java.util.concurrent.CompletionStage.applyToEither.

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.

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

Implements java.util.concurrent.CompletionStage.applyToEitherAsync.

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.

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

Implements java.util.concurrent.CompletionStage.applyToEitherAsync.

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.

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

Implements java.util.concurrent.CompletionStage.exceptionally.

Returns a new CompletionStage that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied function.

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

Implements java.util.concurrent.CompletionStage.handle.

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.

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

Implements java.util.concurrent.CompletionStage.handleAsync.

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.

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

Implements java.util.concurrent.CompletionStage.handleAsync.

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.

pack-priv static final <T> SameExecutorCompletionStage<T>
of(CompletionStage<T> delegate, Executor defaultExecutor)

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

Implements java.util.concurrent.CompletionStage.runAfterBoth.

Returns a new CompletionStage that, when this and the other given stage both complete normally, executes the given action.

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

Implements java.util.concurrent.CompletionStage.runAfterBothAsync.

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.

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

Implements java.util.concurrent.CompletionStage.runAfterBothAsync.

Returns a new CompletionStage that, when this and the other given stage both complete normally, executes the given action using the supplied executor.

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

Implements java.util.concurrent.CompletionStage.runAfterEither.

Returns a new CompletionStage that, when either this or the other given stage complete normally, executes the given action.

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

Implements java.util.concurrent.CompletionStage.runAfterEitherAsync.

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.

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

Implements java.util.concurrent.CompletionStage.runAfterEitherAsync.

Returns a new CompletionStage that, when either this or the other given stage complete normally, executes the given action using the supplied executor.

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

Implements java.util.concurrent.CompletionStage.thenAccept.

Returns a new CompletionStage that, when this stage completes normally, is executed with this stage's result as the argument to the supplied action.

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

Implements java.util.concurrent.CompletionStage.thenAcceptAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenAcceptAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenAcceptBoth.

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.

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

Implements java.util.concurrent.CompletionStage.thenAcceptBothAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenAcceptBothAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenApply.

Returns a new CompletionStage that, when this stage completes normally, is executed with this stage's result as the argument to the supplied function.

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

Implements java.util.concurrent.CompletionStage.thenApplyAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenApplyAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenCombine.

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.

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

Implements java.util.concurrent.CompletionStage.thenCombineAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenCombineAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenCompose.

Returns a new CompletionStage that is completed with the same value as the CompletionStage returned by the given function.

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

Implements java.util.concurrent.CompletionStage.thenComposeAsync.

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.

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

Implements java.util.concurrent.CompletionStage.thenComposeAsync.

Returns a new CompletionStage that is completed with the same value as the CompletionStage returned by the given function, executed using the supplied Executor.

public final CompletionStage<Void>
thenRun(Runnable action)

Implements java.util.concurrent.CompletionStage.thenRun.

Returns a new CompletionStage that, when this stage completes normally, executes the given action.

public final CompletionStage<Void>
thenRunAsync(Runnable action)

Implements java.util.concurrent.CompletionStage.thenRunAsync.

Returns a new CompletionStage that, when this stage completes normally, executes the given action using this stage's default asynchronous execution facility.

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

Implements java.util.concurrent.CompletionStage.thenRunAsync.

Returns a new CompletionStage that, when this stage completes normally, executes the given action using the supplied Executor.

public final CompletableFuture<T>
toCompletableFuture()

Implements java.util.concurrent.CompletionStage.toCompletableFuture.

Returns a CompletableFuture maintaining the same completion properties as this stage.

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

Implements java.util.concurrent.CompletionStage.whenComplete.

Returns a new CompletionStage with the same result or exception as this stage, that executes the given action when this stage completes.

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

Implements java.util.concurrent.CompletionStage.whenCompleteAsync.

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.

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

Implements java.util.concurrent.CompletionStage.whenCompleteAsync.

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.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait