Package 

Class RepeatExtensionsKt

    • Constructor Detail

    • 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 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.
      • 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 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.
      • 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 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.
      • 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 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.