一、描述

如果原始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调度器上执行。

二、示意图

retry

三、示例代码

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();
    }
})
    .retry(1)
    .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: 0
onNext: 1
onNext: 2
onNext: 3
onError: Integer is 4!

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

五、更多

retry操作符还有以下变体：

retry()
retry(long)
retry(Func2)

跟retry相关的操作符还有：

retryWhen(Func1)
retryWhen(Func1,Scheduler)

详情可查阅下面的参考资料。

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客