前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >【Rxjs】Rxjs_Subject 及其衍生类

【Rxjs】Rxjs_Subject 及其衍生类

作者头像
CloudCat
发布2019-05-26 11:09:10
8890
发布2019-05-26 11:09:10
举报
文章被收录于专栏:一只想做全栈的猫

Rxjs_Subject 及其衍生类

在 RxJS 中,Observable 有一些特殊的类,在消息通信中使用比较频繁,下面主要介绍较常用的几个类:

1/ Subject

Subject 可以实现一个消息向多个订阅者推送消息。

Subject 是一种特殊类型的 Observable,它允许将值多播给多个观察者,所以 Subject 是多播的,而普通的 Observables 是单播的(每个已订阅的观察者都拥有 Observable 的独立执行)。每个 Subject 都是观察者。 - Subject 是一个有如下方法的对象: next(v)、error(e) 和 complete() 。要给 Subject 提供新值,只要调用 next(theValue),它会将值多播给已注册监听该 Subject 的观察者们。

代码语言:javascript
复制
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订阅消息,获取消息流中的数据
});

这样两路接受者都能拿到发送的数据流:

代码语言:javascript
复制
observerA:1
observerB:1

2/ BehaviorSubject

BehaviorSubject 是 Subject 的一个衍生类,它将数据流中的最新值推送给接受者。

代码语言:javascript
复制
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); //再发送一个数据流

这样,每次接受者只会接受最新最送的那个消息:

代码语言:javascript
复制
observerA:2
observerB:2
observerA:3
observerB:3

3/ ReplaySubject

ReplaySubject 类似于 BehaviorSubject,它可以发送旧值给新的订阅者,但它还可以记录 Observable 执行的一部分。

当创建 ReplaySubject 时,你可以指定回放多少个值:

代码语言:javascript
复制
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);

输出:

代码语言:javascript
复制
observerA: 1
observerA: 2
observerA: 3
observerA: 4
observerB: 2
observerB: 3
observerB: 4
observerA: 5
observerB: 5

4/ AsyncSubject

AsyncSubject 是另一个 Subject 变体,只有当 Observable 执行完成时(执行 complete()),它才会将执行的最后一个值发送给观察者。

代码语言:javascript
复制
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();

输出:

代码语言:javascript
复制
observerA: 5
observerB: 5

参考文档《PublishSubject,ReplaySubject,BehaviorSubject,AsyncSubject》

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • Rxjs_Subject 及其衍生类
    • 1/ Subject
      • 2/ BehaviorSubject
        • 3/ ReplaySubject
          • 4/ AsyncSubject
          领券
          问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档