网络请求到的数据, BehaviorSubject 作为事件仓库 store,
BehaviorSubject 用户行为事件源, 保持住最新的事件。
用户行为点击,采用 PublishSubject 即时事件源,马上 fire ,作为开关,发起 BehaviorSubject 存储的事件
场景:网络请求到的数据,不是马上展示。是用户点击某个按钮后,才展示
网络请求到的数据,不是马上展示,就需要用 BehaviorSubject 把这个事件 hold 住。
用户点击某个按钮后,才展示。采用 PublishSubject, 作为上面事件的开关,fire 开启事件
代码部分:
struct PerViewModel { private let inputTap = PublishSubject<Bool>() private let inputNet = BehaviorSubject<Model?>(value: nil) var outputNetPop: Observable<Model?> init() { let netOK = inputNet.filter { $0 != nil } outputNetPop = netOK.sample(inputTap) } func click(){ inputTap.onNext(true) } func popUp(net data: Model){ inputNet.onNext(data) }}
RxSwift 的 Operator , Sample 具有这个特性
sample 操作符, 可以不定期的 ( 根据需要 ) 对源Observable ( 第 1 个 ) 进行采样操作。
通过第二个Observable ( 开关 )来控制采样时机。一旦第二个Observable ( 开关 ) 发出一个元素,就从源Observable ( 第 1 个 ) 中取出,最后产生的元素
RxSwift 的 flatMap , 和 flatMapLatest, 我们用起来,一般没什么差别
- 按钮点击,是一个事件的连续流,
- 网络请求,不是一个事件的连续流, 一次性的消耗事件,标准的 trait 特性 Single
- FlatMap
- FlatMapLatest
因为切换订阅对象的情况很少。
一般不会切换,产生订阅事件流的事件流