簡介

ReactiveX 的每個特定語言實作都實作了一組運算子。雖然實作之間有很多重疊之處，但也有些運算子僅在某些實作中實作。此外，每個實作都傾向於將其運算子命名為類似於該語言中其他上下文中已熟悉的類似方法。

串聯運算子

大多數運算子都對 Observable 進行操作並返回一個 Observable。這允許你一個接一個地以鏈的形式應用這些運算子。鏈中的每個運算子都會修改前一個運算子操作產生的 Observable。

還有其他模式，例如 Builder 模式，其中特定類別的各種方法透過方法的操作修改該物件，對該類別的項目進行操作。這些模式也允許你以類似的方式鏈接方法。但是，雖然在 Builder 模式中，方法在鏈中出現的順序通常並不重要，但在 Observable 運算子中，順序很重要。

Observable 運算子鏈不會獨立地對源自該鏈的原始 Observable 進行操作，而是依次操作，每個運算子都對鏈中緊接在前一個運算子生成的 Observable 進行操作。

ReactiveX 的運算子

此頁面首先列出 ReactiveX 中可被視為「核心」運算子的內容，並連結到具有更深入資訊的頁面，說明這些運算子如何運作以及特定語言的 ReactiveX 版本如何實作這些運算子。

接下來是一個「決策樹」，可協助你選擇最適合你的使用案例的運算子。

最後，有一個字母順序的列表，列出 ReactiveX 的許多特定語言實作中可用的大多數運算子。這些連結到記錄最接近特定語言運算子的核心運算子的頁面（因此，例如，Rx.NET 的「SelectMany」運算子連結到 FlatMap ReactiveX 運算子的文件，其中「SelectMany」是 Rx.NET 的實作）。

如果你想實作自己的運算子，請參閱實作你自己的運算子。

依類別分類的運算子

建立 Observables

產生新 Observables 的運算子。

Create — 透過程式設計呼叫觀察者方法，從頭開始建立 Observable
Defer — 在觀察者訂閱之前不要建立 Observable，並為每個觀察者建立一個新的 Observable
Empty/Never/Throw — 建立具有非常精確和有限行為的 Observables
From — 將其他物件或資料結構轉換為 Observable
Interval — 建立一個 Observable，該 Observable 發出以特定時間間隔間隔的整數序列
Just — 將一個物件或一組物件轉換為發出該物件或那些物件的 Observable
Range — 建立一個 Observable，該 Observable 發出一個連續的整數範圍
Repeat — 建立一個 Observable，該 Observable 重複發出特定項目或項目序列
Start — 建立一個 Observable，該 Observable 發出函數的傳回值
Timer — 建立一個 Observable，該 Observable 在給定的延遲後發出單個項目

轉換 Observables

轉換 Observable 發出的項目的運算子。

Buffer — 定期從 Observable 收集項目到捆綁包中，並發出這些捆綁包，而不是一次發出一個項目
FlatMap — 將 Observable 發出的項目轉換為 Observables，然後將這些項目的發射展平為單個 Observable
GroupBy — 將 Observable 分成一組 Observables，每個 Observable 發出原始 Observable 的不同項目組，按鍵組織
Map — 透過對每個項目應用函數來轉換 Observable 發出的項目
Scan — 依序將函數應用於 Observable 發出的每個項目，並發出每個後續值
Window — 定期將 Observable 的項目細分為 Observable 視窗，並發出這些視窗，而不是一次發出一個項目

篩選 Observables

有選擇地從來源 Observable 發出項目的運算子。

Debounce — 僅當特定時間範圍過去而沒有發出另一個項目時，才從 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 個項目

合併 Observables

使用多個來源 Observables 來建立單個 Observable 的運算子

And/Then/When — 透過 Pattern 和 Plan 中介合併由兩個或多個 Observables 發出的一組項目
CombineLatest — 當兩個 Observables 中的任何一個發出一個項目時，透過指定的函數合併每個 Observable 發出的最新項目，並根據此函數的結果發出項目
Join — 當一個 Observable 的項目在根據另一個 Observable 發出的項目定義的時間視窗內發出時，合併兩個 Observables 發出的項目
Merge — 透過合併其發射，將多個 Observables 合併為一個
StartWith — 在開始發出來源 Observable 的項目之前，發出指定的項目序列
Switch — 將發出 Observables 的 Observable 轉換為單個 Observable，該 Observable 發出最近發出的那些 Observables 發出的項目
Zip — 透過指定的函數合併多個 Observables 的發射，並根據此函數的結果為每個組合發出單個項目