简介

ReactiveX 的每个语言特定实现都实现了一组运算符。尽管实现之间存在很多重叠，但也有一些运算符只在某些实现中实现。此外，每个实现都倾向于将其运算符命名为类似于在该语言的其他上下文中已经熟悉的类似方法。

链式运算符

大多数运算符对 Observable 进行操作并返回 Observable。这使您可以将这些运算符一个接一个地应用，形成一个链。链中的每个运算符都会修改前一个运算符操作产生的 Observable。

还存在其他模式，例如 Builder 模式，其中特定类的各种方法对该类的同一个项目进行操作，通过方法的操作修改该对象。这些模式也允许您以类似的方式对方法进行链式操作。但是，虽然在 Builder 模式中，方法在链中出现的顺序通常无关紧要，但对于 Observable 运算符来说，顺序很重要。

Observable 运算符链不会独立地对产生链的原始 Observable 进行操作，而是依次进行操作，每个运算符都会对链中紧邻其前面的运算符生成的 Observable 进行操作。

ReactiveX 的运算符

此页面首先列出了 ReactiveX 中可能被认为是“核心”的运算符，并链接到提供有关这些运算符工作原理以及特定语言特定 ReactiveX 版本如何实现这些运算符的更深入信息的页面。

接下来是一个“决策树”，它可以帮助您选择最适合您的用例的运算符。

最后，是 ReactiveX 的许多语言特定实现中提供的大多数运算符的字母顺序列表。这些链接到记录最接近语言特定运算符的核心运算符的页面（例如，Rx.NET 的“SelectMany”运算符链接到 FlatMap ReactiveX 运算符的文档，“SelectMany”是 Rx.NET 的实现）。

如果要实现自己的运算符，请参阅实现自己的运算符.

按类别分类的运算符

创建 Observable

生成新的 Observable 的运算符。

Create — 通过以编程方式调用观察者方法从头开始创建 Observable
Defer — 直到观察者订阅时才创建 Observable，并且为每个观察者创建一个新的 Observable
Empty/Never/Throw — 创建具有非常精确和有限行为的 Observable
From — 将其他对象或数据结构转换为 Observable
Interval — 创建一个 Observable，它按特定时间间隔发出一系列整数
Just — 将对象或一组对象转换为发出该对象或这些对象的 Observable
Range — 创建发出连续整数范围的 Observable
Repeat — 创建一个 Observable，它重复发出特定项目或一系列项目
Start — 创建一个 Observable，它发出函数的返回值
Timer — 创建一个 Observable，它在给定延迟后发出单个项目

转换 Observable

转换由 Observable 发出的项目的运算符。

Buffer — 定期将 Observable 中的项目收集到捆绑包中，并发出这些捆绑包，而不是一次发出一个项目
FlatMap — 将由 Observable 发出的项目转换为 Observable，然后将这些 Observable 的发出项展平成单个 Observable
GroupBy — 将 Observable 分成一组 Observable，每个 Observable 都发出原始 Observable 中的不同组项目，这些项目按键进行组织
Map — 通过对每个项目应用函数来转换由 Observable 发出的项目
Scan — 对由 Observable 发出的每个项目依次应用函数，并发出每个后续值
Window — 定期将 Observable 中的项目细分为 Observable 窗口，并发出这些窗口，而不是一次发出一个项目

过滤 Observable

选择性地从源 Observable 发出项目的运算符。

Debounce — 仅当经过特定时间段后 Observable 没有发出其他项目时，才从 Observable 发出项目
Distinct — 抑制由 Observable 发出的重复项目
ElementAt — 仅发出由 Observable 发出的第 n 个项目
Filter — 仅发出通过谓词测试的 Observable 中的项目
First — 仅发出第一个项目，或第一个满足条件的项目，从 Observable 中发出
IgnoreElements — 不从 Observable 发出任何项目，但镜像其终止通知
Last — 仅发出由 Observable 发出的最后一个项目
Sample — 每隔特定时间间隔发出 Observable 发出的最新项目
Skip — 抑制由 Observable 发出的前 n 个项目
SkipLast — 抑制由 Observable 发出的最后 n 个项目
Take — 仅发出由 Observable 发出的前 n 个项目
TakeLast — 仅发出由 Observable 发出的最后 n 个项目

组合 Observable

使用多个源 Observable 来创建单个 Observable 的运算符

And/Then/When — 通过 Pattern 和 Plan 中介，组合两个或多个 Observable 发出的项目集
CombineLatest — 当两个 Observable 中的任何一个发出项目时，通过指定函数组合每个 Observable 发出的最新项目，并根据该函数的结果发出项目
Join — 每当一个 Observable 在根据另一个 Observable 发出的项目定义的时间窗口内发出项目时，组合两个 Observable 发出的项目
Merge — 通过合并多个 Observable 的发出项将多个 Observable 组合成一个
StartWith — 在开始发出源 Observable 中的项目之前，发出指定的项目序列
Switch — 将发出 Observable 的 Observable 转换为单个 Observable，该 Observable 发出最近发出的那些 Observable 发出的项目
Zip — 通过指定函数将多个 Observable 的发出项组合在一起，并根据该函数的结果为每个组合发出单个项目