RxJS 中的 Subject 的实现原理
如果你是一名前端开发者，那么你一定会接触到 RxJS 这个强大的库。RxJS 是 Reactive Extensions 的简称，是一款响应式编程库，它可以让我们用流式操作来处理异步数据。而 Subject 就是 RxJS 中最为核心的部分之一。
Subject 是一种特殊的 Observable，它可以同时作为一个观察者和一个可观察对象。Subject 可以订阅一个或多个观察者，当它内部的数据发生变化时，会自动将这些变化推送给所有订阅它的观察者。因此，Subject 可以用来实现多个组件或模块之间的数据通信。如果你想深入了解 RxJS 中的 Subject，就需要了解它的实现原理。
Subject 的实现分为两部分，分别是 Subject 类和 Subject 实例。Subject 类的定义如下所示：
-- -------------------- ---- -------
----- ---------- ------- ------------- ---------- ------------- -
------- ---------- ------------- - ---
------- ------- ------- - ------
------------ --- ---- -
-- -------------- -
----- ---- - -----------------------
--- ---- - - -- - - ------------ ---- -
--------------------
-
-
-
---------- ----- ---- -
-- -------------- -
----------- - -----
----- ---- - -----------------------
--- ---- - - -- - - ------------ ---- -
-------------------
-
--------------------- - --
-
-
----------- ---- -
-- -------------- -
----------- - -----
----- ---- - -----------------------
--- ---- - - -- - - ------------ ---- -
-------------------
-
--------------------- - --
-
-
------- ------------- -
-------------- - ------
----------- - -----
-
--------- ---------------------- --------------- ------------ -
-- ------------- -
----- --- --------------------------
- ---- -- --------------- -
-----------------------------------
------ -------------------
- ---- -- ---------------- -
----------------------
------ -------------------
- ---- -
--------------------------------
------ --- ------------------------- ------------
-
-
-Subject 实例的定义则包含了一些额外的方法和属性，例如 unsubscribe 方法和 isStopped 属性。在实例化 Subject 时，我们接收到的是一个类的实例，它相当于一个事件发布者，多个订阅者可以订阅这个发布者，当 Subject 的 next 方法被调用时，订阅者就会收到这个事件。
除了 next 方法，Subject 还包含了 error 和 complete 方法，这些方法可以在 Subject 的发布者完成它的工作后被调用。当 error 或 complete 方法被调用时，Subject 实例会停止向订阅者发布消息。
Subject 的实现十分简单，它的核心就是观察者模式。Subject 会维护一个观察者数组，当它的 next 方法被调用时，就会遍历这个数组，将消息推送给所有的观察者。当 error 或 complete 方法被调用时，Subject 会遍历这个数组，并调用观察者的 error 和 complete 方法。
下面是一个简单的 Subject 使用示例：
-- -------------------- ---- ------- ------ - ------- - ---- ------- ----- ------- - --- ------------------ ------------------- ----- ----- -- ------------------------------ --- ---------------- -- -- ---------- ---------------- -- -- ----------
这个例子中，我们通过创建一个 Subject 实例来创建一个发布者。然后我们调用了这个实例的 next 方法，将值推送给了订阅者。在这个例子中，我们只订阅了一个观察者，但实际上 Subject 可以同时订阅多个观察者。
总结
RxJS 中的 Subject 是一种特殊的 Observable，它可以同时作为一个观察者和一个可观察对象。Subject 的实现原理是观察者模式，Subject 维护了一个观察者数组，它的 next 方法会遍历这个数组，并将数据推送给所有的观察者。Subject 还包含了 error 和 complete 方法，它们可以用来停止向订阅者发布消息。使用 Subject 可以实现多个组件或模块之间的数据通信。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64aa5a5448841e989468805c