com.radixdlt.client.core.util

Class IncreasingRetryTimer

java.lang.Object

com.radixdlt.client.core.util.IncreasingRetryTimer

All Implemented Interfaces:

io.reactivex.functions.Function<io.reactivex.Observable<java.lang.Throwable>,io.reactivex.ObservableSource<java.lang.Long>>

public class IncreasingRetryTimer
extends java.lang.Object
implements io.reactivex.functions.Function<io.reactivex.Observable<java.lang.Throwable>,io.reactivex.ObservableSource<java.lang.Long>>

Constructor Summary

Constructors

Constructor and Description
IncreasingRetryTimer(java.lang.Class<? extends java.lang.Exception> retryOnClass)
IncreasingRetryTimer(io.reactivex.functions.Predicate<java.lang.Throwable> filter)

Method Summary

Modifier and Type	Method and Description
io.reactivex.ObservableSource<java.lang.Long>	apply(io.reactivex.Observable<java.lang.Throwable> attempts)

Methods inherited from class java.lang.Object

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

Constructor Detail

IncreasingRetryTimer

public IncreasingRetryTimer(java.lang.Class<? extends java.lang.Exception> retryOnClass)

IncreasingRetryTimer

public IncreasingRetryTimer(io.reactivex.functions.Predicate<java.lang.Throwable> filter)

Method Detail

apply

public io.reactivex.ObservableSource<java.lang.Long> apply(io.reactivex.Observable<java.lang.Throwable> attempts)

Specified by:

apply in interface io.reactivex.functions.Function<io.reactivex.Observable<java.lang.Throwable>,io.reactivex.ObservableSource<java.lang.Long>>