【Rxjs】Rxjs_Subject 及其衍生类

Rxjs_Subject 及其衍生类在 RxJS 中，Observable 有一些特殊的类，在消息通信中使用比较频繁，下面主要介绍较常用的几个类：1/ SubjectSubject 可以实现一个消息向多个订阅者推送消息。Subject 是一种特殊类型的 Observable，它允许将值多播给多个观察者，所以 Subject 是多播的，而普通的 Observables 是单播的(每个已订阅的观察者都拥有 Observable 的独立执行)。每个 Subject 都是观察者。 - Subject 是一个有如下方法的对象： next(v)、error(e) 和 complete() 。要给 Subject 提供新值，只要调用 next(theValue)，它会将值多播给已注册监听该 Subject 的观察者们。var subject = new Rx.Subject(); //实例化一个Subject对象subject.next(1); //向接受者发送一个消息流subject.subscribe({ next: value => console.log(“observerA: " + value) //接受者A订阅消息，获取消息流中的数据});subject.subscribe({ next: value => console.log(“observerB: " + value) //接受者B订阅消息，获取消息流中的数据});这样两路接受者都能拿到发送的数据流：observerA:1observerB:12/ BehaviorSubjectBehaviorSubject 是 Subject 的一个衍生类，它将数据流中的最新值推送给接受者。var subject = new Rx.BehaviorSubject(0); //声明一个 BehaviorSubject 对象subject.next(1); //发送一个数据流subject.next(2); //再发送一个数据流subject.subscribe({ next: v => console.log(“observerA: " + v) //接受者 A 订阅消息});subject.subscribe({ next: v => console.log(“observerB: " + v) //接受者 B 订阅消息});subject.next(3); //再发送一个数据流这样，每次接受者只会接受最新最送的那个消息：observerA:2observerB:2observerA:3observerB:33/ ReplaySubjectReplaySubject 类似于 BehaviorSubject，它可以发送旧值给新的订阅者，但它还可以记录 Observable 执行的一部分。当创建 ReplaySubject 时，你可以指定回放多少个值：var subject = new Rx.ReplaySubject(3); // 为新的订阅者缓冲3个值subject.subscribe({ next: v => console.log(“observerA: " + v)});subject.next(1);subject.next(2);subject.next(3);subject.next(4);subject.subscribe({ next: v => console.log(“observerB: " + v)});subject.next(5);输出：observerA: 1observerA: 2observerA: 3observerA: 4observerB: 2observerB: 3observerB: 4observerA: 5observerB: 54/ AsyncSubjectAsyncSubject 是另一个 Subject 变体，只有当 Observable 执行完成时(执行 complete())，它才会将执行的最后一个值发送给观察者。var subject = new Rx.AsyncSubject();subject.subscribe({ next: v => console.log(“observerA: " + v)});subject.next(1);subject.next(2);subject.next(3);subject.next(4);subject.subscribe({ next: v => console.log(“observerB: " + v)});subject.next(5);subject.complete();输出：observerA: 5observerB: 5参考文档《PublishSubject，ReplaySubject，BehaviorSubject，AsyncSubject》