如何在RxJS 5中创建Hot Observable

How to create Hot Observable in RxJS 5

本文关键字：创建 Hot Observable RxJS      更新时间：2023-09-26

我使用RxJS 4创建Hot Observable，如官方文档中所述

但是RxJS 5迁移指南并没有解释如何创建Hot Observable。

const source = Observable.create((observer) => {
  asynCall((data) => {
    observer.onNext(data)
  })
})
const published = source.publish()
published.connect()
published.subscribe((data) => {
  console.log(data)
})

对于Rx5，我有以下错误：

未捕获类型错误：source.publish不是函数（…）

您可以使用.publish().refCount()（或.share()作为别名）

var source = Rx.Observable.interval(1000)
    .take(5)
    .publish().refCount();
source.subscribe( item => console.log(`-: ${item}`));
setTimeout(() => {
    source.subscribe( item => console.log(`--: ${item}`));
}, 2500);

http://jsbin.com/cupibitehu/1/edit?js，控制台

上面设置了两个订阅，以显示延迟的订阅将从当前发射发生的地方开始，而不是重播以前发射的结果。

记录以下

"-: 0"
"-: 1"
"-: 2"
"--: 2"
"-: 3"
"--: 3"
"-: 4"
"--: 4"

http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#实例方法共享

以下是对冷热可观测的看法

 Hot Observable

任何在订阅上没有产生新生产者的可观察对象（如果obs.subscribe（）在可观察对象上被调用，则不应该为新创建的订阅创建新的observer.next（val）。它应该使用旧的，因此获得当前时间点的值）

Cold Observable

任何在订阅上产生新生产者的obs.subscribe（）基本上都会创建observer.next（）——一个单独用于该订阅的新源生产者。所有角度的HttpCLient可观察器都是这种类型的。对于组件中的每个obs.subscribe，您可以看到仅从该订阅的API发出的值。每次从开始

因此，基本上，publish（）和refCount（）rxjs运算符在上面所做的是创建一个可观察的对象，它的行为同时类似于热可观察和冷可观察。Hot observable-因为没有生成新的源值，Cold observable–因为它只有在订阅发生时才开始发出值-第一次调用obs.subscribe（）

因此，为了生成一个不需要订阅就可以存在的HotObservable，那么publish（）和connect（）将完成

var source = Rx.Observable.create({<some obj>})
   
    .publish();
source.connect();
source.subscribe( item => console.log(`-: ${item}`));
setTimeout(() => {
    source.subscribe( item => console.log(`--: ${item}`));
}, 2500);

您将不会在控制台中看到任何内容，因为在订阅发生时，可观察对象会发出值。请注意，如果可观察到的值发出延迟，那么您可能会在订阅中看到它们我也想称赞这篇文章：它解释得很好https://blog.thoughtram.io/angular/2016/06/16/cold-vs-hot-observables.html

相关文章：