shareReplay与ReplaySubject -仅ReplaySubject在订阅前缓存最新值
shareReplay和ReplaySubject都是RxJS中的操作符和主题，用于在订阅前缓存最新值。
- shareReplay:
- 概念：shareReplay是一个操作符，用于在多个订阅者之间共享Observable的值，并且在新的订阅者加入时，将最新的值立即发送给它们。
- 优势：通过使用shareReplay，可以避免重复执行Observable的副作用，减少资源消耗，并确保新的订阅者能够立即获取到最新的值。
- 应用场景：适用于需要多个订阅者共享同一份数据的场景，例如在多个组件中使用同一个HTTP请求的结果。
- 推荐的腾讯云相关产品：无
- ReplaySubject:
- 概念：ReplaySubject是一个特殊类型的Subject，它会在订阅前缓存一定数量的值，并在新的订阅者加入时，将缓存的值立即发送给它们。
- 优势：ReplaySubject可以确保新的订阅者能够获取到之前已经发出的值，而不仅仅是最新的值。
- 应用场景：适用于需要在订阅前获取之前发出的值的场景，例如在日志记录或事件追踪中，可以使用ReplaySubject来获取之前的日志或事件。
- 推荐的腾讯云相关产品：无
请注意，以上答案仅供参考，具体的推荐产品和产品介绍链接地址需要根据实际情况进行选择。
相关·内容
在观察者可以订阅之前，我有一个外部热源在推送数值。订阅后，较晚的观察者应收到最新的值以及此后的每一个值。send valuesconst o = s.pipe(shareReplay但什么也没发生)，但我找到了一种方法让它起作用： // irrelevant, just t
浏览 39提问于2019-01-05得票数 2
回答已采纳
嗨，我正在寻找一个行为类似于withLatestFrom的RxJs操作符，但它会等待第二个流发出一个值，而不是跳过它。我只想在第一条溪流释放出一个新的值时才要排放。
浏览 0提问于2020-04-24得票数 3
回答已采纳
2回答
角6发送请求一次
、、
请帮忙解决这个问题public list(): Observable<ILanguage[]> { if (this._languages && this._languages.length > 0) { observer.comp
浏览 0提问于2018-09-03得票数 1
回答已采纳
当消费者订阅时，他们应该立即收到最后的价值，并在未来得到新的价值。
我的理解是:如果我添加上面所示的shareReplay，并且关闭了refCount，它将订阅它的上游可观测性(即。(在本例中，dataSubject )立即保存最后一个值，当存在下游订阅者时，发出最后一个值以及任何未来的值。相反，如果我正确理解，会发生什么:如果第一个下游订阅者比源中的第一个值来得晚，那么主题的第一个值就会丢失，因为
浏览 0提问于2020-11-02得票数 2
回答已采纳
我有一个简单的代码，返回缓存的公司或从数据库的公司。问题是我几乎在同一时间从两个不同的地方订阅了这个观察点。这会触发对数据库的2次调用，所以我只想在第一次调用完成并且缓存值已经存在的情况下运行第二次订阅。有没有通过rxjs运算符执行此操作的标准方法？
浏览 0提问于2018-05-25得票数 1
3回答
Problem：在构造方面，我正在使用的角度应用程序相当复杂。许多相同组件的实例具有相同位置的不同数据输入(父组件)，每个组件都是在应用程序中显示的不同的图表，如下所示：
<sample-component [data]='data1> </sample-componentdata]='data2> </sample-component> <sample-component [data]='data3> </sample-component>
浏览 4提问于2020-04-09得票数 0
我使用角(v6)服务从后端获取数据并存储在变量中。我只想调用api一次，并在需要时将数据提供给不同的组件。问题是，我从不同的组件调用服务中的getPlans()函数来获取数据，对于每个调用，我在浏览器的网络选项卡中看到一个api调用。
浏览 3提问于2019-05-09得票数 5
在登录过程之后，我向服务器发出请求，并获得活动的car。此外，当用户已经登录(令牌还没有过期)并打开应用程序(或通过F5刷新页面)时，我还从服务器加载活动的汽车。因此，在我的服务中，我有：然后，在构造函数中，我获取数据并为然后，我在一些组件中使用它： .subscribe(car=> {
浏览 2提问于2017-08-22得票数 0
1回答
我正在创建一个角度应用程序，它使用WebSocket连接与后端服务器进行通信。details'), takeUntil(this.authService.logout),}
这在第一次登录时工作得很好--所以在创建服务时是这样，但是当注销和再次登录时，服务构造函数就不会再次被触发，而且可观察到的details$似乎不会发出任
浏览 3提问于2020-06-11得票数 1
回答已采纳
1回答
每次this.selectedLanguage$发出一个新值时，我都需要发出一个异步计算的值。_matchService.getCategoriesAsync(x)),我使用switchMap是因为如果selectedLanguage在获取类别时发生了变化，
浏览 0提问于2020-03-21得票数 0
2回答
subscription.unsubscribe(),6000);我之所以使用behaviorSubject而不直接在可观察到的上订阅，是因为我希望在重新订阅时立即从最后一个xhr请求中获得最后一个值。
浏览 1提问于2017-02-19得票数 2
回答已采纳
我正在寻找一个主题，它结合了ReplaySubject的功能和BehaviourSubject的功能。它应：
ReplaySubject)only 没有初始值(与BehaviourSubject不同，但与类似，向订阅服务器发送事件以进行最新更改(与ReplaySubject不同，但类似于BehaviourSubject
浏览 4提问于2021-02-04得票数 1
回答已采纳
2回答
#adaptedData), )
}}<ng-container *ngIf="(dashboardStats | async) as现在，我只使用模板中的异步管道初
浏览 8提问于2022-03-15得票数 0
回答已采纳
我一直在尝试让我的流只重放最新的值，但运气很差。基本上，我在一个不能手动.onNext它的地方有一个replaySubject(1)。我想要做的是，将它映射到其他东西，然后添加一个初始值。我的第一反应是：var testOutStream = testInStream.startWith(-1);我能想到的最接近的是
var testInStream = new Rx.Re
浏览 0提问于2016-03-29得票数 4
新的订阅者应该会看到最近发出的健康数据。我也想关闭websocket时，没有更多的订户。
订阅服务器C连接，但只需要一个值take(1)。返回由publishReplay(1)<em
浏览 0提问于2018-12-15得票数 6
4回答
我们尝试使用BehaviorSubject在多个组件之间共享API数据。在我的组件上，我触发了一个HTTP请求，并在返回响应后更新主题。this.http.get(myUrl).subscribe((res: any) => { });在请求完成后，如何才能仅访问BehaviourSubject发出的最后一个值？
浏览 7提问于2021-01-14得票数 0
_selectedViewBy$.complete();}在消费者方面，当我订阅这个ReplaySubject时，如果它的值发出的时间早于我应该得到的最后一个值，但是如果我没有从这个ReplaySubject发出任何值，那么我想要startWith但是，只有在没有从sta
浏览 1提问于2020-04-22得票数 0
在angular应用程序中，我经常使用一些服务，这些服务需要通过http请求检索一些数据，并通过BehaviorSubject将其分享给消费者。res => this.data.next(res)); } 这种方法的主要问题是，当应用程序的一些组件在还没有值的情况下同时调用getData()时，它将触发多个http调用和数据发送，所以我找到了两种方法来防止它：class Service
浏览 0提问于2018-07-18得票数 1
我已经订阅了一个ReplaySubject，并且正在尝试用ngOnDestroy方法取消订阅。当我离开subscription组件，返回到相同的组件而没有发出数据时，它又被订阅了。/test-case-form/test-case.model';import { ReplaySubject } from'rxjs/ReplaySubjec
浏览 23提问于2019-06-11得票数 0
回答已采纳
从观察者的角度来看，使用带有Subject运算符的last()是否与使用ReplaySubject(1)相同？换句话说，在这种情况下：let s2 = new ReplaySubject<any>(1)();
因此，在这种情况下，如果s1和s2的序列源相同，那么s1和s2的订阅者将看到相同的值序列？
浏览 0提问于2018-09-12得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
