public class RetryWithDelay
extends java.lang.Object
implements io.reactivex.functions.Function<io.reactivex.Observable<java.lang.Throwable>,io.reactivex.ObservableSource<?>>
| Modifier and Type | Field and Description |
|---|---|
java.lang.String |
TAG |
| Constructor and Description |
|---|
RetryWithDelay(int maxRetries,
int retryDelaySecond) |
| Modifier and Type | Method and Description |
|---|---|
io.reactivex.ObservableSource<?> |
apply(io.reactivex.Observable<java.lang.Throwable> throwableObservable) |
public io.reactivex.ObservableSource<?> apply(@NonNull
io.reactivex.Observable<java.lang.Throwable> throwableObservable)
throws java.lang.Exception
apply in interface io.reactivex.functions.Function<io.reactivex.Observable<java.lang.Throwable>,io.reactivex.ObservableSource<?>>java.lang.Exception