Package reactor.kotlin.extra.retry

Functions

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.

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.

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.

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.