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
- 只取头几个元素
- 只取头几个满足判定的元素: 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