5. 如何选择操作符?
Last updated
Was this helpful?
Last updated
Was this helpful?
产生特定的一个元素:
经过一段延时:
从一个序列拉取元素:
重复的产生某一个元素:
存在自定义逻辑:
每次订阅时产生:
每隔一段时间,发出一个元素:
在一段延时后:
一个空序列,只有一个完成事件:
一个任何事件都没有产生的序列:
任意一个 Observable
产生了元素,就发出这个元素:
让这些 Observables
一个接一个的发出元素,当上一个 Observable
元素发送完毕后,下一个 Observable
才能开始发出元素:
当每一个 Observable
都发出一个新的元素:
当任意一个 Observable
发出一个新的元素:
对每个元素直接转换:
转换到另一个 Observable
:
只接收最新的元素转换的 Observable
所产生的元素:
每一个元素转换的 Observable
按顺序产生元素:
基于所有遍历过的元素:
我想要将产生的每一个元素,拖延一段时间后再发出:
将他们封装成 Event<Element>
:
然后解封出来:
我想要忽略掉所有的 next
事件,只接收 completed
和 error
事件:
我想创建一个新的 Observable
在原有的序列前面加入一些元素:
我想从 Observable
中收集元素,缓存这些元素之后在发出:
我想将 Observable
拆分成多个 Observables
:
基于元素的共同特征:
发出唯一的元素:
通过判定条件过滤出一些元素:
仅仅发出头几个元素:
仅仅发出尾部的几个元素:
仅仅发出第 n 个元素:
跳过头 n 个元素:
跳过头几个满足判定的元素:,
跳过某段时间内产生的头几个元素:
跳过头几个元素直到另一个 Observable
发出一个元素:
只取头几个满足判定的元素:,
只取某段时间内产生的头几个元素:
只取头几个元素直到另一个 Observable
发出一个元素:
周期性的对 Observable
抽样:
发出那些元素,这些元素产生后的特定的时间内,没有新的元素产生:
直到元素的值发生变化,才发出新的元素:
并提供元素是否相等的判定函数:
在开始发出元素时,延时后进行订阅:
我想要从一些 Observables
中,只取第一个产生元素的 Observable
:
并且对每个元素应用聚合方法,待所有元素都应用聚合方法后,发出结果:
并且对每个元素应用聚合方法,每次应用聚合方法后,发出结果:
我想在某个 应用操作符:
在某个 监听:
我想要 Observable
发生某个事件时, 采取某个行动:
我想要 Observable
发出一个 error
事件:
如果规定时间内没有产生元素:
如果规定时间内没有产生元素,就切换到备选 Observable
:
如果产生错误,将错误替换成某个元素 :
如果产生错误,就切换到备选 Observable
:
如果产生错误,就重试 :
我创建一个 Disposable
资源,使它与 Observable
具有相同的寿命:
我创建一个 Observable
,直到我通知它可以产生元素后,才能产生元素:
并且,就算是在产生元素后订阅,也要发出全部元素:
并且,一旦所有观察者取消观察,他就被释放掉:
通知它可以产生元素了: