Uses of Interface
dev.failsafe.spi.AsyncExecutionInternal
Packages that use AsyncExecutionInternal
Package
Description
APIs for performing failsafe executions.
The Failsafe Service Provider Interface (SPI).
-
Uses of AsyncExecutionInternal in dev.failsafe
Classes in dev.failsafe that implement AsyncExecutionInternalModifier and TypeClassDescription(package private) final class
AsyncExecution and AsyncExecutionInternal implementation.Fields in dev.failsafe with type parameters of type AsyncExecutionInternalModifier and TypeFieldDescriptionprivate Function
<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> AsyncExecutionImpl.outerFn
Methods in dev.failsafe that return AsyncExecutionInternalMethods in dev.failsafe that return types with arguments of type AsyncExecutionInternalModifier and TypeMethodDescription(package private) static <R> Function
<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> Functions.getPromise
(ContextualSupplier<R, R> supplier, Executor executor) Returns a Function 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.getPromiseExecution
(AsyncRunnable<R> runnable, Executor executor) Returns a Function for asynchronous executions that pre-executes theexecution
, runs therunnable
, and attempts to complete theexecution
if a failure occurs.(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.(package private) static <R> Function
<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> Functions.toExecutionAware
(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn) Returns a Function that returns an execution result if one was previously recorded, else applies theinnerFn
.Method parameters in dev.failsafe with type arguments of type AsyncExecutionInternalModifier 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.(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.(package private) static <R> Function
<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> Functions.toExecutionAware
(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn) Returns a Function that returns an execution result if one was previously recorded, else applies theinnerFn
.Constructor parameters in dev.failsafe with type arguments of type AsyncExecutionInternalModifierConstructorDescription(package private)
AsyncExecutionImpl
(List<Policy<R>> policies, Scheduler scheduler, FailsafeFuture<R> future, boolean asyncExecution, Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn) -
Uses of AsyncExecutionInternal in dev.failsafe.internal
Methods in dev.failsafe.internal that return types with arguments of type AsyncExecutionInternalModifier 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.Methods in dev.failsafe.internal with parameters of type AsyncExecutionInternalModifier and TypeMethodDescriptionRetryPolicyExecutor.handleAsync
(AsyncExecutionInternal<R> execution, Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future, CompletableFuture<ExecutionResult<R>> promise, AtomicReference<ExecutionResult<R>> previousResultRef) Method parameters in dev.failsafe.internal with type arguments of type AsyncExecutionInternalModifier 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) -
Uses of AsyncExecutionInternal in dev.failsafe.spi
Methods in dev.failsafe.spi that return AsyncExecutionInternalModifier and TypeMethodDescriptionAsyncExecutionInternal.copy()
Returns a new copy of the AsyncExecutionInternal.Methods in dev.failsafe.spi that return types with arguments of type AsyncExecutionInternalModifier 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.Methods in dev.failsafe.spi with parameters of type AsyncExecutionInternalModifier and TypeMethodDescriptionprotected CompletableFuture
<ExecutionResult<R>> PolicyExecutor.postExecuteAsync
(AsyncExecutionInternal<R> execution, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future) Performs potentially asynchronous post-execution handling for aresult
.Method parameters in dev.failsafe.spi with type arguments of type AsyncExecutionInternalModifier 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.