Uses of Class
dev.failsafe.spi.FailsafeFuture
-
Packages that use FailsafeFuture Package Description dev.failsafe APIs for performing failsafe executions.dev.failsafe.internal dev.failsafe.spi The Failsafe Service Provider Interface (SPI). -
-
Uses of FailsafeFuture in dev.failsafe
Fields in dev.failsafe declared as FailsafeFuture Modifier and Type Field Description private FailsafeFuture<R>
AsyncExecutionImpl. future
Methods in dev.failsafe with parameters of type FailsafeFuture Modifier and Type Method Description (package private) static <R> java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
Functions. getPromiseOfStage(ContextualSupplier<R,? extends java.util.concurrent.CompletionStage<? extends R>> supplier, FailsafeFuture<R> future, java.util.concurrent.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> java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
Functions. toAsync(java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.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 FailsafeFuture Modifier and Type Method Description private <T> java.util.concurrent.CompletableFuture<T>
FailsafeExecutor. callAsync(java.util.function.Function<FailsafeFuture<T>,java.util.function.Function<AsyncExecutionInternal<T>,java.util.concurrent.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 FailsafeFuture Constructor Description AsyncExecutionImpl(java.util.List<Policy<R>> policies, Scheduler scheduler, FailsafeFuture<R> future, boolean asyncExecution, java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>> innerFn)
-
Uses of FailsafeFuture in dev.failsafe.internal
Methods in dev.failsafe.internal with parameters of type FailsafeFuture Modifier and Type Method Description java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
FallbackExecutor. applyAsync(java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.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.java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
RetryPolicyExecutor. applyAsync(java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)
java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
TimeoutExecutor. applyAsync(java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.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.java.lang.Object
RetryPolicyExecutor. handleAsync(AsyncExecutionInternal<R> execution, java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future, java.util.concurrent.CompletableFuture<ExecutionResult<R>> promise, java.util.concurrent.atomic.AtomicReference<ExecutionResult<R>> previousResultRef)
java.util.concurrent.CompletableFuture<ExecutionResult<R>>
RetryPolicyExecutor. onFailureAsync(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)
Defaults async executions to not be complete untilsays they are
.protected java.util.concurrent.CompletableFuture<ExecutionResult<R>>
BulkheadExecutor. preExecuteAsync(Scheduler scheduler, FailsafeFuture<R> future)
protected java.util.concurrent.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 FailsafeFuture Modifier and Type Method Description java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
PolicyExecutor. applyAsync(java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.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 java.util.concurrent.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 java.util.concurrent.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 java.util.concurrent.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.
-