# 5. 如何选择操作符？

![](https://4217506537-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MWj545abP2yK86-qksJ%2Fsync%2F70f42c76f0140dc3c2613fef2d3f8040d1541b6d.png?generation=1616819385313020\&alt=media)

下面这个**决策树**可以帮助你找到需要的操作符。

## 决策树

**我想要创建一个 `Observable`**

* 产生特定的一个元素：[just](https://3440217568.gitbook.io/rxswift/decision_tree/just)
  * 经过一段延时：[timer](https://3440217568.gitbook.io/rxswift/decision_tree/timer)
* 从一个序列拉取元素：[from](https://3440217568.gitbook.io/rxswift/decision_tree/from)
* 重复的产生某一个元素：[repeatElement](https://3440217568.gitbook.io/rxswift/decision_tree/repeatelement)
* 存在自定义逻辑：[create](https://3440217568.gitbook.io/rxswift/decision_tree/create)
* 每次订阅时产生：[deferred](https://3440217568.gitbook.io/rxswift/decision_tree/deferred)
* 每隔一段时间，发出一个元素：[interval](https://3440217568.gitbook.io/rxswift/decision_tree/interval)
  * 在一段延时后：[timer](https://3440217568.gitbook.io/rxswift/decision_tree/timer)
* 一个空序列，只有一个完成事件：[empty](https://3440217568.gitbook.io/rxswift/decision_tree/empty)
* 一个任何事件都没有产生的序列：[never](https://3440217568.gitbook.io/rxswift/decision_tree/never)

**我想要创建一个 `Observable` 通过组合其他的 `Observables`**

* 任意一个 `Observable` 产生了元素，就发出这个元素：[merge](https://3440217568.gitbook.io/rxswift/decision_tree/merge)
* 让这些 `Observables` 一个接一个的发出元素，当上一个 `Observable` 元素发送完毕后，下一个  `Observable` 才能开始发出元素：[concat](https://3440217568.gitbook.io/rxswift/decision_tree/concat)
* 组合多个 `Observables` 的元素
  * 当每一个 `Observable` 都发出一个新的元素：[zip](https://3440217568.gitbook.io/rxswift/decision_tree/zip)
  * 当任意一个 `Observable` 发出一个新的元素：[combineLatest](https://3440217568.gitbook.io/rxswift/decision_tree/combinelatest)

**我想要转换 `Observable` 的元素后，再将它们发出来**

* 对每个元素直接转换：[map](https://3440217568.gitbook.io/rxswift/decision_tree/map)
* 转换到另一个 `Observable`：[flatMap](https://3440217568.gitbook.io/rxswift/decision_tree/flatmap)
  * 只接收最新的元素转换的 `Observable` 所产生的元素：[flatMapLatest](https://3440217568.gitbook.io/rxswift/decision_tree/flatmaplatest)
  * 每一个元素转换的 `Observable` 按顺序产生元素：[concatMap](https://3440217568.gitbook.io/rxswift/decision_tree/concatmap)
* 基于所有遍历过的元素： [scan](https://3440217568.gitbook.io/rxswift/decision_tree/scan)

**我想要将产生的每一个元素，拖延一段时间后再发出：**[**delay**](https://3440217568.gitbook.io/rxswift/decision_tree/delay)

**我想要将产生的事件封装成元素发送出来**

* 将他们封装成 `Event<Element>`：[materialize](https://3440217568.gitbook.io/rxswift/decision_tree/materialize)
  * 然后解封出来：[dematerialize](https://3440217568.gitbook.io/rxswift/decision_tree/dematerialize)

**我想要忽略掉所有的 `next` 事件，只接收 `completed` 和 `error` 事件：**[**ignoreElements**](https://3440217568.gitbook.io/rxswift/decision_tree/ignoreelements)

**我想创建一个新的 `Observable` 在原有的序列前面加入一些元素：**[**startWith**](https://3440217568.gitbook.io/rxswift/decision_tree/startwith)

**我想从 `Observable` 中收集元素，缓存这些元素之后在发出：**[**buffer**](https://3440217568.gitbook.io/rxswift/decision_tree/buffer)

**我想将 `Observable` 拆分成多个 `Observables`：**[**window**](https://3440217568.gitbook.io/rxswift/decision_tree/window)

* 基于元素的共同特征：[groupBy](https://3440217568.gitbook.io/rxswift/decision_tree/groupby)

**我想只接收 `Observable` 中特定的元素**

* 发出唯一的元素：[single](https://3440217568.gitbook.io/rxswift/decision_tree/single)

**我想重新从 `Observable` 中发出某些元素**

* 通过判定条件过滤出一些元素：[filter](https://3440217568.gitbook.io/rxswift/decision_tree/filter)
* 仅仅发出头几个元素：[take](https://3440217568.gitbook.io/rxswift/decision_tree/take)
* 仅仅发出尾部的几个元素：[takeLast](https://3440217568.gitbook.io/rxswift/decision_tree/takelast)
* 仅仅发出第 n 个元素：[elementAt](https://3440217568.gitbook.io/rxswift/decision_tree/elementat)
* 跳过头几个元素 &#x20;
  * 跳过头 n 个元素：[skip](https://3440217568.gitbook.io/rxswift/decision_tree/skip)
  * 跳过头几个满足判定的元素：[skipWhile](https://3440217568.gitbook.io/rxswift/decision_tree/skipwhile)，[skipWhileWithIndex](https://3440217568.gitbook.io/rxswift/decision_tree/skipwhile)
  * 跳过某段时间内产生的头几个元素：[skip](https://3440217568.gitbook.io/rxswift/decision_tree/skip)
  * 跳过头几个元素直到另一个 `Observable` 发出一个元素：[skipUntil](https://3440217568.gitbook.io/rxswift/decision_tree/skipuntil)
* 只取头几个元素
  * 只取头几个满足判定的元素：[takeWhile](https://3440217568.gitbook.io/rxswift/decision_tree/takewhile)，[takeWhileWithIndex](https://3440217568.gitbook.io/rxswift/decision_tree/takewhile)
  * 只取某段时间内产生的头几个元素：[take](https://3440217568.gitbook.io/rxswift/decision_tree/take)
  * 只取头几个元素直到另一个 `Observable` 发出一个元素：[takeUntil](https://3440217568.gitbook.io/rxswift/decision_tree/takeuntil)
* 周期性的对 `Observable` 抽样：[sample](https://3440217568.gitbook.io/rxswift/decision_tree/sample)
* 发出那些元素，这些元素产生后的特定的时间内，没有新的元素产生：[debounce](https://3440217568.gitbook.io/rxswift/decision_tree/debounce)
* 直到元素的值发生变化，才发出新的元素：[distinctUntilChanged](https://3440217568.gitbook.io/rxswift/decision_tree/distinctuntilchanged)
  * 并提供元素是否相等的判定函数：[distinctUntilChanged](https://3440217568.gitbook.io/rxswift/decision_tree/distinctuntilchanged)
* 在开始发出元素时，延时后进行订阅：[delaySubscription](https://3440217568.gitbook.io/rxswift/decision_tree/delaysubscription)

**我想要从一些 `Observables` 中，只取第一个产生元素的 `Observable`：**[**amb**](https://3440217568.gitbook.io/rxswift/decision_tree/amb)

**我想评估 `Observable` 的全部元素**

* 并且对每个元素应用聚合方法，待所有元素都应用聚合方法后，发出结果：[reduce](https://3440217568.gitbook.io/rxswift/decision_tree/reduce)
* 并且对每个元素应用聚合方法，每次应用聚合方法后，发出结果：[scan](https://3440217568.gitbook.io/rxswift/decision_tree/scan)

**我想把 `Observable` 转换为其他的数据结构：as...**

**我想在某个** [**Scheduler**](https://3440217568.gitbook.io/rxswift/rxswift_core/schedulers) **应用操作符：**[**subscribeOn**](https://3440217568.gitbook.io/rxswift/decision_tree/subscribeon)

* 在某个 [Scheduler](https://3440217568.gitbook.io/rxswift/rxswift_core/schedulers) 监听：[observeOn](https://3440217568.gitbook.io/rxswift/decision_tree/observeon)

**我想要 `Observable` 发生某个事件时, 采取某个行动：**[**do**](https://3440217568.gitbook.io/rxswift/decision_tree/do)

**我想要 `Observable` 发出一个 `error` 事件：**[**error**](https://3440217568.gitbook.io/rxswift/decision_tree/error)

* 如果规定时间内没有产生元素：[timeout](https://3440217568.gitbook.io/rxswift/decision_tree/timeout)

**我想要 `Observable` 发生错误时，优雅的恢复**

* 如果规定时间内没有产生元素，就切换到备选 `Observable` ：[timeout](https://3440217568.gitbook.io/rxswift/decision_tree/timeout)
* 如果产生错误，将错误替换成某个元素 ：[catchErrorJustReturn](https://3440217568.gitbook.io/rxswift/decision_tree/catcherror)
* 如果产生错误，就切换到备选 `Observable` ：[catchError](https://3440217568.gitbook.io/rxswift/decision_tree/catcherror)
* 如果产生错误，就重试 ：[retry](https://3440217568.gitbook.io/rxswift/decision_tree/retry)

**我创建一个 `Disposable` 资源，使它与 `Observable` 具有相同的寿命：**[**using**](https://3440217568.gitbook.io/rxswift/decision_tree/using)

**我创建一个 `Observable`，直到我通知它可以产生元素后，才能产生元素：**[**publish**](https://3440217568.gitbook.io/rxswift/decision_tree/publish)

* 并且，就算是在产生元素后订阅，也要发出全部元素：[replay](https://3440217568.gitbook.io/rxswift/decision_tree/replay)
* 并且，一旦所有观察者取消观察，他就被释放掉：[refCount](https://3440217568.gitbook.io/rxswift/decision_tree/refcount)
* 通知它可以产生元素了：[connect](https://3440217568.gitbook.io/rxswift/decision_tree/connect)


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://3440217568.gitbook.io/rxswift/decision_tree.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.