RxJS 源代码学习（四）—— Subjects揭秘

1. Subject的定义

Subject 是 RxJS 中一个特殊的 Observable，它可以同时作为 Observable 和 Observer，即既可以向订阅者发布数据，也可以从其他 Observable 订阅数据。换句话说，Subject 是一个多播的 Observable，它可以将收到的数据同时发送给多个订阅者。

2. Subject的作用

Subject 主要用于以下几个场景：

• 当需要将数据从一个 Observable 发送到多个 Observable 时，可以使用 Subject。
• 当需要将多个 Observable 合并成一个 Observable 时，可以使用 Subject。
• 当需要在多个 Observable 之间共享数据时，可以使用 Subject。

3. Subject的使用场景

Subject 在实际开发中有很多使用场景，下面列举几个常见的例子：

• 实现广播通信： 当需要将数据广播给多个组件时，可以使用 Subject。例如，在一个聊天应用中，当有新消息到来时，可以使用 Subject 将消息广播给所有连接到服务器的客户端。
• 实现状态管理： 当需要在多个组件之间共享状态时，可以使用 Subject。例如，在一个音乐播放器中，当播放状态发生变化时，可以使用 Subject 将新的播放状态广播给所有正在播放音乐的组件。
• 实现事件处理： 当需要处理来自多个来源的事件时，可以使用 Subject。例如，在一个表单中，当用户在不同的输入框中输入内容时，可以使用 Subject 将这些事件统一处理。

4. Subject的源代码分析

Subject 的源代码位于 rxjs/src/internal/Subject.ts 文件中。Subject 类继承自 Observable 类，并实现了 Observer 接口。

在 Subject 类中，定义了以下几个重要的属性：

• _isStopped: 表示 Subject 是否已经停止发送数据。
• _hasError: 表示 Subject 是否已经发生错误。
• _thrownError: 表示 Subject 发生错误时抛出的错误对象。
• _values: 保存 Subject 收到的数据。
• _hasErrorThrown: 表示 Subject 是否已经抛出过错误。
• _observers: 保存订阅 Subject 的 Observer 对象。

在 Subject 类中，还定义了以下几个重要的方法：

• next(value): 向 Subject 发送一个数据。
• error(err): 向 Subject 发送一个错误。
• complete(): 通知 Subject 已经完成发送数据。
• subscribe(observer): 订阅 Subject。

5. 结束语

Subject 是 RxJS 中一个非常重要的类，它可以同时作为 Observable 和 Observer，具有非常强大的功能。在实际开发中，Subject 有很多使用场景，例如实现广播通信、实现状态管理、实现事件处理等。