iOS_RxSwift使用（文档整理）

2022-07-20 14:28:44 浏览数 (1)

整理总结了一下文档内容，方便自己查阅~

一、RxSwift可以做什么？

例如：

代码语言：javascript复制
valid = field.rx.text.orEmpty.map{$0.count >= 6}
.share(replay:1) // 多个地方使用时共享(而不是另外创建)
valid.bind(to: button.rx.isEnable)
valid3 = Observable.combineLatest(valid1, valid2){$0 && $1} // 合并
.share(replay:1)
.disposed(by: disposBag) // disposBag管理绑定的生命周期

二、RxSwift核心

例如：

代码语言：javascript复制
text = field.rx.text.orEmpty.asObservable() // text是Observable<String>
valid = text.map{ $0.characters.count >= 6} // valid是Observable<Bool>、map是Operator
observer = tipsLb.rx.isHidden // Observer<Bool>
disposable = valid
						.subscribleOn(MainScheduler.instance) // Scheduler
						.observeOn(MainSchedule.instance)
						.bind(to: observer)
disposable.dispose() // 解绑

三、Observable序列

所有事物皆序列：

代码语言：javascript复制
Observable<Double> // 温度
Observable<onePieceEpisode> // 海贼王
Observable<JSON> // json
Observable<void> // 回调

最直接的创建方式：Observable.create

代码语言：javascript复制
number: Observable<Int> = 
Observable.create{ observer -> Disposable in // 参数 -> 返回类型
                  observer.onNext(0)
                  ...
                  observer.onNext(n)
                  observer.onCompleted() // 表示已经全部生产，没有更多元素了
                  return Disposable.creat()
                 }

四、Observable特征序列

  1. Single = Observable.asSignle()：只发出一个元素/Error
  2. Completable：一个Completed/Error
  3. Maybe = Observable.asMaybe()：一个元素/completed/Error 以上3不像Observable可发出多个元素，也不共享
  4. Driver：不会Error 且 mainThread监听 （可简化UI层代码，解决失败不能try again，后台返回，多次请求）
  5. Signal：与Driver相反，但不会对新观察者回放上一个元素（Driver会，不适用于点击事件）
  6. ControlEvent：UI控件产生事件，无Error，mainThread订阅监听 以上3共享

五、Observer观察者

响应事件的都是观察者

RxSwift已实现的：

  • view.isHidden
  • button.isEnable
  • label.text
  • imageView.image
  • …

最基本的创建方式：Observable.subscrible

代码语言：javascript复制
tap.subscribe(onNext: { [weak self] in
    self?.showAlert()
}, onError: { error in
    print("发生错误： (error.localizedDescription)")
}, onCompleted: {
    print("任务完成")
})
特征观察者：
  1. AnyObservable：可描述任意一种观察者（定义一个回调，在subscrible中执行）详情
  2. Binder：详情
    • 不处理Error（测试环境：执行fataError，发布环境：打印ErrorLog）
    • 确保绑定都在给定Scheduler上执行(默认：MainScheduler)

注：Observer监听到error事件（onError:）就会停止监听！！！

六、Observable & Observer

既是可监听序列 也是 观察者，如：field.text/switch.on/segmentedControl选中/datePick选中/…

RxSwift已定义的辅助类型，它们既是可监听序列也是观察者：

  1. AsyncSubject：事件完成后只发出最后一个元素/Error（即使是先订阅后产生的）
  2. PblishSubject：只收订阅后的元素
  3. ReplaySubject：会发送订阅前的元素，可以设置前n个/前一段时间的
  4. BehaviorSubject：订阅时，发送最新的元素/Error
  5. ControlProperty：UI控件属性，无Error，mainThread订阅监听（同ControlEvent）

七、Operator操作符

创建序列/组合原有序列

filter过滤：filter{ age in age >= 18 }

map转换：map{ Model.init } （JSON -> Model）

Zip配对：Zip{ hamburg, frechFries } （As, Bs -> {A, B}）

forEach遍历：同for in

sorted排序：sorted{ student1, student2 in student1.score > student2.score} 。。。

Rx提供了充分的操作符来帮我们创建序列（操作符列表），当然如果内置的无法满足也可以自定义。选择操作符可以参考决策树

如何使用操作符：直接调用实例方法/静态方法

代码语言：javascript复制
// 1.温度过滤
// 温度
let rxTemperature: Observable<Double> = ...
// filter 操作符
rxTemperature.filter { temperature in temperature > 33 }
    .subscribe(onNext: { temperature in
        print("高温：(temperature)度")
    })
    .disposed(by: disposeBag)

// 2.解析JSON
// JSON
let json: Observable<JSON> = ...
// map 操作符
json.map(Model.init)
    .subscribe(onNext: { model in
        print("取得 Model: (model)")
    })
    .disposed(by: disposeBag)

// 3.成套餐
// 汉堡
let rxHamburg: Observable<Hamburg> = ...
// 薯条
let rxFrenchFries: Observable<FrenchFries> = ...
// zip 操作符
Observable.zip(rxHamburg, rxFrenchFries)
    .subscribe(onNext: { (hamburg, frenchFries) in
        print("取得汉堡: (hamburg) 和薯条：(frenchFries)")
    })
    .disposed(by: disposeBag)

八、Disposable可被清除的资源

Disposable可被清除的资源

例：

九、Scheduler调度器

控制任务在哪个线程或队列运行

如：

代码语言：javascript复制
let rxData: Observable<Data> = ...
rxData 
.subscribleOn(ConcurrentDispatchQueueScheduler(qos: .userInitiated)) // subscribleOn 设置`序列构建函数`在哪执行
// observeOn 设置在哪个线程监听 
.observeOn(MainScheduler.asyncInstance) // 异步事件
//.observeOn(MianScheduler.instance) // 异步事件
.subscrible(onNext:{ [weak self] data in
                    self?.data = data
                   })
.disposed(by: disposeBag)

派发队列DispatchQueue：

  • 主线程：MainScheduler
  • 串行：SerialDsipatchQueueScheduler
  • 并行：ConcurrentDispatchQueueScheduler
  • OperationQueueScheduler抽象了NSOperationQueue，具备其一些特点，如：可以设置maxConcurrentOperationCount 控制同时执行并发任务的最大数量

十、防止Error后序列终止

ErrorHanding错误处理：

十一、冷热信号

建议将其视为序列的属性，而不是单独的类型，因为它们是用同样的抽象来表示的，完全符合它们，可观察的序列Observable sequence

热信号

冷信号

是序列

是序列

无论是否有观察者订阅，都使用资源（产生热能）

观察者订阅之前，不使用资源（不产生热能）

变量/属性/常量，点击坐标，鼠标坐标，UI控件值，当前时间…

异步操作，HTTP连接，TCP连接，流…

通常包含N个元素

通常包含1个元素

无论是否有观察者订阅，都会生成序列元素

晋档有订阅的观察者时才产生序列元素

序列计算资源通常在所有订阅的观察者之间共享

通常为每个订阅的观察者分配计算资源

通常有状态

通常无状态

参考：

RxSwift中文文档

Hot and Cold Observables

swift ios 编程算法 actionscript

0 人点赞