@cxm-2016
2016-11-25T17:38:45.000000Z
字数 2375
阅读 2970
RxJava学习指南
版本:1
整理:陈小默
从onError
通知中恢复发射数据
Catch
操作符拦截原始Observable的onError
通知,将它替换为其它的数据项或数据序列,让产生的Observable能够正常终止或者根本不终止。
在某些ReactiveX的实现中,有一个叫onErrorResumeNext
的操作符,它的行为与Catch
相似。
RxJava将Catch
实现为三个不同的操作符:
onErrorReturn
让Observable遇到错误时发射一个特殊的项并且正常终止。
onErrorResumeNext
让Observable在遇到错误时开始发射第二个Observable的数据序列。
onExceptionResumeNext
让Observable在遇到错误时继续发射后面的数据项。
onErrorReturn
方法返回一个镜像原有Observable行为的新Observable,后者会忽略前者的onError
调用,不会将错误传递给观察者,作为替代,它会发发射一个特殊的项并调用观察者的onCompleted
方法。
onErrorResumeNext
方法返回一个镜像原有Observable行为的新Observable,后者会忽略前者的onError
调用,不会将错误传递给观察者,作为替代,它会开始镜像另一个,备用的Observable。
和onErrorResumeNext
类似,onExceptionResumeNext
方法返回一个镜像原有Observable行为的新Observable,也使用一个备用的Observable,不同的是,如果onError
收到的Throwable
不是一个Exception
,它会将错误传递给观察者的onError
方法,不会使用备用的Observable。
如果原始Observable遇到错误,重新订阅它期望它能正常终止
Retry
操作符不会将原始Observable的onError
通知传递给观察者,它会订阅这个Observable,再给它一次机会无错误地完成它的数据序列。Retry
总是传递onNext
通知给观察者,由于重新订阅,可能会造成数据项重复,如上图所示。
RxJava中的实现为retry
和retryWhen
。
无论收到多少次onError
通知,无参数版本的retry
都会继续订阅并发射原始Observable。
接受单个count
参数的retry
会最多重新订阅指定的次数,如果次数超了,它不会尝试再次订阅,它会把最新的一个onError
通知传递给它的观察者。
还有一个版本的retry
接受一个谓词函数作为参数,这个函数的两个参数是:重试次数和导致发射onError
通知的Throwable
。这个函数返回一个布尔值,如果返回true
,retry
应该再次订阅和镜像原始的Observable,如果返回false
,retry
会将最新的一个onError
通知传递给它的观察者。
retry
操作符默认在trampoline
调度器上执行。
retryWhen
和retry
类似,区别是,retryWhen
将onError
中的Throwable
传递给一个函数,这个函数产生另一个Observable,retryWhen
观察它的结果再决定是不是要重新订阅原始的Observable。如果这个Observable发射了一项数据,它就重新订阅,如果这个Observable发射的是onError
通知,它就将这个通知传递给观察者然后终止。
retryWhen
默认在trampoline
调度器上执行,你可以通过参数指定其它的调度器。
示例代码
Observable.create((Subscriber<? super String> s) -> {
System.out.println("subscribing");
s.onError(new RuntimeException("always fails"));
}).retryWhen(attempts -> {
return attempts.zipWith(Observable.range(1, 3), (n, i) -> i).flatMap(i -> {
System.out.println("delay retry by " + i + " second(s)");
return Observable.timer(i, TimeUnit.SECONDS);
});
}).toBlocking().forEach(System.out::println);
输出
subscribing
delay retry by 1 second(s)
subscribing
delay retry by 2 second(s)
subscribing
delay retry by 3 second(s)
subscribing