RxJava操作符-错误处理
onErrorReturn:
public final Observable<T> onErrorReturn(Func1<java.lang.Throwable,? extends T> resumeFunction)
默认情况下,Observer订阅的Observable如果发生异常或错误,那么Observable就不再释放item而是调用Observer的onError方法之后终止。现在可以使用onErrorReturn来改变这个行为了。可以看到onErrorReturn接受一个Func1实现,当源Observable正常执行时onErrorReturn就直接把源Observable释放的item释放出去,一旦源Observable发生了错误或异常,替代原先源Observable调用Observer的onError方法,onErrorReturn中那个Func1实现被调用并接受这个错误或异常作为参数,这个Func1实现的返回值将作为onErrorReturn返回的Observable的item释放出去然后调用Observer的onCompleted方法终止。
onErrorResumeNext:
public final Observable<T> onErrorResumeNext(Func1<java.lang.Throwable,? extends Observable<? extends T>> resumeFunction)
public final Observable<T> onErrorResumeNext(Observable<? extends T> resumeSequence)
和上面差不多,都是源Observable正常的时候由这个操作符新建的Observable把源Observable释放的item直接释放释放出去。一旦源Observable遇到错误,这个onErrorResumeNext会把源Observable用一个新的Observable替掉,然后这个新的Observable如果没遇到什么问题就会释放item给Observer。你可以直接将一个Observable实例传入onErrorResumeNext作为这个新的Observable,也可以传给onErrorResumeNext一个Func1实现,这个Func1实现接受源Observable的错误作为参数,返回新的Observable。
onExceptionResumeNext:
public final Observable<T> onExceptionResumeNext(Observable<? extends T> resumeSequence)
和上面的onErrorResumeNext差不多,不过触发onErrorResumeNext的是源Observable发生了错误(Error),而触发onExceptionResumeNext的是源Observable发生了异常(Exception),如果源Observable发生了错误仍然像默认情况一样调用Observer的onError方法。
retry:
public final Observable<T> retry()
public final Observable<T> retry(long count)
public final Observable<T> retry(Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate)
默认retry在trampoline Scheduler上执行。正常情况一下retry新建的Observable直接把源Observable释放的item释放出去。当源Observable遇到错误或异常时,对于那个无参retry()方法,ta会重新订阅源Observable,只要源Observable遇到错误或异常ta都会重新订阅源Observable,没次数限制;对于retry(long count)可以限制重新订阅的次数,超过这个次数限制,直接调用Observer的onError终止。还有个retry接受一个Func2实现作为参数,Func2接受两个参数第一个是到现在为止retry新建的Observable已经重新订阅源Observable的次数,第二参数是导致源Observable要调用Observer的onError的错误或异常实例,Fun2的返回值是个Boolean用来指示retry新建的Observable是否再次重新订阅源Observable,如果不再订阅,直接将把源Observable最后的调用onError通知传给Observer。值得注意的是,retry新建的Observable会把源Observable释放的所有item都释放出去,即使中间某次重新订阅发生失败,失败时的源Observable释放的item在下次成功订阅时也会随着释放出去,比如第一次订阅失败了,在此期间源Observable发出[1,2],但是第二次成功了源Observable释放了[1,2,3,4,5],那么这次retry新建的Observable释放的完整序列是[1,2,1,2,3,4,5]。
retryWhen:
public final Observable<T> retryWhen(Func1<? super Observable<? extends java.lang.Throwable>,? extends Observable<?>> notificationHandler)
public final Observable<T> retryWhen(Func1<? super Observable<? extends java.lang.Throwable>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
retryWhen默认在trampoline Scheduler上执行,也可以指定ta的Scheduler。源Observable没出状况时直接镜像ta释放的item。一旦源Observable遇到异常,将把这个异常包装成一个Observable传给retryWhen的参数Func1实现,这个Func1实现返回一个Observable,接下来如果这个Observable正常释放一个item,那么retryWhen新建的Observable重新订阅源Obervable,然后镜像释放源Observable释放的item,如果Func1返回的Observable发生错误或异常,发出调用onError通知,那么就直接把这个调用onError通知传递给Observer然后retry新建的Observable终止。