Uses of Interface
dev.failsafe.spi.AsyncExecutionInternal

Packages that use AsyncExecutionInternal

Package	Description
dev.failsafe	APIs for performing failsafe executions.
dev.failsafe.internal
dev.failsafe.spi	The Failsafe Service Provider Interface (SPI).

Uses of AsyncExecutionInternal in dev.failsafe

Classes in dev.failsafe that implement AsyncExecutionInternal

Modifier and Type	Class	Description
(package private) final class	AsyncExecutionImpl<R>	AsyncExecution and AsyncExecutionInternal implementation.

Fields in dev.failsafe with type parameters of type AsyncExecutionInternal

Modifier and Type	Field	Description
private Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	AsyncExecutionImpl.outerFn

Methods in dev.failsafe that return AsyncExecutionInternal

Modifier and Type	Method	Description
AsyncExecutionInternal<R>	AsyncExecutionImpl.copy()

Methods in dev.failsafe that return types with arguments of type AsyncExecutionInternal

Modifier and Type	Method	Description
(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 the execution, applies the supplier, 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 the execution, runs the runnable, and attempts to complete the execution 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 the execution, applies the supplier, 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 the innerFn 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 the innerFn.

Method parameters in dev.failsafe with type arguments of type AsyncExecutionInternal

Modifier and Type	Method	Description
private <T> CompletableFuture<T>	FailsafeExecutor.callAsync(Function<FailsafeFuture<T>,Function<AsyncExecutionInternal<T>,CompletableFuture<ExecutionResult<T>>>> innerFn, boolean asyncExecution)	Calls the asynchronous innerFn 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 the innerFn 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 the innerFn.

Constructor parameters in dev.failsafe with type arguments of type AsyncExecutionInternal

Modifier	Constructor	Description
(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 AsyncExecutionInternal

Modifier and Type	Method	Description
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	FallbackExecutor.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.
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	RetryPolicyExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	TimeoutExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Schedules a separate timeout call that blocks and fails with TimeoutExceededException if the policy's timeout is exceeded.

Methods in dev.failsafe.internal with parameters of type AsyncExecutionInternal

Modifier and Type	Method	Description
Object	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)

Method parameters in dev.failsafe.internal with type arguments of type AsyncExecutionInternal

Modifier and Type	Method	Description
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	FallbackExecutor.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.
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	RetryPolicyExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	TimeoutExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Schedules a separate timeout call that blocks and fails with TimeoutExceededException if the policy's timeout is exceeded.
Object	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 AsyncExecutionInternal

Modifier and Type	Method	Description
AsyncExecutionInternal<R>	AsyncExecutionInternal.copy()	Returns a new copy of the AsyncExecutionInternal.

Methods in dev.failsafe.spi that return types with arguments of type AsyncExecutionInternal

Modifier and Type	Method	Description
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	PolicyExecutor.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 AsyncExecutionInternal

Modifier and Type	Method	Description
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.postExecuteAsync(AsyncExecutionInternal<R> execution, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Performs potentially asynchronous post-execution handling for a result.

Method parameters in dev.failsafe.spi with type arguments of type AsyncExecutionInternal

Modifier and Type	Method	Description
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	PolicyExecutor.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.