Package 

Class RetryExtensionsKt

    • Constructor Detail

    • Method Detail

      • retryExponentialBackoff

        @Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed.") final static <T extends Any> Flux<T> retryExponentialBackoff(Flux<T> $self, Long times, Duration first, Duration max, Boolean jitter, Function1<RetryContext<T>, Unit> doOnRetry)

        Extension to add a Flux.retry variant to Flux that uses an exponential backoff, as enabled by reactor-extra's Retry 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
        doOnRetry - optional Consumer-like lambda that will receive a RetryContext each time an attempt is made.
      • retryExponentialBackoff

        @Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed.") final static <T extends Any> Mono<T> retryExponentialBackoff(Mono<T> $self, Long times, Duration first, Duration max, Boolean jitter, Function1<RetryContext<T>, Unit> doOnRetry)

        Extension to add a Mono.retry variant to Mono that uses an exponential backoff, as enabled by reactor-extra's Retry 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
        doOnRetry - optional Consumer-like lambda that will receive a RetryContext each time an attempt is made.
      • retryRandomBackoff

        @Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed.") final static <T extends Any> Flux<T> retryRandomBackoff(Flux<T> $self, Long times, Duration first, Duration max, Function1<RetryContext<T>, Unit> doOnRetry)

        Extension to add a Flux.retry variant to Flux that uses a random backoff, as enabled by reactor-extra's Retry 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
        doOnRetry - optional Consumer-like lambda that will receive a RetryContext each time an attempt is made.
      • retryRandomBackoff

        @Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed.") final static <T extends Any> Mono<T> retryRandomBackoff(Mono<T> $self, Long times, Duration first, Duration max, Function1<RetryContext<T>, Unit> doOnRetry)

        Extension to add a Mono.retry variant to Mono that uses a random backoff, as enabled by reactor-extra's Retry 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
        doOnRetry - optional Consumer-like lambda that will receive a RetryContext each time an attempt is made.