RxJS 是一个强大的响应式编程库，其提供了丰富的操作符来方便我们对数据流进行操作。而其中的一个操作符 switchMap，可以用来解决一些异步请求嵌套的问题。本文将详细介绍 switchMap 的实现原理，并手写一个 switchMap 的实现来加深理解。
switchMap 操作符简介
switchMap 是一个将源 Observable 转换为新 Observable 的操作符。它将源 Observable 的每个值映射为一个新的 Observable，并返回这个新 Observable，然后将这个 Observable 的值合并为一个单独的 Observable 流，覆盖任何先前的 Observable 流。
举个例子，假设我们需要从一个服务器上获取两个不同的数据，第二个请求需要用到第一个请求的结果来构造请求 URL。使用 switchMap 操作符可以让我们方便地处理这种情况。
-- -------------------- ---- -------
------ - ---- - ---- -------
------ - --------- - ---- -----------------
----- --------- - -------------------------
-------------------- - ---------
------
--------------------- --
----------------------------
----------------- -- -
----- --- - --------- - -------- - ---------
------ -----------------
--
-
-
-
------------------------这里的 switchMap 实现了一个嵌套的异步请求，第二个请求直接使用了第一个请求的结果来构造 URL。
手写 switchMap
现在，我们将手写一个 switchMap 操作符来加深我们的理解。我们的 switchMap 将接收一个返回 Observable 的函数，将这个函数应用于每个源 Observable 发出的值，并将新 Observable 所发出的值合并到一个单独的 Observable 流中。
我们的 switchMap 函数将需要一些输入参数：
project：返回一个 Observable 的函数。concurrent：定义最多可以同时激活多少个内部 Observable。source：源 Observable，我们需要将其转换为新的 Observable。
-- -------------------- ---- -------
------ - ---------- - ---- -------
-------- ------------------ ---------- - -- -
------ -------- -------- -
------ ---------------------------- -- -
----- ----------------- - ---
--- ------- - --
----- -------------- - -- -- -
-- ------------------------- --- -- -
--------------------
-
--
----- ------------------------ - --------------- -- -
-- -------- -- ----------- -
-------
-
----------
----- ------------ - -------------------------
----- ------- -- ---------------------
------ ------- -- ----------------------
--------- -- -- -
----- ----- - ----------------------------------------
------------------------------- ---
----------
-----------------
--
---
-------------------------------------
--
----- ------------------ - ------------------
----- ------- -- -
----- ------------- - ---------------
----------------------------------------
--
------ ------- -- ----------------------
--------- -- -- -
-----------------
--
---
------ -- -- -
---------------------------------
---------------------------------------- -- ----------------------------
--
---
--
-我们的函数将创建一个新的 Observable，并使用传递给它的源 Observable 订阅，以便在接收源值时调用 project 方法。
在我们的 subscribeToNewObservable 函数中，我们将每个新 Observable 的订阅提取出来，然后将其添加到 activeObservables 中。如果超过 concurrent 个 Observables 被添加到 activeObservables 中，则会忽略后来的 Observable。
每当一个内部 Observable 完成时，我们将其从 activeObservables 中移除，此外我们需要将 activeCount 中减1，当没有活动的 Observables 剩余了，则说明整个操作已经完成了。
总结
本文介绍了 RxJS 中 switchMap 操作符的作用及其实现原理。同时我们还手写了一个 switchMap，用以更加深入地理解其实现原理。
RxJS 提供了一系列强大的操作符来使我们更加便捷地处理数据流，switchMap 是其中之一。在实践中，我们需要合理地使用这些操作符，以提高代码质量和效率。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/651faa6895b1f8cacd730fbc