Uses of Interface
com.dianxin.tori.base.concurrent.FutureAction

Packages that use FutureAction

Package	Description
com.dianxin.tori.base.concurrent

Uses of FutureAction in com.dianxin.tori.base.concurrent

Methods in com.dianxin.tori.base.concurrent that return FutureAction

Modifier and Type	Method	Description
static <T> FutureAction<T>	FutureAction.action(@NotNull Callable<T> task)	Creates a new FutureAction from a given Callable task, but Executor is IO.
static <T> FutureAction<T>	FutureAction.action(@NotNull Callable<T> task, @Nullable Executor executor)	Creates a new FutureAction from a given Callable task.
default @NotNull FutureAction<T>	FutureAction.addCheck(@NotNull BooleanSupplier checks)	Appends a new check to the existing ones using a logical AND (invalid input: '&'invalid input: '&').
default <U, O> @NotNull FutureAction<O>	FutureAction.and(@NotNull FutureAction<U> other, @NotNull BiFunction<? super T,? super U,? extends O> accumulator)	Combines the result of this action with another action using an accumulator function.
static <E> @NotNull FutureAction<List<E>>	FutureAction.collect(@NotNull FutureAction<? extends E>... actions)	Sequences multiple actions to run sequentially (one after another).
static <E> @NotNull FutureAction<List<E>>	FutureAction.collectParallel(@NotNull FutureAction<? extends E>... actions)	Dispatches multiple actions to run in parallel simultaneously.
static <T> FutureAction<T>	FutureAction.completed(T value)	Creates a FutureAction that is already completed with the given value.
@NotNull FutureAction<T>	FutureAction.deadline(long timestamp)	Sets an absolute Unix timestamp deadline for this action.
default @NotNull FutureAction<T>	FutureAction.delay(long delay, @NotNull TimeUnit unit)	Delays the execution or completion of this action by a specified duration.
<U> @NotNull FutureAction<U>	FutureAction.flatMap(@NotNull Function<? super T,? extends FutureAction<U>> mapper)	Chains another asynchronous action to run after this one completes successfully.
static <T> FutureAction<T>	FutureAction.fromCompletableFuture(@NotNull CompletableFuture<T> future, @Nullable Executor executor)	Creates a new FutureAction from a given CompletableFuture.
<U> @NotNull FutureAction<U>	FutureAction.map(@NotNull Function<? super T,? extends U> mapper)	Transforms the result of this action using the provided mapping function.
FutureAction<T>	FutureAction.onErrorFlatMap(@Nullable Predicate<? super Throwable> condition, @NotNull Function<? super Throwable,? extends FutureAction<? extends T>> map)	Conditionally handles an exception by returning an entirely new asynchronous fallback action.
default FutureAction<T>	FutureAction.onErrorMap(@NotNull Function<? super Throwable,? extends T> map)	Maps the exception thrown by this action into a default successful result.
FutureAction<T>	FutureAction.onErrorMap(@Nullable Predicate<? super Throwable> condition, @NotNull Function<? super Throwable,? extends T> map)	Conditionally maps the exception into a successful result.
@NotNull FutureAction<T>	FutureAction.onErrorReturn(T fallback)	Directly returns a hardcoded fallback value if an exception occurs.
@NotNull FutureAction<T>	FutureAction.onExecutor(@NotNull Executor executor)	Transfers the completion processing of this action to a specific executor.
@NotNull FutureAction<T>	FutureAction.onFailure(@NotNull Consumer<? super Throwable> failure)	Appends a failure callback without interrupting the chain.
@NotNull FutureAction<T>	FutureAction.onSuccess(@NotNull Consumer<? super T> con)	Appends a success callback without interrupting the chain.
@NotNull FutureAction<T>	FutureAction.recover(@NotNull Function<Throwable,T> fallback)	Recovers from an exception by providing a fallback value.
default @NotNull FutureAction<T>	FutureAction.retryIfError(int retries)	Retries this action immediately up to the specified maximum attempts if an error occurs.
default @NotNull FutureAction<T>	FutureAction.retryIfError(int retries, @NotNull Duration delay)	Retries this action with a fixed backoff delay between attempts if an error occurs.
default @NotNull FutureAction<T>	FutureAction.retryIfError(int retries, @NotNull Duration delay, @Nullable Runnable onRetry)	Retries this action with a fixed backoff delay and an execution hook invoked prior to each retry.
default @NotNull FutureAction<T>	FutureAction.retryIfError(int retries, @NotNull Duration delay, @Nullable Runnable onRetry, @Nullable Predicate<? super Throwable> condition)	Retries this action using a comprehensive set of shortcut configurations including backoff, lifecycle hook, and error filtering.
@NotNull FutureAction<T>	FutureAction.retryWhen(@NotNull Retry retry)	Retries this action based on a custom retry strategy defined by a Retry policy.
@NotNull FutureAction<T>	FutureAction.setChecks(@Nullable BooleanSupplier checks)	Sets a condition (check) that must return true before the action is executed.
default @NotNull FutureAction<T>	FutureAction.timeout(long timeout, @NotNull TimeUnit unit)	Sets a relative timeout for this action.
default @NotNull FutureAction<List<T>>	FutureAction.zip(@NotNull FutureAction<? extends T> first, @NotNull FutureAction<? extends T>... other)	Zips the results of multiple actions together in parallel execution.

Methods in com.dianxin.tori.base.concurrent with parameters of type FutureAction

Modifier and Type	Method	Description
default <U, O> @NotNull FutureAction<O>	FutureAction.and(@NotNull FutureAction<U> other, @NotNull BiFunction<? super T,? super U,? extends O> accumulator)	Combines the result of this action with another action using an accumulator function.
static <E> @NotNull FutureAction<List<E>>	FutureAction.collect(@NotNull FutureAction<? extends E>... actions)	Sequences multiple actions to run sequentially (one after another).
static <E> @NotNull FutureAction<List<E>>	FutureAction.collectParallel(@NotNull FutureAction<? extends E>... actions)	Dispatches multiple actions to run in parallel simultaneously.
default @NotNull FutureAction<List<T>>	FutureAction.zip(@NotNull FutureAction<? extends T> first, @NotNull FutureAction<? extends T>... other)	Zips the results of multiple actions together in parallel execution.

Method parameters in com.dianxin.tori.base.concurrent with type arguments of type FutureAction

Modifier and Type	Method	Description
<U> @NotNull FutureAction<U>	FutureAction.flatMap(@NotNull Function<? super T,? extends FutureAction<U>> mapper)	Chains another asynchronous action to run after this one completes successfully.
FutureAction<T>	FutureAction.onErrorFlatMap(@Nullable Predicate<? super Throwable> condition, @NotNull Function<? super Throwable,? extends FutureAction<? extends T>> map)	Conditionally handles an exception by returning an entirely new asynchronous fallback action.