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

查看所有标签

猜你喜欢:

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

Java EE WEB开发与项目实战

Java EE WEB开发与项目实战

李俊青 / 华中科技大学出版社 / 2011-11 / 59.80元

本书采用工程案例的形式,将日常Java EE项目开发所涉及的技术要点进行了解析,系统介绍了Apache的安装、Tomcat的安装、虚拟主机的配置、开发工具的搭配使用、验证码的使用、过滤器的使用、密码的加密与解密、JavaMail邮件发送、Web在线编辑器的使用、文件上传、数据库连接池、Ajax与Servlet的身份认证、Struts框架的应用、JSF框架的应用、Spring框架的应用、Hibern......一起来看看 《Java EE WEB开发与项目实战》 这本书的介绍吧!

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

在线压缩/解压 CSS 代码

XML、JSON 在线转换
XML、JSON 在线转换

在线XML、JSON转换工具

RGB CMYK 转换工具
RGB CMYK 转换工具

RGB CMYK 互转工具