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. futureMethods 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 theinnerFnon 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 asynchronousinnerFnvia 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 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)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.
-