com.github.davidmoten.rx2

Class RetryWhen

java.lang.Object

com.github.davidmoten.rx2.RetryWhen

public final class RetryWhen
extends Object

Provides builder for the Function parameter of Flowable.retryWhen(Function). For example:

 o.retryWhen(RetryWhen.maxRetries(4).delay(10, TimeUnit.SECONDS).action(log).build());
 

or

 o.retryWhen(RetryWhen.exponentialBackoff(100, TimeUnit.MILLISECONDS).maxRetries(10).build());
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RetryWhen.Builder
static class	RetryWhen.ErrorAndDuration

Method Summary

Modifier and Type	Method and Description
static RetryWhen.Builder	action(io.reactivex.functions.Consumer<? super RetryWhen.ErrorAndDuration> action)
static RetryWhen.Builder	delay(long delay, TimeUnit unit)
static RetryWhen.Builder	delays(io.reactivex.Flowable<Long> delays, TimeUnit unit)
static RetryWhen.Builder	delaysInt(io.reactivex.Flowable<Integer> delays, TimeUnit unit)
static RetryWhen.Builder	exponentialBackoff(long firstDelay, TimeUnit unit)
static RetryWhen.Builder	exponentialBackoff(long firstDelay, TimeUnit unit, double factor)
static RetryWhen.Builder	failWhenInstanceOf(Class<? extends Throwable>... classes)
static RetryWhen.Builder	maxRetries(int maxRetries)
static RetryWhen.Builder	retryIf(io.reactivex.functions.Predicate<Throwable> predicate)
static RetryWhen.Builder	retryWhenInstanceOf(Class<? extends Throwable>... classes)
static RetryWhen.Builder	scheduler(io.reactivex.Scheduler scheduler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

retryWhenInstanceOf

public static RetryWhen.Builder retryWhenInstanceOf(Class<? extends Throwable>... classes)

failWhenInstanceOf

public static RetryWhen.Builder failWhenInstanceOf(Class<? extends Throwable>... classes)

retryIf

public static RetryWhen.Builder retryIf(io.reactivex.functions.Predicate<Throwable> predicate)

delays

public static RetryWhen.Builder delays(io.reactivex.Flowable<Long> delays,
                                       TimeUnit unit)

delaysInt

public static RetryWhen.Builder delaysInt(io.reactivex.Flowable<Integer> delays,
                                          TimeUnit unit)

delay

public static RetryWhen.Builder delay(long delay,
                                      TimeUnit unit)

maxRetries

public static RetryWhen.Builder maxRetries(int maxRetries)

scheduler

public static RetryWhen.Builder scheduler(io.reactivex.Scheduler scheduler)

action

public static RetryWhen.Builder action(io.reactivex.functions.Consumer<? super RetryWhen.ErrorAndDuration> action)

exponentialBackoff

public static RetryWhen.Builder exponentialBackoff(long firstDelay,
                                                   TimeUnit unit,
                                                   double factor)

exponentialBackoff

public static RetryWhen.Builder exponentialBackoff(long firstDelay,
                                                   TimeUnit unit)