com.github.davidmoten.rx

Class RetryWhen.Builder

java.lang.Object

com.github.davidmoten.rx.RetryWhen.Builder

Enclosing class:

RetryWhen

public static final class RetryWhen.Builder
extends Object

Method Summary

Modifier and Type	Method and Description
RetryWhen.Builder	action(rx.functions.Action1<? super RetryWhen.ErrorAndDuration> action)
rx.functions.Func1<rx.Observable<? extends Throwable>,rx.Observable<?>>	build()
RetryWhen.Builder	delay(Long delay, TimeUnit unit)
RetryWhen.Builder	delays(rx.Observable<Long> delays, TimeUnit unit)
RetryWhen.Builder	delaysInt(rx.Observable<Integer> delays, TimeUnit unit)
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(rx.functions.Func1<Throwable,Boolean> predicate)
RetryWhen.Builder	retryWhenInstanceOf(Class<? extends Throwable>... classes)
RetryWhen.Builder	scheduler(rx.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(rx.functions.Func1<Throwable,Boolean> predicate)

delays

public RetryWhen.Builder delays(rx.Observable<Long> delays,
                                TimeUnit unit)

delaysInt

public RetryWhen.Builder delaysInt(rx.Observable<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(rx.Scheduler scheduler)

action

public RetryWhen.Builder action(rx.functions.Action1<? super RetryWhen.ErrorAndDuration> action)

exponentialBackoff

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

exponentialBackoff

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

build

public rx.functions.Func1<rx.Observable<? extends Throwable>,rx.Observable<?>> build()