内容简介:在 RxJS 中,Observable 有一些特殊的类,在消息通信中使用比较频繁,下面主要介绍较常用的几个类:Subject 可以实现一个消息向多个订阅者推送消息。这样两路接受者都能拿到发送的数据流:
Rxjs_Subject 及其衍生类
在 RxJS 中,Observable 有一些特殊的类,在消息通信中使用比较频繁,下面主要介绍较常用的几个类:
1/Subject
Subject 可以实现一个消息向多个订阅者推送消息。
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:1 observerB:1
2/BehaviorSubject
BehaviorSubject 是 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:2 observerB:2 observerA:3 observerB:3
3/ReplaySubject
ReplaySubject 类似于 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: 1 observerA: 2 observerA: 3 observerA: 4 observerB: 2 observerB: 3 observerB: 4 observerA: 5 observerB: 5
4/AsyncSubject
AsyncSubject 是另一个 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: 5 observerB: 5
以上所述就是小编给大家介绍的《【Rxjs】Rxjs_Subject 及其衍生类》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:- 大数据生态圈及其衍生物
- MariaDB 10.3.16 发布,MySQL 衍生版
- MariaDB 10.3.16 发布,MySQL 衍生版
- Ultimate Edition 5.7 发布,Ubuntu 的衍生版
- MariaDB 10.4.7 稳定版发布,MySQL 衍生版
- Puppy Linux 衍生版 Fatdog64 发布,采用 Linux 4.14
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。