随着 Web 应用程序的复杂性和需求的增加，异步请求和加载状态成为了前端开发中的核心问题。对于一些需要复杂计算和对远程服务的依赖性的任务，异步请求和加载状态是最常见的任务之一。RxJS 给了我们处理这些复杂任务的强大工具，我们可以使用它来处理异步请求和加载状态。
在这篇文章中，我们将讨论如何使用 RxJS 实现带有 loading 状态的异步请求，这可以使我们更好地掌控我们的前端应用程序的状态并方便用户的使用。
RxJS 和 Observable
在介绍 RxJS 如何实现加载状态前，我们需要先简要介绍 RxJS 和 Observable。RxJS 是 Reactive Extensions 的 JS 版本，可以帮助我们处理异步、流（stream）和事件，使我们的前端代码变得更加简单、整洁。Observable 是 RxJS 中一个重要的类，它代表一个异步的、可观测序列，我们可以使用许多 RxJS 的操作符来对其进行转换和处理。
带有 loading 状态的异步请求
在我们的前端应用程序中，异步请求的状态通常是四种：未加载、正在加载、加载完成和加载失败。为了更好地跟踪异步请求的状态，我们可以使用如下面所示的代码实现。
首先，我们定义了一个组件，它有三个状态：loading$、completed$ 和 failed$，它们都是 RxJS 的 Observable 对象：
-- -------------------- ---- -------
------ - ---------- ------ - ---- ----------------
------ - ---------- - ---- -------
------ - ---------- --- - ---- -----------------
------ - ----------- - ---- -----------------
------------
--------- -----------
--------- -
---- ---------------- - --------
----------
------
---- --------------- - --------
------ -- ---- -----
------
---- ------------------ - --------
----
--- ----------- ---- -- ---------- - -------
-- --------- --
-----
-----
------
--
--
------ ----- ------------ ---------- ------ -
---------- --------------------
------------ ------------------
--------- --------------------
------------------- -------- ------------ --
---------- -
------------- - ----------------------
--------------- - ------------------------
------------ - ---------------------
--------------------
-
-参考代码中的 DataService 类通过向后端发送 HTTP 请求并将结果发送到 Observable 对象来负责异步请求：
-- -------------------- ---- -------
------ - ---------- - ---- ----------------
------ - ---------- - ---- -----------------------
------ - ----------- --- ---------- - ---- -------
------ - ----------- ---------- --- - ---- -----------------
------------- ----------- ------ --
------ ----- ----------- -
----- ----- - ---
--------- --------------------
----------- ------------------
-------- --------------------
------- -------------- - --- -----------------------
------- ---------------- - --- ---------------------------
------- ------------- - --- -----------------------
------------------- ----- ----------- -
------------- - -----------------------------------
--------------- - -------------------------------------
------------ - ----------------------------------
-
------ -
----- --- - ---------------------------------------------
-------------------------------
-------------------------------
-------------------------------
-------- -- -
---------------------------------
-------------------------------
--------------------------------
---
------------- -- -
------------------------------
--------------------------------
------ -------
--
--------------
-
-在 load() 方法中，我们首先设置了 loadingSubject 的初始值为 true，同时将 failedSubject 的初始值设置为 false。然后，我们使用 HttpClient 发送 HTTP 请求，将数据发送给 completedSubject。在出现错误的情况下，我们将 failedSubject 的值设置为 true，并将 loadingSubject 的值设置为 false，以确保我们的应用程序可以更好地处理错误情况。
结论
在这篇文章中，我们介绍了如何使用 RxJS 实现带有 loading 状态的异步请求。通过跟踪异步请求的状态，我们可以使我们的前端代码变得更加简单、整洁，同时可以有效地避免出现错误。希望这篇文章能够有帮助。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/671e41d82e7021665ef71eac
