retry
优质
小牛编辑
134浏览
2023-12-01
retry
如果源 Observable
产生一个错误事件,重新对它进行订阅,希望它不会再次产生错误
retry 操作符将不会将 error
事件,传递给观察者,然而,它会从新订阅源 Observable
,给这个 Observable
一个重试的机会,让它有机会不产生 error
事件。retry 总是对观察者发出 next
事件,即便源序列产生了一个 error
事件,所以这样可能会产生重复的元素(如上图所示)。
演示 1
let disposeBag = DisposeBag()
var count = 1
let sequenceThatErrors = Observable<String>.create { observer in
observer.onNext("")
observer.onNext("")
observer.onNext("")
if count == 1 {
observer.onError(TestError.test)
print("Error encountered")
count += 1
}
observer.onNext("")
observer.onNext("")
observer.onNext("")
observer.onCompleted()
return Disposables.create()
}
sequenceThatErrors
.retry()
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
输出结果:
Error encountered
演示 2
let disposeBag = DisposeBag()
var count = 1
let sequenceThatErrors = Observable<String>.create { observer in
observer.onNext("")
observer.onNext("")
observer.onNext("")
if count < 5 {
observer.onError(TestError.test)
print("Error encountered")
count += 1
}
observer.onNext("")
observer.onNext("")
observer.onNext("")
observer.onCompleted()
return Disposables.create()
}
sequenceThatErrors
.retry(3)
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
输出结果:
Error encountered
Error encountered
Error encountered
Unhandled error happened: test
subscription called from: