fun <T> Flux<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Flux<T>
Extension to add a Flux.retry variant to Flux that uses a random backoff, as enabled by reactor-extra's Retry builder.
times
- the maximum number of retry attempts
first
- the initial delay in retrying
max
- the optional upper limit the delay can reach after subsequent backoffs
doOnRetry
- optional Consumer-like lambda that will receive a RetryContext
each time an attempt is made.
Author
Simon Baslé
Since
3.1.1