程序包 | 说明 |
---|---|
reactor.core.publisher | |
reactor.util.retry |
限定符和类型 | 方法和说明 |
---|---|
Mono<T> |
Mono.retryWhen(Retry retrySpec)
|
Flux<T> |
Flux.retryWhen(Retry retrySpec)
Retries this
Flux in response to signals emitted by a companion Publisher . |
限定符和类型 | 类和说明 |
---|---|
class |
RetryBackoffSpec
A
Retry strategy based on exponential backoffs, with configurable features. |
class |
RetrySpec
A simple count-based
Retry strategy with configurable features. |
限定符和类型 | 方法和说明 |
---|---|
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. |
static Retry |
Retry.withThrowable(java.util.function.Function<Flux<java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> function)
|