RxJS 是一个强大的响应式编程库，它的早期版本中，操作符是以链式调用的方式实现的，例如：source.map().filter().switchMap()。这种方式虽然直观，但是当需要组合多个操作符时，代码就会变得冗长和难以维护。
RxJS 6 引入了 pipeable operators （管道操作符），它允许我们将操作符打包到独立的函数中，从而更好地组合它们。在这篇文章中，我们将探讨 pipeable operators 的新特性，包括如何使用它们以及它们可以为我们带来的好处。
如何使用 pipeable operators
在 RxJS 6 中，我们可以使用 pipe() 操作符将多个成员函数组合在一起。例如：
-- -------------------- ---- -------
------ - -- - ---- -------
------ - ---- ------- --------- - ---- -----------------
----- -- --
------
-------- -- - - - --- ---
----- -- - - ---
----------- -- ------
-
------------------------我们将 filter()、map() 和 switchMap() 操作符打包到一个链式的 pipe() 中，它们被应用于被 of() 函数发出的值。最终结果是：我们过滤出偶数并计算它们的平方，然后将结果转化为新的 observable。
注意：pipe() 操作符需要至少一个操作符作为参数。如果没有任何操作符，则它没有任何效果。
pipeable operators 的好处
使用 pipeable operators 有几个好处，包括：
易于维护
当我们需要组合多个操作符时，在使用 pipeable operators 时，我们不必担心代码的可读性或易于维护性。相反，它让我们的代码变得更加清晰、简单和可读。
具有更高的可复用性
通过将操作放在单独的函数中，我们可以将它们更好地复用于不同的观察者上。这样，我们就可以更好地管理和组织代码，并避免代码冗余。
异步管道的特定错误处理
当我们使用 pipeable operators 时，我们可以轻松地将特定的错误处理函数添加到管道的特定位置。通过这种方式，我们可以更好地控制应用程序的错误处理流程，并可以更轻松地调试和维护它们。
示例代码
以下是一些示例代码，展示如何使用一些常见的操作符与 pipeable operators。
-- -------------------- ---- -------
------ - -- - ---- -------
------ - --- - ---- -----------------
-- -- -------- --------- - ----- -------- ----------
----- -- -- -- --
------
----- -- - - --
-
------------------------
-- -- -------- --------- - ----- ------ ----------
--------- ------ ------
------
----- -- --------- - --
-
------------------------
-- -- -------- --------- - -------- ------ ----------
----- -- -- -- --
------
-------- -- - - - --- --
-
------------------------
-- -- -------- --------- - ----- --------
----- -- -- -- --
------
----- -- ------------------- ------ ----
----- -- - - ---
----- -- ------------------ ------ ---
-
------------------------结论
pipeable operators 将操作符分离到单独的函数中，使得 RxJS 的代码更简洁、清晰和可读。它们也提高了代码的可复用性，并且可以更好地组织和管理代码。最后，它们使我们的异步编程更加灵活，能够更好地控制错误处理流程。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/66fa6e6e44713626014c45f9