retry

如果源 Observable 产生一个错误事件，重新对它进行订阅，希望它不会再次产生错误

retry 操作符将不会将 error 事件，传递给观察者，然而，它会从新订阅源 Observable，给这个 Observable 一个重试的机会，让它有机会不产生 error 事件。retry 总是对观察者发出 next 事件，即便源序列产生了一个 error 事件，所以这样可能会产生重复的元素（如上图所示）。

演示 1

1. let disposeBag = DisposeBag()
2. var count = 1

4. let sequenceThatErrors = Observable<String>.create { observer in
5. observer.onNext("?")
6. observer.onNext("?")
7. observer.onNext("?")

9. if count == 1 {
10. observer.onError(TestError.test)
11. print("Error encountered")
12. count += 1
13. }

15. observer.onNext("?")
16. observer.onNext("?")
17. observer.onNext("?")
18. observer.onCompleted()

20. return Disposables.create()
21. }

23. sequenceThatErrors
24. .retry()
25. .subscribe(onNext: { print($0) })
26. .disposed(by: disposeBag)

输出结果：

1. ?
2. ?
3. ?
4. Error encountered
5. ?
6. ?
7. ?
8. ?
9. ?
10. ?

演示 2

1. let disposeBag = DisposeBag()
2. var count = 1

4. let sequenceThatErrors = Observable<String>.create { observer in
5. observer.onNext("?")
6. observer.onNext("?")
7. observer.onNext("?")

9. if count < 5 {
10. observer.onError(TestError.test)
11. print("Error encountered")
12. count += 1
13. }

15. observer.onNext("?")
16. observer.onNext("?")
17. observer.onNext("?")
18. observer.onCompleted()

20. return Disposables.create()
21. }

23. sequenceThatErrors
24. .retry(3)
25. .subscribe(onNext: { print($0) })
26. .disposed(by: disposeBag)

输出结果：

1. ?
2. ?
3. ?
4. Error encountered
5. ?
6. ?
7. ?
8. Error encountered
9. ?
10. ?
11. ?
12. Error encountered
13. Unhandled error happened: test
14. subscription called from: