com.iotize.android.communication.protocol.ble.rx.util

Class RetryWithDelay

java.lang.Object

com.iotize.android.communication.protocol.ble.rx.util.RetryWithDelay

All Implemented Interfaces:

io.reactivex.functions.Function<io.reactivex.Observable<? extends java.lang.Throwable>,io.reactivex.Observable<?>>

public class RetryWithDelay
extends java.lang.Object
implements io.reactivex.functions.Function<io.reactivex.Observable<? extends java.lang.Throwable>,io.reactivex.Observable<?>>

Constructor Summary

Constructors

Constructor and Description
RetryWithDelay(int maxRetries, int retryDelayMillis)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryWithDelay

public RetryWithDelay(int maxRetries,
                      int retryDelayMillis)

Method Detail

apply

public io.reactivex.Observable<?> apply(io.reactivex.Observable<? extends java.lang.Throwable> attempts)

Specified by:

apply in interface io.reactivex.functions.Function<io.reactivex.Observable<? extends java.lang.Throwable>,io.reactivex.Observable<?>>