程序包 | 说明 |
---|---|
reactor.util.retry |
限定符和类型 | 方法和说明 |
---|---|
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. |
限定符和类型 | 方法和说明 |
---|---|
RetrySpec |
RetrySpec.doAfterRetry(java.util.function.Consumer<Retry.RetrySignal> doAfterRetry)
Add synchronous behavior to be executed after the retry trigger is emitted in
the companion publisher.
|
RetryBackoffSpec |
RetryBackoffSpec.doAfterRetry(java.util.function.Consumer<Retry.RetrySignal> doAfterRetry)
Add synchronous behavior to be executed after the retry trigger is emitted in
the companion publisher.
|
RetrySpec |
RetrySpec.doAfterRetryAsync(java.util.function.Function<Retry.RetrySignal,Mono<java.lang.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(java.util.function.Function<Retry.RetrySignal,Mono<java.lang.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(java.util.function.Consumer<Retry.RetrySignal> doBeforeRetry)
Add synchronous behavior to be executed before the retry trigger is emitted in
the companion publisher.
|
RetryBackoffSpec |
RetryBackoffSpec.doBeforeRetry(java.util.function.Consumer<Retry.RetrySignal> doBeforeRetry)
Add synchronous behavior to be executed before the retry trigger is emitted in
the companion publisher.
|
RetrySpec |
RetrySpec.doBeforeRetryAsync(java.util.function.Function<Retry.RetrySignal,Mono<java.lang.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(java.util.function.Function<Retry.RetrySignal,Mono<java.lang.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(java.util.function.Function<Flux<Retry.RetrySignal>,? extends org.reactivestreams.Publisher<?>> function)
A wrapper around
Function to provide Retry by using lambda expressions. |
Flux<java.lang.Long> |
RetrySpec.generateCompanion(Flux<Retry.RetrySignal> flux) |
abstract org.reactivestreams.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<java.lang.Long> |
RetryBackoffSpec.generateCompanion(Flux<Retry.RetrySignal> t) |
RetryBackoffSpec |
RetryBackoffSpec.onRetryExhaustedThrow(java.util.function.BiFunction<RetryBackoffSpec,Retry.RetrySignal,java.lang.Throwable> retryExhaustedGenerator)
Set the generator for the
Exception to be propagated when the maximum amount of retries
is exhausted. |
RetrySpec |
RetrySpec.onRetryExhaustedThrow(java.util.function.BiFunction<RetrySpec,Retry.RetrySignal,java.lang.Throwable> retryExhaustedGenerator)
Set the generator for the
Exception to be propagated when the maximum amount of retries
is exhausted. |