【Rxjs】Rxjs_Subject 及其衍生类

栏目: 编程语言 · 发布时间: 5年前

内容简介:在 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 及其衍生类》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

上瘾

上瘾

[美] 尼尔·埃亚尔、[美] 瑞安·胡佛 / 钟莉婷、杨晓红 / 中信出版集团 / 2017-5 / 49.00元

——为什么我们会习惯性地点开某个App? ——这种使用习惯到底是如何养成的? ——为什么有些产品能让我们戒不掉,而其他的产品却不行? ——是否有什么秘诀能让用户对你的产品形成使用习惯,欲罢不能? 《上瘾》揭示了很多让用户形成使用习惯,甚至“上瘾”的互联网产品服务背后的基 本设计原理,告诉你怎样打造一款让用户欲罢不能的产品。作者根据自己多年的研究、咨询及实际经验,提出了新颖而......一起来看看 《上瘾》 这本书的介绍吧!

CSS 压缩/解压工具
CSS 压缩/解压工具

在线压缩/解压 CSS 代码

图片转BASE64编码
图片转BASE64编码

在线图片转Base64编码工具

随机密码生成器
随机密码生成器

多种字符组合密码