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) class
AsyncExecutionImpl<R>
AsyncExecution and AsyncExecutionInternal implementation.Fields in dev.failsafe with type parameters of type AsyncExecutionInternal Modifier and Type Field Description private java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.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> java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
Functions. getPromise(ContextualSupplier<R,R> supplier, java.util.concurrent.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> java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
Functions. getPromiseExecution(AsyncRunnable<R> runnable, java.util.concurrent.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> 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.(package private) static <R> java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
Functions. toExecutionAware(java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.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 AsyncExecutionInternal 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.(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.(package private) static <R> java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.CompletableFuture<ExecutionResult<R>>>
Functions. toExecutionAware(java.util.function.Function<AsyncExecutionInternal<R>,java.util.concurrent.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 AsyncExecutionInternal 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 AsyncExecutionInternal in dev.failsafe.internal
Methods in dev.failsafe.internal that return types with arguments of type AsyncExecutionInternal 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.Methods in dev.failsafe.internal with parameters of type AsyncExecutionInternal Modifier and Type Method Description 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)
Method parameters in dev.failsafe.internal with type arguments of type AsyncExecutionInternal 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)
-
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 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.Methods in dev.failsafe.spi with parameters of type AsyncExecutionInternal Modifier and Type Method Description 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
.Method parameters in dev.failsafe.spi with type arguments of type AsyncExecutionInternal 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.
-