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) classAsyncExecutionImpl<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. outerFnMethods 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 theexecutionif 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 theinnerFnon 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 asynchronousinnerFnvia 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 theinnerFnon 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 withTimeoutExceededExceptionif the policy's timeout is exceeded.Methods in dev.failsafe.internal with parameters of type AsyncExecutionInternal Modifier and Type Method Description java.lang.ObjectRetryPolicyExecutor. 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 withTimeoutExceededExceptionif the policy's timeout is exceeded.java.lang.ObjectRetryPolicyExecutor. 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.
-