MVVM Architecture template
RxSwift ViewModel中如何选择信号源
-
PublishSubject
-
将对观察者发送订阅后产生的元素，而在订阅前发出的元素将不会发送给观察者。如果你希望观察者接收到所有的元素，你可以通过使用 Observable 的 create 方法来创建 Observable，或者使用 ReplaySubject。
-
PublishRelay
-
就是 PublishSubject 去掉终止事件 onError 或 onCompleted
BehaviorSubject
-
当观察者对 BehaviorSubject 进行订阅时，它会将源 Observable 中最新的元素发送出来（如果不存在最新的元素，就发出默认元素）。然后将随后产生的元素发送出来。
-
BehaviorRelay
-
就是 BehaviorSubject 去掉终止事件 onError 或 onCompleted。
-
Driver
-
是一个精心准备的特征序列。它主要是为了简化 UI 层的代码。不过如果你遇到的序列具有以下特征，你也可以使用它： 不会产生 error 事件 一定在 MainScheduler 监听（主线程监听） 共享附加作用 这些都是驱动 UI 的序列所具有的特征。
-
Signal
-
Signal 和 Driver 相似，唯一的区别是，Driver 会对新观察者回放（重新发送）上一个元素，而 Signal 不会对新观察者回放上一个元素。
-
结论
-
一般情况下状态序列我们会选用 Driver 这个类型，事件序列我们会选用 Signal 这个类型
-
如何选择操作符
-
我想要创建一个 Observable
-
产生特定的一个元素：just
-
经过一段延时：timer
-
从一个序列拉取元素：from
-
重复的产生某一个元素：repeatElement
-
存在自定义逻辑：create
-
每次订阅时产生：deferred
-
每隔一段时间，发出一个元素：interval
-
在一段延时后：timer
-
一个空序列，只有一个完成事件：empty
-
一个任何事件都没有产生的序列：never
-
我想要创建一个 Observable 通过组合其他的 Observables
-
任意一个 Observable 产生了元素，就发出这个元素：merge
-
让这些 Observables 一个接一个的发出元素，当上一个 Observable 元素发送完毕后，下一个 Observable 才能开始发出元素：concat
-
组合多个 Observables 的元素
-
当每一个 Observable 都发出一个新的元素：zip
-
当任意一个 Observable 发出一个新的元素：combineLatest
-
我想要转换 Observable 的元素后，再将它们发出来
-
对每个元素直接转换：map
-
转换到另一个 Observable：flatMap
-
只接收最新的元素转换的 Observable 所产生的元素：flatMapLatest
-
每一个元素转换的 Observable 按顺序产生元素：concatMap
-
基于所有遍历过的元素： scan
-
我想要将产生的每一个元素，拖延一段时间后再发出：delay
-
我想要将产生的事件封装成元素发送出来
-
将他们封装成 Event：materialize
-
然后解封出来：dematerialize
-
我想要忽略掉所有的 next 事件，只接收 completed 和 error 事件：ignoreElements
-
我想创建一个新的 Observable 在原有的序列前面加入一些元素：startWith
-
我想从 Observable 中收集元素，缓存这些元素之后在发出：buffer
-
我想将 Observable 拆分成多个 Observables：window
-
基于元素的共同特征：groupBy
-
我想只接收 Observable 中特定的元素
-
发出唯一的元素：single
-
我想重新从 Observable 中发出某些元素
-
通过判定条件过滤出一些元素：filter
-
仅仅发出头几个元素：take
-
仅仅发出尾部的几个元素：takeLast
-
仅仅发出第 n 个元素：elementAt
-
跳过头几个元素
-
跳过头 n 个元素：skip
-
跳过头几个满足判定的元素：skipWhile，skipWhileWithIndex
-
跳过某段时间内产生的头几个元素：skip
-
跳过头几个元素直到另一个 Observable 发出一个元素：skipUntil
-
只取头几个元素
-
只取头几个满足判定的元素：takeWhile，takeWhileWithIndex
-
只取某段时间内产生的头几个元素：take
-
只取头几个元素直到另一个 Observable 发出一个元素：takeUntil
-
周期性的对 Observable 抽样：sample
-
发出那些元素，这些元素产生后的特定的时间内，没有新的元素产生：debounce
-
直到元素的值发生变化，才发出新的元素：distinctUntilChanged
-
并提供元素是否相等的判定函数：distinctUntilChanged
-
在开始发出元素时，延时后进行订阅：delaySubscription
-
我想要从一些 Observables 中，只取第一个产生元素的 Observable：amb
-
我想评估 Observable 的全部元素
-
并且对每个元素应用聚合方法，待所有元素都应用聚合方法后，发出结果：reduce
-
并且对每个元素应用聚合方法，每次应用聚合方法后，发出结果：scan
-
我想把 Observable 转换为其他的数据结构：as...
-
我想在某个 Scheduler 应用操作符：subscribeOn
-
在某个 Scheduler 监听：observeOn
-
我想要 Observable 发生某个事件时, 采取某个行动：do
-
我想要 Observable 发出一个 error 事件：error
-
如果规定时间内没有产生元素：timeout
-
我想要 Observable 发生错误时，优雅的恢复
-
如果规定时间内没有产生元素，就切换到备选 Observable ：timeout
-
如果产生错误，将错误替换成某个元素 ：catchErrorJustReturn
-
如果产生错误，就切换到备选 Observable ：catchError
-
如果产生错误，就重试 ：retry
-
我创建一个 Disposable 资源，使它与 Observable 具有相同的寿命：using
-
我创建一个 Observable，直到我通知它可以产生元素后，才能产生元素：publish
-
并且，就算是在产生元素后订阅，也要发出全部元素：replay
-
并且，一旦所有观察者取消观察，他就被释放掉：refCount
-
通知它可以产生元素了：connect