amb
多个Observables中,取第一个发出元素的Observable
buffer
缓存元素
当元素达到某个数量,然后将元素集合发送出来
catchError
拦截一个error事件,将他替换成其他的元素或一组元素,使得正常结束
catchErrorJustReturn
将error事件替换成其他的一个元素,然后结束该序列
combineLatest
将多个Observables中最新的元素通过一个函数组合起来,然后将这个组合的结果发出来
concat
将多个Observables按顺序串联起来,当前一个Observable元素发送完毕后,后一个Observable才可以开始发出元素
concatMap
转换成 Observables。然后让这些 Observables 按顺序的发出元素,当前一个 Observable 元素发送完毕后,后一个 Observable 才可以开始发出元素。等待前一个 Observable 产生完成事件后,才对后一个 Observable 进行订阅
connect
通知可被连接的Observable可以开始发出元素了
create
通过一个构建函数完整的创建一个Observable
debounce
过滤掉高频产生的元素
debug
打印所有的订阅,事件以及销毁信息
defer
直到订阅发生采取创建Observable,并且为每个订阅者创建全新的Observable
delay
将Observable的每个元素拖延一段时间后发出
delaySubscription
进行拖时订阅
dematerialize
将materialize转换后的元素还原
distinctUntilChanged
阻止Observable发出相同的元素
do
操作符来注册一些回调操作,这些回调会被单独调用,它们会和Observable原本的回调分离
elementAt
只发出Observable中的第n个元素
empty
创建一个空Observable,只有完成事件
error
创建一个只有error事件的Observable
filter
提供判定方法过滤一个Observable
flatMap
当Observable的元素本生拥有其他的Observable时,你可以将所有子Observables的元素发送出来
flatMapLatest
将Observable的元素转换成其他的Observable,然后取这些Observables中最新的一个
from
将其他类型或者数据结构转换成Observable
groupBy
将源Observable分解为多个子Observable,并且每个子Observable将相似的元素发送出来
网友评论