Constructor Detail

Method Detail

• retryExponentialBackoff

  @Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed. If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.") 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. If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.") 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. If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.") 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. If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.") 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.