Rxjs主题不会立即发出数据
Rxjs是一个用于处理异步数据流的JavaScript库。它提供了一种响应式编程的方式，通过使用观察者模式来处理数据流的变化。
在Rxjs中，主题（Subject）是一种特殊的可观察对象，它既可以作为数据的生产者，也可以作为数据的消费者。主题不会立即发出数据，而是在有订阅者订阅之后，才会开始发出数据。
主题有多种类型，包括BehaviorSubject、ReplaySubject和AsyncSubject。它们在数据发出的时机和订阅者接收到的数据数量上有所不同。
- BehaviorSubject：当有新的订阅者订阅时，会立即发出最近的一个值，然后继续发出后续的值。
- ReplaySubject：无论何时订阅，都会发出所有的值。可以通过设置缓冲区大小来限制发出的历史值的数量。
- AsyncSubject：只在主题完成时发出最后一个值，如果主题没有完成，则不会发出任何值。
Rxjs主题的应用场景非常广泛，特别适用于处理实时数据流、事件处理、状态管理等场景。例如，在前端开发中，可以使用Rxjs主题来处理用户输入、网络请求、定时任务等异步操作。
腾讯云提供了云原生应用开发平台Tencent Cloud Native，其中包括了一些与Rxjs相关的产品和服务。例如，Tencent Cloud Native提供了消息队列CMQ（Cloud Message Queue），可以用于处理异步消息的传递和处理。此外，Tencent Cloud Native还提供了Serverless框架SCF（Serverless Cloud Function），可以用于编写和部署无服务器函数，实现更灵活的异步处理。
更多关于腾讯云产品和服务的信息，您可以访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
1回答
我有一个带有RXJS主题的服务，并且我正在将数据分配给执行api调用的构造函数中的主题。我在组件模板中订阅此主题。尽管数据已提供给对象，但它不会在第一次发出时立即发出。<td> {{ item.employee_salary}} </td> </table> 我在200ms后通过调用getEmplo
浏览 6提问于2020-09-29得票数 1
回答已采纳
显示数据的组件指向与服务相同的对象，因此在服务中对对象所做的任何更改都将自动显示在视图层中。第一种方法有效吗？
浏览 0提问于2018-08-03得票数 0
3回答
示例Plunkr：auditTime()、throttleTime()和debounceTime() .subscribe((value) => doNextRequest(value))
throttleTime从不给出最后一个值，如果是在节流阀超时时发出的debounceTime不会立即
浏览 5提问于2016-05-10得票数 21
回答已采纳
我正在尝试创建一个rxjs主题，它将在一段时间的不活动之后重复它的输出。我最初的设计是使用debounceTime，但是这似乎不会触发不止一次。我希望主题在调用next时立即发出，并定期重复该发射，直到提供新值为止：Outputs: ---a---a---a-b---next => next, error => error, () => {
console.log('emit
浏览 8提问于2017-04-18得票数 6
回答已采纳
2回答
epic在应用程序中运行良好，我可以检查它是否正确地删除了动作，并等待300 it才发出。但由于某种原因，当我试图用玩笑测试它时，debounce操作符会立即触发。';import 'rxjs/add/operator/map&#
浏览 0提问于2019-03-19得票数 3
回答已采纳
1回答
RXJS立即发出并重试
、、、
我们在Angular中发出一个http请求，返回一些包含布尔值的数据，该布尔值指示数据是否已被完全处理。我们希望从第一个http响应中发出不完整的数据，并继续发出http请求，直到processed为true。如果第一个响应返回的是processed true，我们也希望避免产生重复的http请求。retryBackoff(retryOptions)问题是在处理为真
浏览 4提问于2019-07-27得票数 1
回答已采纳
如何在RxJS中实现乐观更新？);
在ajax调用完成之前，$todo不会发出但我希望它在todoIdSource发出后立即释放出乐观值。最后，$todo应该发出两个值：
乐观值不应触发ajax调用。乐观值应该能够使用来自可观察的
浏览 0提问于2020-02-28得票数 1
回答已采纳
3回答
在Angular4中使用Rxjs发布关注点要复制的代码:服务subject= new AsyncSubject<String>(); subject.next(data); subject.complete();预期行为:只接收一次数据，而下一次清洁数据将不会再收到一次或强迫非子危险的主题实际行为:在服务中，我有asyncSubject，它发出</
浏览 0提问于2017-10-30得票数 0
回答已采纳
2回答
无法订阅主题数据
、、
我正在使用一个共享服务来通过Subject发出数据。在一个组件中，我试图订阅主题数据，但它从不订阅 我通过组件A中的主题发送索引数据，如下组件A所示 export class ComponentA { this.sharedService.startedEditing.next(index);} 我正在使用一个共享服务来发出使用主题的索引数据。shar
浏览 34提问于2019-06-08得票数 0
回答已采纳
我有一个RxJS Subject<boolean>，用于控制旋转器是启动(true)还是停止(false)。我试图在RxJS中实现以下行为：
当我启动旋转器时，我希望它至少运行500 to ，即使在此之前收到了停止事件。用RxJS术语:当我在我的主题上发出一个true值时，计时器应该启动500 my，在这个主题上发出的所有false值都应该被忽略，直到计时器过期。用RxJS术语:当我在我的主题上发出一
浏览 1提问于2019-10-05得票数 1
我有一个像这样实现的snackbar主题，其中一条消息将在一个有角度的应用程序中出现4秒： this.snackbar.next(null); }
我想知道是否有可能以更像rxjs
浏览 4提问于2022-05-17得票数 0
回答已采纳
1回答
我有4个主题在用户输入时发出值。this.filterInputStore.selectedPrivacyOptionsHandler我的目标是一旦其中一个发出值问题:像zip或combineLatest这样的所有rxjs操作符都需要等待，直到它中的所有主题发出。如果说我想过滤一个列表并想要结果，即使我只使用一个过滤器，这是非常不切实际的。有没有rxjs的最佳实践？
浏览 5提问于2022-07-04得票数 1
回答已采纳
1回答
假设我想要定期地发出值，直到另一个可观测到的发射。因此，我可以使用timer和takeUntil来实现这一点。但是，我希望处理每个发出的值，并在某些条件变为真时停止(错误)发出。所以我写了下一段代码：const { takeUntil, map } = 'rxjs/operators';
const s看起来，当管道操作符完成时，它的值不会立即<e
浏览 3提问于2019-10-04得票数 1
回答已采纳
我尝试在多播中使用Subject来完成，但它没有显示在complete()方法中设置的完成消息。原因何在？以及如何使用error和complete方法？ subscriber.next(1); subscriber.complete(); }
let subject = new Subjec
浏览 3提问于2021-12-03得票数 0
如何编写返回的函数:可观察的。 modelTemp= [{ }]; return this.modelTemp;在服务中，变量在服务中显示为红色：如何修复此错误？ model: ModelTemp;
construc
浏览 0提问于2019-06-24得票数 1
我有一个带有值选择选项的组件 ? 。我在每个其他组件中的初始化时订阅它的值。从第一次初始化开始，返回值，但在我更改组件并返回后，值是未定义的。创建该服务是为了将该值设置为可观察值。 @Injectable({})
cho
浏览 11提问于2021-05-04得票数 0
回答已采纳
2回答
但是，即使我在模板中的布尔观察值上使用异步管道，管道()语句中的代码也永远不会执行。
浏览 31提问于2020-09-25得票数 0
回答已采纳
我有两个主题：const bar = new Subject();const foo$ = foo.pipe(我有一些限制：
import { switchMap } from 'rxjs/opera
浏览 5提问于2022-01-29得票数 0
在从任何源加载数据之前，我经常需要订阅一个主题。我还需要订阅在订阅之后立即触发，前提是并且只有在以前在主题上调用next()的情况下，并且我希望它向我显示最后发出的值，并且能够在任何时间点同步地获得当前值，类似于value字段的BehaviorSubject以下是我尝试过的：
Subject，--但是它不会像订阅BehaviorSubject那样在订阅它之后立即释放旧值，而且我不能使用大小为1的缓冲区检索当前的value.ReplaySubject，但是这也不允许检索当
浏览 0提问于2021-02-24得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
