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终止。