前言
- Swift进阶之RxSwift（一）
- Swift进阶之RxSwift（二）
- Swift进阶之RxSwift（三）
- Demo地址，个人水平有限，如有问题，欢迎指出！
- 本文系RxSwift学习笔记最后一章，主要内容包含Error以及Debugging
步入正题
1.Error
当我们创建Observable的时候，其内部默认是带有三个事件的：
- onNext
- onError
- onCompleted
正常情况下，在被dispose之前都会执行onNext事件，这也是我们希望的情况，but shit happens! 这是就会执行onError以及complete，从下面的🌰中来看一下具体执行过程！
-
catchErrorJustReturn
接收到错误是返回特定值，可用于error在预料之中，或者确定不会发生错误的情况。
let disposeBag = DisposeBag()
let sequenceThatFails = PublishSubject<String>()
/// 捕捉到错误后返回😊，执行onCompleted，销毁sequenceThatFails
sequenceThatFails
.catchErrorJustReturn("😊")
.subscribe { print($0) }
.disposed(by: disposeBag)
sequenceThatFails.onNext("😬")
sequenceThatFails.onNext("😨")
/// 模拟发生错误
sequenceThatFails.onError(TestError.test)
/// 打印结果
next(😬)
next(😨)
next(😊)
completed
-
catchError
当捕捉到错误时，讲执行操作交给另外的Observable
let disposeBag = DisposeBag()
/// 创建两个subject
let sequenceThatFails = PublishSubject<String>()
let recoverySequence = PublishSubject<String>()
/// shit happend! 捕捉到error时，返回recoverySequence，sequenceThatFails发送complete，销毁sequenceThatFails。
sequenceThatFails
.catchError {
print("Error:", $0)
return recoverySequence
}
.subscribe { print($0) }
.disposed(by: disposeBag)
sequenceThatFails.onNext("😬")
sequenceThatFails.onNext("😨")
sequenceThatFails.onError(TestError.test)
recoverySequence.onNext("😊")
/// 打印结果
next(😬)
next(😨)
Error: test
next(😊)
-
retry and retry(_:)
发生错误时进行重试
let disposeBag = DisposeBag()
var count = 1
let sequenceThatErrors = Observable<String>.create { observer in
observer.onNext("🍎")
observer.onNext("🍐")
/// 模拟发生错误
if count == 1 {
observer.onError(TestError.test)
print("Error encountered")
count += 1
}
observer.onNext("🐶")
observer.onNext("🐱")
observer.onCompleted()
return Disposables.create()
}
sequenceThatErrors
.retry()
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
发生错误是重试，参数为次数
let disposeBag = DisposeBag()
var count = 1
let sequenceThatErrors = Observable<String>.create { observer in
observer.onNext("🍎")
observer.onNext("🍐")
if count < 5 {
observer.onError(TestError.test)
print("Error encountered")
count += 1
}
observer.onNext("🐶")
observer.onNext("🐱")
observer.onCompleted()
return Disposables.create()
}
sequenceThatErrors
.retry(3)
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
** 开发过程中，没有人希望出现错误，但是错误是不可避免的，当发生错误是我们可以通过上述方法来进行补救，我们也可以通过Debug来减少错误的发生！**
2.Debugging
-
debug
打印所有的订阅，事件以及销毁操作
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)
.debug()
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
-
RxSwift.Resources.total
有点类似于引用计数的东西，默认是不开启的，如果需要使用的话，在cocoapod文件中添加点东西，所以你的Podfile文件看起来应该是这样的
target 'AppTarget' do
pod 'RxSwift'
end
/// 开启 RxSwift.Resources.total
post_install do |installer|
installer.pods_project.targets.each do |target|
if target.name == 'RxSwift'
target.build_configurations.each do |config|
if config.name == 'Debug'
config.build_settings['OTHER_SWIFT_FLAGS'] ||= ['-D', 'TRACE_RESOURCES']
end
end
end
end
end
总结
终于学完了，本系列文章基本上涵盖了RxSwift官方demo中的所有用法，我这里最多只能起到个抛砖引玉的作用，Rx博大精深，想要用好还是需要下点功夫的！各位加油！
** 另外，在ReactiveObjC中有许多方法是与cocoa部分关联的，但是在RxSwift中并不包含，需要引入RxCocoa方可使用！**
码字好辛苦的，各位不吝赐个赞呗！
