reactor-kotlin-extensions/reactor.kotlin.extra.retry/repeatExponentialBackoff

repeatExponentialBackoff

fun <T> Flux<T>.repeatExponentialBackoff(    times: Long,     first: Duration,     max: Duration? = null,     jitter: Boolean = false,     doOnRepeat: (RepeatContext<T>) -> Unit? = null): Flux<T>
Content copied to clipboard

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

Author

Simon Baslé

Since

3.1.1

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

jitter

optional flag to activate random jitter in the backoffs

doOnRepeat

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


fun <T> Mono<T>.repeatExponentialBackoff(    times: Long,     first: Duration,     max: Duration? = null,     jitter: Boolean = false,     doOnRepeat: (RepeatContext<T>) -> Unit? = null): Flux<T>
Content copied to clipboard

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

Author

Simon Baslé

Since

3.1.1

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

jitter

optional flag to activate random jitter in the backoffs

doOnRepeat

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