RxSwift操作符分类
一、我想要创建一个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<Element>：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
- 跳过头 n 个元素：
- 只取头几个元素
- 只取头几个满足判定的元素：
takeWhile，takeWhileWithIndex - 只取某段时间内产生的头几个元素：
take - 只取头几个元素直到另一个
Observable发出一个元素：takeUntil
- 只取头几个满足判定的元素：
- 周期性的对
Observable抽样：sample - 发出那些元素，这些元素产生后的特定的时间内，没有新的元素产生：
debounce - 直到元素的值发生变化，才发出新的元素：
distinctUntilChanged- 并提供元素是否相等的判定函数：
distinctUntilChanged
- 并提供元素是否相等的判定函数：
- 在开始发出元素时，延时后进行订阅：
delaySubscription
十二、我想要从一些Observables中，只取第一个产生元素的 Observable：amb
十三、我想评估Observable的全部元素
- 并且对每个元素应用聚合方法，待所有元素都应用聚合方法后，发出结果：reduce
- 并且对每个元素应用聚合方法，每次应用聚合方法后，发出结果：scan
十四、我想把 Observable 转换为其他的数据结构：as...
- asObservable()
- asDriver()
- ...
十五、我想在某个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
本篇来源：RxSwift中文文档
