me.jessyan.rxerrorhandler.handler

Class RetryWithDelayOfFlowable

java.lang.Object

me.jessyan.rxerrorhandler.handler.RetryWithDelayOfFlowable

All Implemented Interfaces:

io.reactivex.functions.Function<io.reactivex.Flowable<java.lang.Throwable>,org.reactivestreams.Publisher<?>>

public class RetryWithDelayOfFlowable
extends java.lang.Object
implements io.reactivex.functions.Function<io.reactivex.Flowable<java.lang.Throwable>,org.reactivestreams.Publisher<?>>

================================================ Created by JessYan on 9/22/2017 15:25 Contact me Follow me ================================================

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	TAG

Constructor Summary

Constructors

Constructor and Description
RetryWithDelayOfFlowable(int maxRetries, int retryDelaySecond)

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<?>	apply(io.reactivex.Flowable<java.lang.Throwable> throwableFlowable)

Methods inherited from class java.lang.Object

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

Field Detail

TAG

public final java.lang.String TAG

Constructor Detail

RetryWithDelayOfFlowable

public RetryWithDelayOfFlowable(int maxRetries,
                                int retryDelaySecond)

Method Detail

apply

public org.reactivestreams.Publisher<?> apply(@NonNull
                                              io.reactivex.Flowable<java.lang.Throwable> throwableFlowable)
                                       throws java.lang.Exception

Specified by:

apply in interface io.reactivex.functions.Function<io.reactivex.Flowable<java.lang.Throwable>,org.reactivestreams.Publisher<?>>

Throws:

java.lang.Exception