一、描述

让Observable在遇到错误时开始发射第二个Observable的数据序列。

onErrorResumeNext方法返回一个镜像原有Observable行为的新Observable，后者会忽略前者的onError调用，不会将错误传递给观察者，作为替代，它会开始镜像另一个，备用的Observable。

二、示意图

onErrorResumeNext

三、示例代码

Observable.create(new Observable.OnSubscribe<Integer>() {
    @Override
    public void call(Subscriber<? super Integer> subscriber) {
        if (subscriber.isUnsubscribed()) {
            return;
        }

        for (int i = 0; i < 7; i++) {
            if (i == 4) {
                subscriber.onError(new Exception("Integer is 4!"));
            } else {
                subscriber.onNext(i);
            }
        }
        subscriber.onCompleted();
    }
})
    .onErrorResumeNext(new Func1<Throwable, Observable<? extends Integer>>() {
        @Override
        public Observable<? extends Integer> call(Throwable throwable) {
            return Observable.just(166, 167, 168);
        }
    })
    .subscribe(new Subscriber<Integer>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(Integer integer) {
            System.out.println("onNext: " + integer);
        }
    });

四、运行结果

onNext: 0
onNext: 1
onNext: 2
onNext: 3
onNext: 166
onNext: 167
onNext: 168
onCompleted.

onErrorResumeNext操作符跟onErrorReturn类似，只不过onErrorReturn只能在错误或异常发生时只返回一个和源Observable相同类型的结果，而onErrorResumeNext操作符是在错误或异常发生时返回一个Observable，也就是说可以返回多个和源Observable相同类型的结果。

项目代码已上传到Github：https://github.com/SherlockShi/RxJavaBestPractise

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注SherlockShi博客