reactor-kotlin-extensions / reactor.kotlin.extra.retry / reactor.core.publisher.Flux / repeatRandomBackoff

repeatRandomBackoff

fun <T> Flux<T>.repeatRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>

Extension to add a Flux.repeat variant to Flux that uses a randomized backoff, as enabled by reactor-extra's Repeat builder.

Parameters

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

doOnRepeat - optional Consumer-like lambda that will receive a RepeatContext each time an attempt is made.

Author
Simon Baslé

Since
3.1.1