Observable<void>不调用订阅者
是指在使用Observable模式进行编程时，创建了一个Observable对象，但没有调用订阅者来订阅这个Observable对象。
Observable是一种用于处理异步数据流的编程模式，它可以将数据流和事件进行抽象和处理。在Observable模式中，有三个角色：Observable（被观察者）、Observer（观察者）和Subscription（订阅关系）。
Observable<void>表示创建了一个Observable对象，该对象不会传递任何值，只会发出一个完成信号。这种Observable通常用于表示某个操作的完成状态。
订阅者是通过调用Observable对象的subscribe()方法来订阅Observable对象的。订阅者可以定义在Observable对象发出值或完成时执行的操作。
如果Observable<void>不调用订阅者，那么订阅者将无法接收到Observable对象发出的值或完成信号。这意味着订阅者无法对Observable对象进行响应式处理。
在实际应用中，Observable<void>不调用订阅者可能是由于以下原因：
- 程序逻辑错误：可能是由于代码中的错误导致忘记调用订阅者。
- 异步操作未完成：可能是由于异步操作还未完成，导致没有调用订阅者。
在使用Observable模式时，建议始终调用订阅者来订阅Observable对象，以确保能够正确处理Observable对象发出的值或完成信号。
腾讯云提供了一系列与Observable模式相关的产品和服务，例如腾讯云函数（SCF）和腾讯云消息队列（CMQ）。您可以通过以下链接了解更多关于腾讯云函数和腾讯云消息队列的信息：
- 腾讯云函数（SCF）：https://cloud.tencent.com/product/scf
- 腾讯云消息队列（CMQ）：https://cloud.tencent.com/product/cmq
相关·内容
2回答
我不需要observable来返回任何数据，我只想让它调用订阅者，作为注销完成的信号。 问题是我的单元测试显示订阅者实际上从来没有被调用过。它应该报告“期望clearSession()被调用1次，结果是0” 所以我运行Jest只是为了看看发生了什么，然后我得到了： FAIL src/app/auth/auth.service.spec.ts
浏览 12提问于2020-04-27得票数 4
我想在defer中调用观察者的onNext方法，有没有好的方法呢？举个例子- @Override } catch (Exception e) { }});
Observable
浏览 3提问于2017-01-18得票数 1
我想知道是否有可能向不同的订阅者发送消息，使它们在不同的线程上运行？IObserable如何控制它？简单的主题实现，据我所知，它在一个线程上一个接一个地调用订阅者。} { } {
public static class Pr
浏览 3提问于2011-10-19得票数 5
回答已采纳
我正在对api调用api.java使用改进：Observable<Profile> getProfile(); 1)如果有人首先订阅了observable，那么在开始时调用API请求，结果(配置文件)将在订阅者处可用。2)如果其他人订阅了observable
浏览 9提问于2017-12-13得票数 3
我想要一个不做任何事情的Observable，当订阅时，会调用观察者的onNext回调函数。我想我在Observable.empty()中发现了这一点，但是下面的代码并没有导致观察者的onNext回调被调用：emptyObservable.subscribe(passedinObserver);
浏览 0提问于2015-03-13得票数 0
2回答
重用订户
、、
在RxJava中，我有一个Subscriber对象，我在Observable上订阅。稍后(在调用onComplete()之后的一段时间)，我创建了一个新的Observable，并使用以前使用的Subscriber实例进行订阅。然而，这似乎行不通。订阅者不能重用吗？示例： Observable</em
浏览 3提问于2015-04-02得票数 5
回答已采纳
我有一个和多个订阅者。使用操作符使订阅发生在不同的线程中。我也不想使用运算符。没有理由仅仅因为异步订阅而缓存所有数据包。
浏览 11提问于2016-08-11得票数 1
回答已采纳
我正在尝试压缩两个观察值，在本例中是一个计时器任务和一个实际任务，以便只有当这两个任务都完成时才会调用我的订阅者。我想用Observable.zip来做这件事，但不知何故这并不起作用，而且我的Observable.timer没有调用onComplete()。这意味着订阅者永远不会同时获得两个Observables的结果。
当我突然将zip更改为merge时，Observable.timer确实调用了onComplet
浏览 10提问于2016-09-26得票数 2
回答已采纳
一个可观察的人是多重价值的生产者，把他们“推”给观察者(消费者)。订阅一个可观察到的函数类似于调用一个函数。要调用可观察到的数据，我们应该从可观测对象本身调用subscribe()函数，并将观察者作为可观测对象传递的数据的使用者传递，例如： const id = setInterval(() => {
subscribe
浏览 1提问于2021-04-04得票数 6
回答已采纳
第一次尝试(不进行铸造)
属性'Symbol.observable‘在类型'{ x: string：() => { x: string：((观察者:观察者) => {取消订阅()：void；}’)( => () => { x: string：((观察员:观察员)=>{un订阅()：void；}) .；订阅(观察者:观察者)：{.；}；})；订阅</
浏览 1提问于2020-05-14得票数 3
回答已采纳
2回答
我正在创建一个可观测的，它在订阅时发出整数。我现在的实现已经设置好了，所以订阅它的行为从一开始就触发了生成，如下所示： return Observable.create( public void call我希望无论订阅
浏览 5提问于2015-12-02得票数 7
回答已采纳
1回答
总之，如果我能创建这样一个方法是很好的：
ReplaySubject似乎有我想要的一些属性，但我不知道如何正确地实现它。
浏览 4提问于2016-11-28得票数 1
回答已采纳
问题当用给定的数据调用Observable.of时，HttpClient应该将数据返回给已经订阅它的方法。回答模拟数据(意思是不允许请求通过网络)，mock.service在app.component中有一个订阅
浏览 3提问于2017-12-04得票数 0
回答已采纳
发现在主题上调用onNext事件后10-20ms内订阅序列化的PublishSubject时，新订阅者的onNext不会被调用。在下面的代码片段中，observe1的值被指定为" 2000“，并且在对值为1998 2的主题调用onNext()后调用subscribeToSubject()；我们可以看到，如果间隔是10ms，新订阅者将错过由主题激发的值2000；而如果间隔是50ms或更长，则新订阅者<
浏览 5提问于2019-02-20得票数 0
回答已采纳
我有一个观察者和PublishSubject，他们是订阅的。我尝试使用subscribe和subscribeWith都不起作用，因为类型不兼容。你能建议我如何将此订阅添加到CompositeDisposable吗？public Observable getObservable() {}
PublishSubject<Object> subjectnew CompositeDisposable
浏览 94提问于2021-05-05得票数 0
2回答
我正在尝试制作一个反应性的RabbitMQ侦听器，它允许我们使用多个订阅者处理每条消息。只有当所有订阅者成功完成时，我们才希望ack消息。-> observable.delay(3, TimeUnit.SECONDS)) .refCount();public void subscribe(Acti
浏览 6提问于2016-08-18得票数 0
我们的项目的RxJava订阅者是这样创建的：
不幸的是这不起作用。订阅者永远不会接到电话，我们也不会收到错误或更多的信息。但是，如果没有使用参数订阅服务器，并且我同时创建了一个全新的
浏览 2提问于2016-04-12得票数 0
回答已采纳
, FINISHED一些可调用的，将检索正确的阶段，我应该能够通过可调用和谓词检查是否stage == FINISHED，并轮询，直到我得到FINISHED事件。在这种情况下，可观察对象应该继续轮询事件，直到它接收到与谓词匹配的事件，或者直到它没有更多的订阅者。这一可观察到的情况应：
如果它从>0订阅者变
浏览 0提问于2018-05-17得票数 0
最近，我需要在一个函数中取一个观察者参数，然后我把头撞到我的桌子上，想找出如何在打字稿中这样做。您可能还记得在C#中使用了一个C#参数；这基本上就是我在这里试图做的。我之所以这样做，是因为我试图为订阅添加AOP类型的书签端。这不是重要的部分。如果没有|后面的部分，我就会得到以下错误：
类型'(res: any) => void‘的参数不能分配给’观察者‘类型的参数。属性'next‘在类型'(res: any) => void’中缺失。在之后添加管道字符和部分之后
浏览 2提问于2016-12-22得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
