retry

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

retry - 图1

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: