仅更改ReplaySubject的一个属性
ReplaySubject是RxJava中的一个特殊类型的Subject，它可以记录并重放所有的观察者事件。当一个新的观察者订阅ReplaySubject时，它会立即收到之前发生的所有事件，包括完成和错误事件。
ReplaySubject的属性可以通过设置来更改其行为。其中一个属性是缓冲区大小，它决定了ReplaySubject可以缓存的事件数量。默认情况下，缓冲区大小是无限的，但可以通过构造函数或createWithSize方法来指定一个固定的大小。
另一个属性是时间窗口，它决定了ReplaySubject可以缓存的时间范围。通过使用createWithTime方法，可以指定一个时间窗口的长度，只有在这个时间窗口内发生的事件才会被缓存。
ReplaySubject可以在许多场景中使用。例如，当需要在观察者订阅之前缓存事件，以便新的观察者能够立即获取到之前的数据时，可以使用ReplaySubject。它还可以用于实现重放功能，即当观察者订阅时，可以重新播放之前发生的事件，以便观察者能够完整地获取到数据流。
对于腾讯云相关产品，推荐使用腾讯云的消息队列CMQ（Cloud Message Queue）来实现类似的功能。CMQ是一种高可靠、可扩展、全托管的消息队列服务，可以实现消息的发布和订阅。通过使用CMQ，可以将事件作为消息发送到队列中，并在需要时订阅该队列以获取事件。CMQ提供了丰富的API和SDK，方便开发者进行集成和使用。
腾讯云CMQ产品介绍链接地址：https://cloud.tencent.com/product/cmq
相关·内容
我有一个UserDetails类型的ReplaySubject。userData: ReplaySubject<UserDetails>; 该类具有以下属性，其中两个是可选的： export class UserDetails {} 为了通过订阅来检测其他组件中的更改，到目前为止，我一直使用this.user.next(value) --但是，例如，我如何仅
浏览 17提问于2019-09-26得票数 1
我正在尝试使用angular 2中的观察值来观察一个名为loggedIn的布尔值的简单更改，它可以是真的也可以是假的。我在TS中遇到了这个错误。有没有人可以提供一个替代方案，或者告诉我我哪里做错了？localStorage.removeItem('auth_token'); //this.loggedIn.next(false);
}
浏览 0提问于2016-08-16得票数 3
我有一个非常简单的要求。当hideToolBarHeader的属性值设置为true时，使用ngClass ="{'my-class'：hideToolBarHeader}隐藏工具栏标题。传入的值来自服务。</mat-toolbar>`
在工具栏组件中不会触发更改检测。值得注意的是，header组件已经实例化并创建，而触发值更改的组件稍后出现。-将hideToolbarHeader$从
浏览 0提问于2019-05-02得票数 0
我正在尝试订阅带有角异步管道的BehaviourSubject/ReplaySubject。此外，我还必须使用auditTime或debounceTime运算符来丢弃一些值。下面是一个示例(我使用了RangeCLIVersion7.3.0并仅更改了app.component )：import {Component, OnInit} from '@angular/core';
import {Observable, ReplaySubject,
浏览 1提问于2019-03-08得票数 1
回答已采纳
我有一个奇怪的问题角5和打字(所以我的题目可能是不正确的)。此外，我还注意到事件发射器在其他地方的一个问题。日历服务constructor()
浏览 1提问于2018-02-17得票数 0
回答已采纳
我已经订阅了一个ReplaySubject，并且正在尝试用ngOnDestroy方法取消订阅。当我离开subscription组件，返回到相同的组件而没有发出数据时，它又被订阅了。/test-case-form/test-case.model';import { ReplaySubject } from'rxjs/ReplaySubject&#x
浏览 23提问于2019-06-11得票数 0
回答已采纳
_selectedViewBy$.complete();}在消费者方面，当我订阅这个ReplaySubject时，如果它的值发出的时间早于我应该得到的最后一个值，但是如果我没有从这个ReplaySubject发出任何值，那么我想要startWith但是，只有在没有从startWith发出的值的</e
浏览 1提问于2020-04-22得票数 0
聪明的爪哇人！我今天早上又慢又困，希望你能帮上忙。(我对流和编程并不陌生，但对Java和Rx非常陌生)
本质上，我有一个简单的对象，即凭据，带有一个userName属性。我把它作为ReplaySubject来接收，我想把它转换成ReplaySubject。也就是说，只需将ReplaySubject转换为ReplaySubject即可。这是表达我想要的代码，但它的错误类型错误，压倒了糟糕的</
浏览 1提问于2016-02-17得票数 0
回答已采纳
我想在一个数组中存储多个replaysubject。我的代码 public filteredSearch: ReplaySubject<any[]> = new ReplaySubject(1);
this.filteredSearch[id].next(filter(somedata)); 它抛出错误，无法读取属性'next‘的未定义，我这里缺少什么？
浏览 25提问于2019-06-25得票数 0
', }} ResourceComponent从REST-API获取资源，并包含一个呈现其他组件的子管线组件应显示提取数据的不同部分。当我单击相应的链接时，可以使用history.state将数据放入子组件中。但是，这在导航到url/resource/1/general时不起作用，因为ResourceGeneralComponent没有来自ResourceCompo
浏览 24提问于2020-04-30得票数 3
回答已采纳
我在理解为什么Intellij产生一个未解决的变量警告时遇到了问题。我希望有人能解释一下为什么会这样。我有一个接口：并且在我的组件中有一个该类型的观察值：可观察对象是从服务中检索的。服务声明返回类型：我使用异步管道在模板中解开了可观察对象，在那里我得到了警告：
<
浏览 30提问于2021-03-13得票数 0
回答已采纳
我正在寻找一个主题，它结合了ReplaySubject的功能和BehaviourSubject的功能。它应：
ReplaySubject)only 没有初始值(与BehaviourSubject不同，但与类似，向订阅服务器发送事件以进行最新更改(与ReplaySubject不同，但类似于BehaviourSubject您的解释不需要是特定的版本，因为我不一定要一个特殊的。
浏览 4提问于2021-02-04得票数 1
回答已采纳
我有一个可过滤的“活动日志”，它目前是使用ReplaySubject实现的(因为有几个组件使用它，它们可能在不同的时间订阅)。当用户更改筛选器设置时，将发出一个新请求，但是结果将追加到ReplaySubject中，而不是替换它。我想知道是否需要更新ReplaySubject，以便只使用switchMap之类的东西发送新项目。否则，我可能需要使用一个返回所有活动条目数组的Behavi
浏览 0提问于2018-07-03得票数 14
回答已采纳
我早些时候创建了一个BehaviourSubject，在订阅它时，我正在进行服务呼叫。但是，由于BehaviorSubject的性质，BehaviouSubject的初始化是不必要的。因此，在进一步阅读后，我将BehaviourSubjedct更改为ReplaySubject(1)。现在，在我定义服务的主@Injectable类中，有另一个独立的服务，一旦我做了上述更改，它就会被延迟。如何确定此处问题的</e
浏览 7提问于2019-09-21得票数 0
1回答
为此，我使用了ReplaySubject。如果我停留在同一页并更改过滤器或monthSlider，这是没有问题的。但在其他页面中也使用了FilterComponent和MonthSliderComponent，当我更改它们并返回到包含ChartComponent的页面时，这两个订阅都会被执行。我的代码：export class FilterService {
...filterReplaySubject: ReplaySubject
浏览 0提问于2017-10-05得票数 0
我定义了这样一个可以观察到的： .publishReplay(1)因此它在我的源可观测到的和所有观察者之间放置了一个ReplaySubject(1)。由于ReplaySubject的状态是观察员的数量(通过它的observers数组属性)，那么如何从obs$访问ReplaySubjec
浏览 1提问于2018-04-23得票数 2
回答已采纳
我在一个角度应用程序(calendarComponent)中有一个日历，它可以从mongodb (通过名为calendarService的服务)获得它的条目。要创建一个新条目，im将弹出一个角材质对话框(addEventComponent)。此对话框需要数据库中的一些数据才能工作。到目前为止，对话框组件从calendarService请求数据，每当我想要添加一个条目时，它都会执行一个新的http请求。除了有明显<em
浏览 0提问于2019-02-03得票数 0
回答已采纳
我有一个Subject<T>，我想在订阅它的时候收到通知。我找不到解决这个问题的机制。我是不是遗漏了什么？例如： { {
浏览 0提问于2011-03-29得票数 2
回答已采纳
假设然后，即使组件被销毁，在每个组件中创建的let todoObs$:Observable背景
我正在尝试一个用于角的Store API，并且我有一个重放主题，它可以广播对存储片的更改。，即返回一个Observable，而不是从ReplaySubject返回。属性</em
浏览 1提问于2018-09-03得票数 2
回答已采纳
我有一个观察物，我正在尝试制作一个回放主题。它应该发出可观察对象发出的当前事件和所有以前的事件。以下是我认为可以工作的方法，根据这个answer // create an observable from dummy array and a blank replay subjectconst replay$ = new ReplaySubject()
// create a replay su
浏览 20提问于2018-12-30得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
