com.github.davidmoten.rx2

Class RetryWhen.Builder

java.lang.Object

com.github.davidmoten.rx2.RetryWhen.Builder

Enclosing class:

RetryWhen

public static final class RetryWhen.Builder
extends Object

Method Summary

Modifier and Type	Method and Description
RetryWhen.Builder	action(io.reactivex.functions.Consumer<? super RetryWhen.ErrorAndDuration> action)
io.reactivex.functions.Function<io.reactivex.Flowable<? extends Throwable>,io.reactivex.Flowable<Object>>	build()
RetryWhen.Builder	delay(Long delay, TimeUnit unit)
RetryWhen.Builder	delays(io.reactivex.Flowable<Long> delays, TimeUnit unit)
RetryWhen.Builder	delaysInt(io.reactivex.Flowable<Integer> delays, TimeUnit unit)
RetryWhen.Builder	exponentialBackoff(long firstDelay, long maxDelay, TimeUnit unit, double factor)
RetryWhen.Builder	exponentialBackoff(long firstDelay, TimeUnit unit)
RetryWhen.Builder	exponentialBackoff(long firstDelay, TimeUnit unit, double factor)
RetryWhen.Builder	failWhenInstanceOf(Class<? extends Throwable>... classes)
RetryWhen.Builder	maxRetries(int maxRetries)
RetryWhen.Builder	retryIf(io.reactivex.functions.Predicate<Throwable> predicate)
RetryWhen.Builder	retryWhenInstanceOf(Class<? extends Throwable>... classes)
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 RetryWhen.Builder retryWhenInstanceOf(Class<? extends Throwable>... classes)

failWhenInstanceOf

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

retryIf

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

delays

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

delaysInt

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

delay

public RetryWhen.Builder delay(Long delay,
                               TimeUnit unit)

maxRetries

public RetryWhen.Builder maxRetries(int maxRetries)

scheduler

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

action

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

exponentialBackoff

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

exponentialBackoff

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

exponentialBackoff

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

build

public io.reactivex.functions.Function<io.reactivex.Flowable<? extends Throwable>,io.reactivex.Flowable<Object>> build()