Please enable JavaScript.
Coggle requires JavaScript to display documents.
RxJs (操作符 (转换 (groupBy (基于提供的值分组成多个 observables), map (对源 observable…
RxJs
操作符
转换
groupBy
基于提供的值分组成多个 observables
map
对源 observable 的每个值应用投射函数
exhaustMap
映射成内部 observable,忽略其他值直到该 observable 完成
mapTo
将每个发出值映射成常量
expand
递归调用提供的函数
mergeMap
映射成 observable 并发出值
concatMapTo
当前一个 observable 完成时订阅提供的 observable 并发出值
partition
根据提供的方法将 observable 分割为两个
concatMap
将值映射成内部 observable,并按顺序订阅和发出
pluck
选择对象的属性来发出
bufferWhen
收集值,直到关闭选择器发出值才发出缓冲的值
scan
随着时间的推移进行归并
bufferToggle
开启开关以捕获源 observable 所发出的值,关闭开关以将缓冲的值作为数组发出
switchMap
映射成 observable,完成前一个内部 observable,发出值
bufferTime
收集发出的值,直到经过了提供的时间才将其作为数组发出
window
时间窗口值的 observable
bufferCount
收集发出的值,直到收集完提供的数量的值才将其作为数组发出
windowCount
源 observable 中的值的 observable,每次发出N个值(N由参数决定)
buffer
收集输出值,直到提供的 observable 发出才将收集到的值作为数组发出
windowTime
在每个提供的时间跨度内,收集源 obsercvable 中的值的 observable
windowToggle
以 openings 发出为起始,以 closingSelector 发出为结束,收集并发出源 observable 中的值的 observable
windowWhen
在提供的时间帧处关闭窗口,并发出从源 observable 中收集的值的 observable
过滤
distinctUntilChanged
只有当当前值与之前最后一个值不同时才将其发出
filter
发出符合给定条件的值
debounceTime
舍弃掉在两次输出之间小于指定时间的发出值
first
发出第一个值或第一个通过给定表达式的值
debounce
根据一个选择器函数,舍弃掉在两次输出之间小于指定时间的发出值
ignoreElements
忽略所有通知,除了 complete 和 error
last
根据提供的表达式,在源 observable 完成时发出它的最后一个值
sample
当提供的 observable 发出时从源 observable 中取样
single
发出通过表达式的单一项
skip
跳过N个(由参数提供)发出值
skipUntil
跳过源 observable 发出的值,直到提供的 observable 发出值
skipWhile
跳过源 observable 发出的值,直到提供的表达式结果为 false
take
在完成前发出N个值(N由参数决定
takeUntil
发出值,直到提供的 observable 发出值,它便完成
takeWhile
发出值,直到提供的表达式结果为 false
throttle
仅当由提供的函数所确定的持续时间已经过去时才发出值
throttleTime
当指定的持续时间经过后发出最新值
sampleTime
在x毫秒内的忽略发出的值
创建
create
使用给定的订阅函数来创建 observable
timer
给定持续时间后,再按照指定间隔时间依次发出数字
throw
在订阅上发出错误
range
依次发出给定区间内的数字
empty
立即完成的 observable
from
将数组、promise 或迭代器转换成 observable
fromEvent
将事件转换成 observable 序列
fromPromise
创建由 promise 转换而来的 observable,并发出 promise 的结果
of
按顺序发出任意数量的值
interval
基于给定时间间隔发出数字序列
ajax
发起 ajax 请求
defer
以惰性的方式产生一个Observable,也就是说,当被订阅的时候才会产生
组合
merge
将多个 observables 转换成单个 observable
mergeAll
收集并订阅所有的 observables
forkJoin
当所有 observables 完成时发出每个 observable 的最新值
race
使用首先发出值的 observable
concatAll
收集 observables,当前一个完成时订阅下一个
startWith
发出给定的第一个值
concat
按照顺序,前一个 observable 完成了再订阅下一个 observable 并发出值
withLatestFrom
还提供另一个 observable 的最新值
combineLatest
当任意 observable 发出值时,发出每个 observable 的最新值
zip
在所有 observables 发出后,将它们的值作为数组发出
combineAll
当源 observable 完成时,对收集的 observables 使用 combineLatest
pairwise
将前一个值和当前值作为数组发出
工具
dematerialize
将 notification 对象转换成 notification 值
delayWhen
延迟发出值,延迟时间由提供函数决定
let
拥有完整的 observable
delay
根据给定时间延迟发出值
toPromise
将 observable 转换成 promise
do
透明地执行操作或副作用,比如打印日志
错误处理
retry
如果发生错误,以指定次数重试 observable 序列
catch
优雅地处理 observable 序列中的错误
retryWhen
当发生错误时,基于自定义的标准来重试 observable 序列
多播
publish
共享源 observable 并通过调用 connect 方法使其变成热的
multicast
使用提供 的 Subject 来共享源 observable
share
在多个订阅者间共享源 observable
条件
defaultIfEmpty
如果在完成前没有发出任何通知,那么发出给定的值
every
如果完成时所有的值都能通过断言,那么发出 true,否则发出 false
数学
min
发出最小值
max
发出最大值
Subject
操作
complete()
subscribe()
error([error message])
unsubscribe()
next([value])
ReplaySubject
缓存最新的 n 个值
AsyncSubject
只发出关闭流前的最后状态
BehaviourSubject
发出最初的值