RxJS 是一个流式编程工具，使得在 JavaScript 中进行事件驱动和异步操作变得更加容易和舒适。在 RxJS 中，Observable 表示一个源数据流并且可以进行诸如过滤、映射等处理。Subject 是一种特殊的可观察对象，它像一个事件发射者和接收者。本篇文章将详细介绍如何使用 Subject 来创建自己的可观察对象并控制数据流。
引入
在开始使用 RxJS 中的 Subject 之前，需要先安装 RxJS，并全局引入 RxJS 库。
npm install rxjs在代码中引入 rxjs。
import { Subject } from 'rxjs';
创建 Subject
Subject 是一个拥有三个方法的特殊可观察对象：next、error 和 complete。这三个方法都可以用来发送值。
可以使用 new 关键字创建一个 Subject。
const subject = new Subject();
将 Subject 转换为 Observable
Subject 常用于将多个 Observable 合并为一个，并同时发射值。但如果要将 Subject 作为普通的 Observable 使用，可以通过 asObservable 方法转换。
const subject = new Subject(); const observable = subject.asObservable();
传递数据
可以通过 next 方法来传递值。每次调用 next 方法时，都会将该值传递给 Subject 的所有订阅者。
const subject = new Subject(); subject.next('hello');
如果在没有订阅者的情况下调用 next 方法，该值将丢失，因为没有目标对象可以接收该值。
处理错误
在观察数据流时，有可能出现错误。使用 error 方法向 Subject 发出通知，指示错误已发生。
const subject = new Subject(); subject.error(new Error('something went wrong'));
处理错误的方法与处理正常值的方法相同。错误信息将传递给所有订阅者。
完成操作
在某些情况下，应该通知订阅者数据流已完成。使用 complete 方法向 Subject 发送通知。
const subject = new Subject(); subject.complete();
在 Subject 调用 complete 方法后，订阅者将不再接收到值。
订阅
创建 Subject 后，需要订阅该 Subject 以接收发出的值和错误信息。
使用 subscribe 方法订阅 Subject。
const subject = new Subject(); const subscription = subject.subscribe({ next: value => console.log(value), error: error => console.log(error), complete: () => console.log('completed'), });
上述代码中，使用一个对象作为 subscribe 方法的参数，并在对象中声明 next、error 和 complete 方法，以定义订阅者需要处理数据流的方式。
示例
下面是一个使用 Subject 和 Observable 的简单示例。
-- -------------------- ---- ------- ------ - ------- - ---- ------- ------ - ---- - ---- ----------------- ----- ------- - --- ---------- ----- ---------- - ------------------------------------- ---------------------- ----- ----- -- ------------------------ ----------- --------- -- -- ------------------------ ------------ --- ---------------- ---------------- ---------------- ----------------展开代码
在上面的示例中，我们使用 Subject 创建一个 observable 对象，并使用 take 操作符将其限制到前三个值。然后我们将该 observable 订阅并记录输出。我们发送四个值，但由于使用 take 操作符而只输出了前三个值。
总结
通过学习如何使用 Subject，您已经了解了它的工作原理。Subject 是一种特殊的可观察对象，它可以像事件发射者和接收者一样工作。它具有三个方法：next、error 和 complete，可用于发送值和通知。通过将 Subject 转换为 Observable，还可以将其用作普通可观察对象。通过订阅 Subject，您可以接收它发送的值和通知。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/649d14fa48841e98949ccfce
