Rxjs 操作符

RxJS 的操作符种类繁多，分类清晰，学习起来可以从 功能类别 入手。以下是对所有操作符的详细分类和简单说明：

1. 创建类操作符

用于创建 Observable。

操作符 描述
of 从一组值创建一个同步发射的 Observable。
from 将数组、Promise、迭代器或 Observable-like 对象转换为 Observable。
fromEvent 从事件创建 Observable，比如 DOM 事件。
interval 按固定时间间隔发出数字序列（无限 Observable）。
timer 在一段时间后触发（一次或间隔性）发出值。
range 发出一段连续的数字序列（如从 1 到 5）。
empty 创建一个立即完成的 Observable。
never 创建永不发出任何值的 Observable。
throwError 创建立即抛出错误的 Observable。
defer 延迟创建 Observable，直到有订阅时才实际执行。
generate 使用初始值、条件和更新逻辑生成 Observable。

2. 转换类操作符

用于转换数据。

操作符 描述
map 对发出的每个值应用函数并返回新值。
mapTo 将所有值映射为指定的常量值。
switchMap 映射为新的 Observable，取消之前的订阅，仅订阅最新的 Observable。
mergeMap 映射为新的 Observable，并发处理所有内部 Observable。
concatMap 映射为新的 Observable，顺序订阅内部 Observable。
exhaustMap 映射为新的 Observable，忽略新值直到当前内部 Observable 完成。
scan 类似于 reduce，但会持续发出中间累积值。
buffer 收集发出的值，直到另一个 Observable 发出值时，将其作为数组发出。
bufferCount 每当收集到指定数量的值时，将其作为数组发出。
bufferTime 收集值并在固定时间间隔后发出数组。
bufferToggle 开关式收集缓冲区，使用一个开/关控制 Observable。
toArray 将所有值收集到数组后发出。

3. 过滤类操作符

用于筛选和限制数据流。

操作符 描述
filter 根据条件过滤值，只发出满足条件的值。
take 仅发出前 N 个值。
takeLast 仅发出 Observable 完成前的最后 N 个值。
takeUntil 发出值直到另一个 Observable 发出值。
skip 跳过前 N 个值。
skipLast 跳过 Observable 完成前的最后 N 个值。
distinct 过滤掉重复值（基于默认或指定的比较器）。
distinctUntilChanged 仅发出相邻的不同值。
debounceTime 忽略快速发出的值，仅在指定时间内未发出新值时才发出值。
throttleTime 限制发出值的频率，每隔指定时间发出一次。
auditTime 忽略一段时间内的值，仅发出最后一个值。

4. 合并类操作符

用于组合多个 Observable。

操作符 描述
merge 并行合并多个 Observable，按发出值的时间顺序合并发出值。
concat 串行连接多个 Observable，等待前一个完成再订阅下一个。
combineLatest 当任何一个 Observable 发出新值时，将所有 Observable 的最新值作为数组发出。
zip 将多个 Observable 的值按索引一一配对并发出（数组形式）。
forkJoin 等待所有 Observable 完成并发出每个 Observable 的最终值（数组形式）。
startWith 在源 Observable 之前插入一个值。
withLatestFrom 在源 Observable 发出值时，结合另一个 Observable 的最新值。

5. 错误处理类操作符

用于处理错误。

操作符 描述
catchError 捕获错误并返回新的 Observable。
retry 在错误时重新订阅源 Observable（指定次数）。
retryWhen 在错误时重新订阅，但可以通过自定义逻辑控制何时重试。
onErrorResumeNext 在错误时继续下一个 Observable。

6. 多播类操作符

用于共享和复用 Observable。

操作符 描述
share 使 Observable 变为共享（热 Observable），多个订阅共享同一数据流。
publish 将 Observable 转为 ConnectableObservable，需手动调用 connect()。
shareReplay 类似于 share，但会缓存最近发出的值以供新订阅者接收。
refCount 自动管理 ConnectableObservable 的连接和断开。

7. 工具类操作符

辅助调试和控制流。

操作符 描述
tap 允许在流中插入副作用操作（如日志、调试）。
delay 延迟发出值。
timeout 如果在指定时间内未发出值，则抛出错误。
finalize 在 Observable 完成或出错时执行清理操作。
repeat 重复订阅 Observable（指定次数或无限次）。

这些操作符是 RxJS 的基础，但并不需要一次性掌握所有，实际开发中可根据需求逐步学习和应用。