Uses of Interface
reactor.util.retry.Retry.RetrySignal

Packages that use Retry.RetrySignal

Package	Description
reactor.util.retry

Uses of Retry.RetrySignal in reactor.util.retry

Methods in reactor.util.retry that return Retry.RetrySignal

Modifier and Type	Method and Description
default Retry.RetrySignal	Retry.RetrySignal.copy() An immutable copy of this Retry.RetrySignal which is guaranteed to give a consistent view of the state at the time at which this method is invoked.

Method parameters in reactor.util.retry with type arguments of type Retry.RetrySignal

Modifier and Type	Method and Description
RetrySpec	RetrySpec.doAfterRetry(Consumer<Retry.RetrySignal> doAfterRetry) Add synchronous behavior to be executed after the retry trigger is emitted in the companion publisher.
RetryBackoffSpec	RetryBackoffSpec.doAfterRetry(Consumer<Retry.RetrySignal> doAfterRetry) Add synchronous behavior to be executed after the retry trigger is emitted in the companion publisher.
RetrySpec	RetrySpec.doAfterRetryAsync(Function<Retry.RetrySignal,Mono<Void>> doAsyncAfterRetry) Add asynchronous behavior to be executed after the current retry trigger in the companion publisher, thus delaying the resulting retry trigger with the additional Mono.
RetryBackoffSpec	RetryBackoffSpec.doAfterRetryAsync(Function<Retry.RetrySignal,Mono<Void>> doAsyncAfterRetry) Add asynchronous behavior to be executed after the current retry trigger in the companion publisher, thus delaying the resulting retry trigger with the additional Mono.
RetrySpec	RetrySpec.doBeforeRetry(Consumer<Retry.RetrySignal> doBeforeRetry) Add synchronous behavior to be executed before the retry trigger is emitted in the companion publisher.
RetryBackoffSpec	RetryBackoffSpec.doBeforeRetry(Consumer<Retry.RetrySignal> doBeforeRetry) Add synchronous behavior to be executed before the retry trigger is emitted in the companion publisher.
RetrySpec	RetrySpec.doBeforeRetryAsync(Function<Retry.RetrySignal,Mono<Void>> doAsyncBeforeRetry) Add asynchronous behavior to be executed before the current retry trigger in the companion publisher, thus delaying the resulting retry trigger with the additional Mono.
RetryBackoffSpec	RetryBackoffSpec.doBeforeRetryAsync(Function<Retry.RetrySignal,Mono<Void>> doAsyncBeforeRetry) Add asynchronous behavior to be executed before the current retry trigger in the companion publisher, thus delaying the resulting retry trigger with the additional Mono.
static Retry	Retry.from(Function<Flux<Retry.RetrySignal>,? extends Publisher<?>> function) A wrapper around Function to provide Retry by using lambda expressions.
Flux<Long>	RetrySpec.generateCompanion(Flux<Retry.RetrySignal> flux)
abstract Publisher<?>	Retry.generateCompanion(Flux<Retry.RetrySignal> retrySignals) Generates the companion publisher responsible for reacting to incoming Retry.RetrySignal emissions, effectively deciding when to retry.
Flux<Long>	RetryBackoffSpec.generateCompanion(Flux<Retry.RetrySignal> t)
RetryBackoffSpec	RetryBackoffSpec.onRetryExhaustedThrow(BiFunction<RetryBackoffSpec,Retry.RetrySignal,Throwable> retryExhaustedGenerator) Set the generator for the Exception to be propagated when the maximum amount of retries is exhausted.
RetrySpec	RetrySpec.onRetryExhaustedThrow(BiFunction<RetrySpec,Retry.RetrySignal,Throwable> retryExhaustedGenerator) Set the generator for the Exception to be propagated when the maximum amount of retries is exhausted.