-
- All Implemented Interfaces:
public final class RepeatExtensionsKt
-
-
Method Summary
Modifier and Type Method Description final static <T extends Any> Flux<T>
repeatExponentialBackoff(Flux<T> $self, Long times, Duration first, Duration max, Boolean jitter, Function1<RepeatContext<T>, Unit> doOnRepeat)
Extension to add a Flux.repeat variant to Flux that uses an exponential backoff, as enabled by reactor-extra's Repeat builder. final static <T extends Any> Flux<T>
repeatExponentialBackoff(Mono<T> $self, Long times, Duration first, Duration max, Boolean jitter, Function1<RepeatContext<T>, Unit> doOnRepeat)
Extension to add a Mono.repeat variant to Mono that uses an exponential backoff, as enabled by reactor-extra's Repeat builder. final static <T extends Any> Flux<T>
repeatRandomBackoff(Flux<T> $self, Long times, Duration first, Duration max, Function1<RepeatContext<T>, Unit> doOnRepeat)
Extension to add a Flux.repeat variant to Flux that uses a randomized backoff, as enabled by reactor-extra's Repeat builder. final static <T extends Any> Flux<T>
repeatRandomBackoff(Mono<T> $self, Long times, Duration first, Duration max, Function1<RepeatContext<T>, Unit> doOnRepeat)
Extension to add a Mono.repeat variant to Mono that uses a randomized backoff, as enabled by reactor-extra's Repeat builder. -
-
Method Detail
-
repeatExponentialBackoff
@Deprecated(message = "Reactor-Extra repeat features are being phased out.") final static <T extends Any> Flux<T> repeatExponentialBackoff(Flux<T> $self, Long times, Duration first, Duration max, Boolean jitter, Function1<RepeatContext<T>, Unit> doOnRepeat)
Extension to add a Flux.repeat variant to Flux that uses an exponential backoff, as enabled by reactor-extra's Repeat builder.
- Parameters:
times
- the maximum number of retry attemptsfirst
- the initial delay in retryingmax
- the optional upper limit the delay can reach after subsequent backoffsjitter
- optional flag to activate random jitter in the backoffsdoOnRepeat
- optional Consumer-like lambda that will receive a RepeatContext each time an attempt is made.
-
repeatExponentialBackoff
@Deprecated(message = "Reactor-Extra repeat features are being phased out.") final static <T extends Any> Flux<T> repeatExponentialBackoff(Mono<T> $self, Long times, Duration first, Duration max, Boolean jitter, Function1<RepeatContext<T>, Unit> doOnRepeat)
Extension to add a Mono.repeat variant to Mono that uses an exponential backoff, as enabled by reactor-extra's Repeat builder.
- Parameters:
times
- the maximum number of retry attemptsfirst
- the initial delay in retryingmax
- the optional upper limit the delay can reach after subsequent backoffsjitter
- optional flag to activate random jitter in the backoffsdoOnRepeat
- optional Consumer-like lambda that will receive a RepeatContext each time an attempt is made.
-
repeatRandomBackoff
@Deprecated(message = "Reactor-Extra repeat features are being phased out.") final static <T extends Any> Flux<T> repeatRandomBackoff(Flux<T> $self, Long times, Duration first, Duration max, Function1<RepeatContext<T>, Unit> doOnRepeat)
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 attemptsfirst
- the initial delay in retryingmax
- the optional upper limit the delay can reach after subsequent backoffsdoOnRepeat
- optional Consumer-like lambda that will receive a RepeatContext each time an attempt is made.
-
repeatRandomBackoff
@Deprecated(message = "Reactor-Extra repeat features are being phased out.") final static <T extends Any> Flux<T> repeatRandomBackoff(Mono<T> $self, Long times, Duration first, Duration max, Function1<RepeatContext<T>, Unit> doOnRepeat)
Extension to add a Mono.repeat variant to Mono that uses a randomized backoff, as enabled by reactor-extra's Repeat builder.
- Parameters:
times
- the maximum number of retry attemptsfirst
- the initial delay in retryingmax
- the optional upper limit the delay can reach after subsequent backoffsdoOnRepeat
- optional Consumer-like lambda that will receive a RepeatContext each time an attempt is made.
-
-
-
-