Package io.github.resilience4j.retry

Class Retry.AsyncRetryBlock<T>

java.lang.Object

io.github.resilience4j.retry.Retry.AsyncRetryBlock<T>

All Implemented Interfaces:

Runnable

Enclosing interface:

Retry

public static class Retry.AsyncRetryBlock<T>
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private final CompletableFuture<T>	promise
private final Retry.AsyncContext<T>	retryContext
private final ScheduledExecutorService	scheduler
private final Supplier<CompletionStage<T>>	supplier

Constructor Summary

Constructors

Constructor	Description
AsyncRetryBlock(ScheduledExecutorService scheduler, Retry.AsyncContext<T> retryContext, Supplier<CompletionStage<T>> supplier, CompletableFuture<T> promise)

Method Summary

Modifier and Type	Method	Description
private void	onError(Exception t)
private void	onResult(T result)
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

scheduler

private final ScheduledExecutorService scheduler

retryContext

private final Retry.AsyncContext<T> retryContext

supplier

private final Supplier<CompletionStage<T>> supplier

promise

private final CompletableFuture<T> promise

Constructor Details

AsyncRetryBlock

AsyncRetryBlock(ScheduledExecutorService scheduler,
 Retry.AsyncContext<T> retryContext,
 Supplier<CompletionStage<T>> supplier,
 CompletableFuture<T> promise)

Method Details

run

public void run()

Specified by:

run in interface Runnable

onError

private void onError(Exception t)

onResult

private void onResult(T result)