Uses of Class
dev.failsafe.spi.FailsafeFuture
Packages that use FailsafeFuture
Package
Description
The Failsafe Service Provider Interface (SPI).
-
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 withTimeoutExceededExceptionif 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.