RxSwift 操作符决策树

之前列举了很多操作符的用法，还有很多我们没有列举的。其实写了那么多操作符有时候我还是会忘记选择哪一个。这个时候，我发现在RxSwift中文文档有一篇关于选择操作符的文章。这一篇水文纯搬运。

我想要创建一个 Observable

我想要创建一个 Observable 通过组合其他的 Observables

任意一个 Observable 产生了元素，就发出这个元素：merge
让这些 Observables 一个接一个的发出元素，当上一个 Observable 元素发送完毕后，下一个Observable 才能开始发出元素：concat
组合多个 Observables 的元素
- 当每一个 Observable 都发出一个新的元素：zip
- 当任意一个 Observable 发出一个新的元素：combineLatest

我想要转换 Observable 的元素后，再将它们发出来

对每个元素直接转换：map
转换到另一个 Observable：flatMap
- 只接收最新的元素转换的 Observable 所产生的元素：flatMapLatest
- 每一个元素转换的 Observable 按顺序产生元素：concatMap
基于所有遍历过的元素： scan

我想要将产生的每一个元素，拖延一段时间后再发出：delay

我想要将产生的事件封装成元素发送出来

我想要忽略掉所有的 next 事件，只接收 completed 和 error 事件：ignoreElements

我想创建一个新的 Observable 在原有的序列前面加入一些元素：startWith

我想从 Observable 中收集元素，缓存这些元素之后在发出：buffer

我想将 Observable 拆分成多个 Observables：window

我想只接收 Observable 中特定的元素

我想重新从 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 的全部元素

我想把 Observable 转换为其他的数据结构：as...

我想在某个 Scheduler 应用操作符：subscribeOn

我想要 Observable 发生某个事件时, 采取某个行动：do

我想要 Observable 发出一个 error 事件：error

我想要 Observable 发生错误时，优雅的恢复

我创建一个 Disposable 资源，使它与 Observable 具有相同的寿命：using

我创建一个 Observable，直到我通知它可以产生元素后，才能产生元素：publish

笨鸟先飞，执行合一。基本了解RxSwift后，就应该动手写一些BUG了。