Package reactor.kotlin.extra.retry

Functions

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

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

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

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

repeatRandomBackoff
Link copied to clipboard
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.

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

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

retryExponentialBackoff
Link copied to clipboard
fun <T> Flux<T>.retryExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRetry: (RetryContext<T>) -> Unit? = null): Flux<T>

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

fun <T> Mono<T>.retryExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRetry: (RetryContext<T>) -> Unit? = null): Mono<T>

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

retryRandomBackoff
Link copied to clipboard
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.

fun <T> Mono<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRetry: (RetryContext<T>) -> Unit? = null): Mono<T>

Extension to add a Mono.retry variant to Mono that uses a random backoff, as enabled by reactor-extra's Retry builder.