Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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)
- // Output:
- // 🍎
- // 🍐
- // 🍊
- // Error encountered
- // 🍎
- // 🍐
- // 🍊
- // 🐶
- // 🐱
- // 🐭
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement