当您不希望外部订阅完成，而内部订阅应该完成时，请避免嵌套订阅
当您不希望外部订阅完成，而内部订阅应该完成时，可以避免嵌套订阅的方法是使用消息队列。
消息队列是一种在应用程序之间传递消息的通信方式。它将消息发送到队列中，并由接收者从队列中获取消息进行处理。通过使用消息队列，可以实现解耦和异步通信，提高系统的可靠性和可扩展性。
在这种情况下，您可以将外部订阅和内部订阅分别作为两个独立的消息发送到消息队列中。外部订阅的处理程序可以订阅外部订阅的消息，并执行相应的操作。而内部订阅的处理程序可以订阅内部订阅的消息，并在内部订阅完成时执行相应的操作。
使用消息队列的优势包括：
- 解耦：通过将消息发送到队列中，发送者和接收者之间的直接依赖关系被解耦，提高了系统的灵活性和可维护性。
- 异步通信：发送者可以将消息发送到队列中后立即返回，而不需要等待接收者的处理。这种异步通信方式可以提高系统的响应速度和吞吐量。
- 可靠性：消息队列通常具有持久化机制，可以确保消息在发送和接收过程中不会丢失。即使接收者暂时不可用，消息也会被保存在队列中，待接收者可用时再进行处理。
- 可扩展性：通过增加消息队列的消费者，可以实现系统的水平扩展，提高系统的处理能力。
在腾讯云中，推荐使用腾讯云消息队列 CMQ（Cloud Message Queue）来实现消息队列功能。CMQ 提供了高可靠、高可用、高性能的消息队列服务，支持消息的发布和订阅，以及消息的持久化和顺序传输等特性。
您可以通过以下链接了解更多关于腾讯云消息队列 CMQ 的信息： https://cloud.tencent.com/product/cmq
相关·内容
我在for each循环中有一个嵌套的订阅，内部订阅将外部订阅的结果作为输入。我需要这样的代码，当它在for循环中迭代时，它应该调用外部订阅，并将其结果/输出传递给内部订阅。在这里，for循环应该等到过程完成后再进行下一次迭代。
浏览 23提问于2020-07-12得票数 0
1回答
response).subscribe(secondResponse => { console.log(secondResponse) })我很确定这做了我想做的事情，但我在某个地方读到，在另一个订阅中做订阅并不是实现它的方法
浏览 1提问于2020-02-26得票数 0
回答已采纳
1回答
在尝试使用广度优先搜索查找最短路径时，首先从具有起始节点的队列开始，将该节点弹出，然后将该节点的子节点添加到队列中，继续循环。当您找到您正在寻找的结束节点时，您将停止执行/从队列中弹出内容。我想要做的是拥有一个可以订阅的外部观察点。当有人订阅时，它将启动一个内部可观察对象的基本队列。当这些观察量运行时，它们会将其他观察量添加到内部观察量队列中。如果我正在寻找的值/场景在可观察的执
浏览 13提问于2021-11-13得票数 0
我只是想知道，在每个管道中使用takeUntil是最佳实践，还是只有一个管道？text$.pipe( distinctUntilChanged(), tap(() => (this.searching = true)), this.searchService.search(term).pipe(
浏览 1提问于2020-12-05得票数 1
使用，似乎有两种方式让订阅者从一个信号接收相同的值，而不是重新触发任何操作生成这些值:通过RACReplaySubject或RACMulticastConnection。下面是RACReplaySubject的头文档：
多播连接封装了向多个订阅者共享一个信号的订阅的想法。如果对底层信号的订阅涉及副作用，或者不应
浏览 3提问于2013-02-25得票数 16
回答已采纳
下面的嵌套订阅可以工作，但不是很好，因为我不想对每个组件都这样做：
http.put('/cart', data).subscribe(()=>{http.get('/cart').subscribe(我希望订阅下一部分只在前两个观察值都完成时调用，如果发生错误，请转到错误部分
浏览 0提问于2018-01-30得票数 1
forState:UIControlStateNormal]; self.viewModel.isValicodeGetEnabel = YES;但我不能进入已完成的街区
浏览 1提问于2015-09-10得票数 0
我在一个无状态小部件中有这个Stream订阅Geolocation.locationUpdates
浏览 1提问于2019-02-07得票数 2
它维护订阅的最后一个内部流的最后一个值，但是当外部流发出时，它只是使用最新的值作为累加器，并取消订阅最后一个内部流。return b$.pipe( ); }, init));b$: --b---b----b-
where
x =
浏览 10提问于2019-08-17得票数 2
2回答
在我们的应用程序中，我们有相当多的地方可以使用：但是对于订阅，您需要担心在某个时候取消订阅，这并不总是简单明了的。someObservable.toPromise().then(onSuccessHandler).catch(onFailureHandler);Observable.time
浏览 5提问于2016-10-06得票数 8
1回答
因此，我想设置一个流，它只在订阅时才能获得数据。如果有多个订阅，那么我希望它可以进行多播，以避免过多的api调用，并缓存最后一个已知的好消息，这样以后的订阅者就可以在不需要访问api的情况下获得数据。当有人订阅时，我希望在间隔内刷新数据。
我试着用shareReplay(n)操作符来完成所有这一切。它做我想做的一切，除了当每个人都取消订阅时，它不会从计时器中取消<
浏览 1提问于2018-03-22得票数 0
回答已采纳
我注意到，当从“入门”部分()运行Rx调试代码时，在订阅上使用disposed(by: disposeBag)时，我的资源总量并没有减少。但是，如果我保留对订阅的引用并对其调用dispose()，那么资源总数就会减少。Note：如果有关系，我在订阅的闭包中使用弱自我。
浏览 2提问于2017-06-13得票数 0
假设chick使用1500ms执行，而chicken使用300ms执行。
我如何处理这种情况？
浏览 3提问于2015-08-04得票数 3
回答已采纳
我有一个和多个订阅者。使用操作符使订阅发生在不同的线程中。我也不想使用运算符。没有理由仅仅因为异步订阅而缓存所有数据包。
浏览 11提问于2016-08-11得票数 1
回答已采纳
1回答
共享服务订阅的角度行为
、、、
the result of the ML changeRPath(path: any) { }然后从一个组件中订阅它<ng-content></ng-content>
当我按下按钮对组件1进行重定向时，我会将其描述为变量，并完成get请求。百事大吉。问题是，当我按下按钮对组件2重定向时，共享变量发生了变化，因为我在组件1上进行了描述，所以它再次执行get请求。实际上，get请求在订
浏览 0提问于2018-08-16得票数 0
回答已采纳
我必须对流进行合并才能获得加载图像的URL :一个流用于放置事件，另一个流用于文件输入更改。在每一条新的路径上，我都会加载这个图像并将其绘制到画布上。这张画布被传递到另一条溪流中。看起来是这样的：[ 'drop', 'dragover' ].forEach(function(eventName) {
Rx.Observable.fromEvent(dropTargetElement, eventName).subscribe(functio
浏览 0提问于2015-02-01得票数 5
回答已采纳
1回答
我有一个方法deleteFeedTable()，它返回一个Completable，当它完成时，我想启动另一个Disposable。我所做的是使用操作符concatWith将两者结合在一起，但这会导致嵌套订阅，我想避免这种情况。.subscribe(() -> {}, throwable -> Log.i("THROW", "loadData ", throwable)));
有什么方法可以避免嵌套<e
浏览 2提问于2018-01-04得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
