RxJS 是一个流行的 JavaScript 库，它提供了一种现代化的、响应式的编程范式，使前端开发人员可以更轻松地处理异步数据流。在 RxJS 中，Observable 是一个核心概念，它代表着一个多个值的集合，可以被订阅，以便在值发生变化时执行一些操作。
在本文中，我们将深入探讨 RxJS 中的创建操作符，这些操作符可以用于创建 Observable，以及如何应用它们来实现真实世界的应用程序开发。
创建 Observable 的操作符
在 RxJS 中，有许多不同的创建操作符可用于创建 Observable，这些操作符可在多个上下文中使用，例如：
- 从事件、Promise 和数组中创建 Observable
- 从定时器和周期性信号中创建 Observable
- 手动创建 Observable，并向其手动添加新的值
接下来，让我们深入了解一些最常见的创建操作符。
of
of 操作符可以用于创建一个 Observable，其中包含一组静态值。在下面的示例中，我们使用 of 操作符来创建一个 Observable，其中包含三个字符串值：
import { of } from 'rxjs';
const myObservable = of('apple', 'banana', 'cherry');
myObservable.subscribe(value => console.log(value));
// 输出：apple
// 输出：banana
// 输出：cherryfrom
from 操作符可以用于从一个可迭代的对象中创建 Observable。在下面的示例中，我们使用 from 操作符将一个数组中的值转换为一个 Observable：
-- -------------------- ---- ------- ------ - ---- - ---- ------- ----- ------- - --- -- -- -- --- ----- ------------ - -------------- ---------------------------- -- -------------------- -- ---- -- ---- -- ---- -- ---- -- ----
interval
interval 操作符可以用于创建一个 Observable，它会在指定的时间间隔后发出一个自增序列。在下面的示例中，我们使用 interval 操作符创建一个每秒钟发出一个递增的数字的 Observable：
-- -------------------- ---- ------- ------ - -------- - ---- ------- ----- ------------ - --------------- ---------------------------- -- -------------------- -- ---- -- ---- -- ---- -- ---- -- -------------
fromEvent
fromEvent 操作符可以用于从 DOM 事件中创建 Observable。在下面的示例中，我们使用 fromEvent 操作符创建一个 Observable，以便在按钮单击时发出一个事件：
import { fromEvent } from 'rxjs';
const myButton = document.querySelector('button');
const myObservable = fromEvent(myButton, 'click');
myObservable.subscribe(() => console.log('button clicked'));
// 当按钮被单击时，输出：button clickedfromPromise
fromPromise 操作符可以用于从 Promise 中创建 Observable。在下面的示例中，我们使用 fromPromise 操作符创建一个 Observable，以便在 Promise 解决时发出一个结果：
-- -------------------- ---- -------
------ - ----------- - ---- -------
----- --------- - --- --------------- -- -
------------- -- -
---------- -- -----------
-- ------
---
----- ------------ - -----------------------
---------------------------- -- --------------------
-- - ------- ------- -- --------应用
RxJS 的创建操作符可以应用于许多不同的场景，这里只是介绍其中一些用例。
数据轮询
利用 interval 和 switchMap 操作符，我们可以轮询 API，以获取最新的数据。在下面的示例中，我们在每 5 秒钟轮询一次 API：
-- -------------------- ---- -------
------ - -------- - ---- -------
------ - --------- - ---- -----------------
----- ------------- - --------------------
------------ -- -
------ -------------------------------------
-------------- -- -----------------
--
--
---------------------------- -- -------------------防抖动
通常情况下，当用户在输入框中输入时，您不希望立即开始搜索。相反，您希望等待用户完成输入，然后再开始搜索。有了 debounceTime 操作符，您可以等待一段时间，然后再执行某些操作。在下面的示例中，我们在等待 250 毫秒之后执行一个操作：
-- -------------------- ---- ------- ------ - --------- - ---- ------- ------ - ------------ - ---- ----------------- ----- --------- - -------------------------------------- ----- ------------- - -------------------- -------------- ----------------- -- -------------------------- -- - ------------------ ----- ------------ -- ---- ---
自动完成
在自动完成中，用户可能会频繁进行输入。为了避免向服务器发起过多的请求，您可以使用 switchMap 操作符在仅发出最新值时执行请求。在下面的示例中，我们在用户按下按键时，使用 switchMap 获取搜索建议：
-- -------------------- ---- -------
------ - --------- - ---- -------
------ - --------- - ---- -----------------
----- --------- - --------------------------------------
----- ------------- - -------------------- --------------
----------- -------------- -- ------------- -- -------------------------
------------------
-------------------- -- -
------ ------------------------------------------------------------
-------------- -- -----------------
--
--
---------------------------- -- -------------------结论
RxJS 的创建操作符是创建 Observable 的重要工具，可以在各种复杂的应用程序场景中发挥作用。了解这些操作符的功能和使用方法，是成为一名优秀的前端开发人员的关键组成部分。我们鼓励您尝试编写一些使用这些操作符的代码，并在实际项目中应用这些技术。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/670b6caad91dce0dc88a6a0f