当前位置: 首页 > news >正文

鑫迪建站系统鄂州网站制作人才招聘

鑫迪建站系统,鄂州网站制作人才招聘,音乐网站制作教程,中国空间站拒绝10国名单在RxJS(Reactive Extensions for JavaScript)中,Subject、BehaviorSubject、ReplaySubject和AsyncSubject都是Observable的变体,它们用于处理观察者模式中的不同场景。以下是它们之间的主要区别: 1、Subject: 是一种特…

在RxJS(Reactive Extensions for JavaScript)中,Subject、BehaviorSubject、ReplaySubject和AsyncSubject都是Observable的变体,它们用于处理观察者模式中的不同场景。以下是它们之间的主要区别:

1、Subject:
是一种特殊的Observable,同时也是观察者。可以通过调用next()方法向Subject中推送新的值。
在订阅Subject时,可以接收到订阅之后产生的值。
没有初始值,也没有缓存历史值的功能。
在这里插入图片描述
上面例子就比较容易理解:

  • 我们创建了一个Subject
  • 发出了一个值1,但由于此时并没有订阅者,所以这个值不会被订阅到
  • 创建了订阅者 A
  • 又发出一个值 2,这时候订阅者 A 会接收到这个值
  • 又创建一个订阅者 B
  • 最后发出一个值 3,这时候已经订阅的都会接收到这个值

2、BehaviorSubject:
是一种特殊的Subject,具有初始值。
在订阅时,会立即收到当前的值,然后在之后每次Subject发出新值时,订阅者都会收到更新后的值。
保留并提供对当前值的访问。
在这里插入图片描述
这段代码做了那些工作呢?

  • 我们首先创建了一个BehaviorSubject的实例behavior$,并在实例化时传入初始值 0。
  • 然后我们订阅了这个这个实例behavior$,由于BehaviorSubject的特点是把最新的值发布给订阅者,订阅者 A 会得到初始值 0,所以就会打引出订阅者 A,订阅值为:0
  • behavior$使用内置的next方法发出一个新的值 1,这时候订阅者 A 将会收到新的值,打印出订阅者 A,订阅值为 1
  • 我们增加一个订阅者 B,这时候它会得到最新的值 1,所以打印结果为订阅者B,订阅值为 1
  • 最后我们再一次调用behavior$的next方法,由于我们之前已经订阅了两次,所以订阅者 A 和订阅者 B 都会接收到新的value

3、ReplaySubject
会在订阅时接收一定数量的历史值(缓存)。
可以指定缓存的大小,当新的值推送到ReplaySubject时,最早的值会从缓存中移除。
适用于需要让订阅者获取历史值的场景。

在这里插入图片描述
这里发生了一些事情:

  • 我们创建了一个ReplaySubject的实例replay$,并指定我们只想存储最后两个值
  • 我们创建了一个订阅者 A
  • 调用三次replay$的next方法,把值发布给订阅者。这时订阅者 A 将会打印三次
  • 现在就来体验ReplaySubject的魔力。我们使用replay$创建了一个新的订阅者 B,由于我们告诉ReplaySubject,存储两个值,因此它将直接向订阅者 B 发出这些最后的值,订阅者 B 将打印出这些值。
  • replay$发出另外一个值,这时候,订阅者 A 和订阅者 B 都接收到值的改变,打印出另外一个值

你还可以指定值在ReplaySubject存储的时间,我们来看一个例子:
在这里插入图片描述
上面代码中发生了那些事情呢:

  • 我们创建了ReplaySubject,并指定它只存储最后两个值,但是不超过 100ms
  • 创建一个订阅者 A
  • 我们开始每 200ms 发出一个新的值。订阅者 A 会接收到发出的所有值
  • 我们创建一个订阅者 B,由于是在 1000ms 后进行订阅。这意味着在开始订阅之前,replay 已经发出了 5 个值。在创建ReplaySubject时,我们指定最多存储 2 个值,并且不能超过 100ms。这意味着在 1000ms 后,订阅者 B 开始订阅时,由于replay 是 200ms 发出一个值,因此订阅者 B 只会接收到 1 个值。

4、AsyncSubject:
只有在Subject完成时,订阅者才会收到最后一个值。
可以看作是在Observable完成时发射最后一个值的特殊Subject。
适用于只关心Observable完成时的结果的场景。

const asyncSubject = new AsyncSubject();
asyncSubject.subscribe(value => console.log(value));
asyncSubject.next(1);
asyncSubject.next(2);
asyncSubject.complete(); // 输出: 2

总的来说,这些Subject的选择取决于使用场景。BehaviorSubject适用于需要初始值的场景,ReplaySubject适用于需要缓存历史值的场景,AsyncSubject适用于只关心Observable完成时的结果的场景,而普通的Subject则是一个简单的广播机制。

http://www.yayakq.cn/news/325727/

相关文章:

  • 电子商务自助建网站公司网站备案需要什么资料
  • 试管婴儿网站建设西安做网站排名
  • 福州网站设计企业网站建站官网优化包括什么内容
  • 乐清柳市广电网站网站建设的电话销售好做不
  • 宿迁做网站 宿迁网站建设常德网站建设培训机构
  • 沈阳做购物网站电话手机版cad简单制图
  • 企业网站建设的流程网站优化推广的方法
  • wordpress做的网站0基础网站建设模板
  • 把网站放到服务器上j集团公司的网站建设
  • 化州网站建设藤虎网络广州网站建设
  • 在线A视频网站 一级A做爰片网络营销推广主要做什么
  • 网站gzip压缩小软件制作教程
  • 自己做网站要买域名吗代理公司简介
  • 营销型网站概念做网站用什么源码
  • 西宁网站搭建企业百度seo自然优化
  • 教育建设网站免费网页源代码网站
  • 聊城专业网站建设搜狐快站建设pc网站
  • 宝塔建站详细教程wordpress获取所有图片
  • 定州建设厅网站如何做静态页网站
  • html5响应式网站psd网页设计心德体会500字范文
  • 适合前端新手做的网站wordpress获取文章时间
  • 怎么把网站做二维码上海成品网站
  • 无网站做百度推广南京做网站的
  • 全景精灵网站建设服装 产品展示网站模板
  • 上海设计网站基本建设程序
  • 鄂尔多斯公司网站建设西安有什么好玩的地方
  • 加盟酒店网站制作wordpress自定义字段面板
  • 商城网站建设都有哪些类型可以做空股票的网站
  • 住房和城乡建设部门户网站网站搭建源码
  • 阿里云网站备案登陆app网站搭建