Uses of Class
dev.failsafe.spi.FailsafeFuture
Packages that use FailsafeFuture
Package
Description
APIs for performing failsafe executions.
The Failsafe Service Provider Interface (SPI).
-
Uses of FailsafeFuture in dev.failsafe
Fields in dev.failsafe declared as FailsafeFutureMethods in dev.failsafe with parameters of type FailsafeFutureModifier and TypeMethodDescription(package private) static <R> Function
<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> Functions.getPromiseOfStage
(ContextualSupplier<R, ? extends CompletionStage<? extends R>> supplier, FailsafeFuture<R> future, Executor executor) Returns a Function that for asynchronous executions that pre-executes theexecution
, applies thesupplier
, records the result and returns a promise containing the result.(package private) static <R> Function
<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> Functions.toAsync
(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future) Returns a Function that asynchronously applies theinnerFn
on the first call, synchronously on subsequent calls, and returns a promise containing the result.Method parameters in dev.failsafe with type arguments of type FailsafeFutureModifier and TypeMethodDescriptionprivate <T> CompletableFuture
<T> FailsafeExecutor.callAsync
(Function<FailsafeFuture<T>, Function<AsyncExecutionInternal<T>, CompletableFuture<ExecutionResult<T>>>> innerFn, boolean asyncExecution) Calls the asynchronousinnerFn
via the configured Scheduler, handling results according to the configured policies.Constructors in dev.failsafe with parameters of type FailsafeFutureModifierConstructorDescription(package private)
AsyncExecutionImpl
(List<Policy<R>> policies, Scheduler scheduler, FailsafeFuture<R> future, boolean asyncExecution, Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn) -
Uses of FailsafeFuture in dev.failsafe.internal
Methods in dev.failsafe.internal with parameters of type FailsafeFutureModifier and TypeMethodDescriptionFallbackExecutor.applyAsync
(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future) Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.RetryPolicyExecutor.applyAsync
(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future) TimeoutExecutor.applyAsync
(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future) Schedules a separate timeout call that blocks and fails withTimeoutExceededException
if the policy's timeout is exceeded.RetryPolicyExecutor.handleAsync
(AsyncExecutionInternal<R> execution, Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future, CompletableFuture<ExecutionResult<R>> promise, AtomicReference<ExecutionResult<R>> previousResultRef) RetryPolicyExecutor.onFailureAsync
(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future) Defaults async executions to not be complete untilsays they are
.protected CompletableFuture
<ExecutionResult<R>> BulkheadExecutor.preExecuteAsync
(Scheduler scheduler, FailsafeFuture<R> future) protected CompletableFuture
<ExecutionResult<R>> RateLimiterExecutor.preExecuteAsync
(Scheduler scheduler, FailsafeFuture<R> future) -
Uses of FailsafeFuture in dev.failsafe.spi
Methods in dev.failsafe.spi with parameters of type FailsafeFutureModifier and TypeMethodDescriptionPolicyExecutor.applyAsync
(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future) Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.protected CompletableFuture
<ExecutionResult<R>> PolicyExecutor.onFailureAsync
(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future) Performs potentially asynchrononus post-execution handling for a failedresult
, possibly creating a new result, else returning the originalresult
.protected CompletableFuture
<ExecutionResult<R>> PolicyExecutor.postExecuteAsync
(AsyncExecutionInternal<R> execution, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future) Performs potentially asynchronous post-execution handling for aresult
.protected CompletableFuture
<ExecutionResult<R>> PolicyExecutor.preExecuteAsync
(Scheduler scheduler, FailsafeFuture<R> future) Called before an async execution to return an alternative result or exception such as if execution is not allowed or needed.