RxJava -我可以绕过onSuccess而只有一个onError选项吗？
RxJava是一个在Java虚拟机上实现的响应式编程库。它提供了一种基于观察者模式的异步编程方式，可以简化并发编程和事件驱动编程。在RxJava中，通过使用Observables和Subscribers来处理数据流。
对于RxJava中的Observable对象，可以通过调用subscribe方法来订阅它，并在订阅时传入一个Subscriber对象。Subscriber对象可以通过实现相应的回调方法来处理Observable发射的数据。
在RxJava中，当Observable发射数据完成时，可以通过调用Subscriber的onCompleted方法来通知订阅者。而当Observable发生错误时，可以通过调用Subscriber的onError方法来通知订阅者。
因此，对于RxJava中的Observable对象，不能绕过onSuccess而只有一个onError选项。当Observable发射数据成功时，应该通过调用Subscriber的onNext方法来传递数据，并在数据流结束时调用onCompleted方法。而当Observable发生错误时，应该通过调用Subscriber的onError方法来传递错误信息。
关于RxJava的更多信息和使用示例，您可以参考腾讯云的RxJava产品介绍页面：RxJava产品介绍
相关·内容
我正在创建一个Disposable在这种情况下，如果myObservableMethod()返回一个成功，我就不需要做更多的事情了，所以mySuccess()是一个空方法，没有任何原因而存在。我已经尝试过了：
myDisposable = myObservableMethod().doOnError(this::myError).
浏览 4提问于2018-08-18得票数 1
回答已采纳
嗨，我有一些用例，这是用Java写的，使用rxJava。我把它们转换成kotlin文件，而不是rxJava，我把它们变成了挂起函数的例程。在我的rxJava代码中，我从用例中进行了一个api调用，它返回结果，但同时onNext它做了一些事情，onError它做了一些事情。 }
data c
浏览 18提问于2021-01-13得票数 1
示例：
带回调的API调用应该在Observable call()方法中吗？如果Quickblox的onError()和onSuccess<
浏览 2提问于2015-11-18得票数 1
回答已采纳
目前，我在一个项目中从RxJava切换到Kotlin合作项目，将所有单一和可观察的返回类型替换为协同服务。我仍然在为下面的构造而挣扎:一个接口(例如存储库)提供数据查询访问，并返回一个RxJava单变量。该实现使用Single.create创建单个对象，并使用onSuccess/onError发布结果。现在，要检索数据，实现需要做的是创建一个带有回调的侦听器，并将该侦听器注册到某个内容。然
浏览 0提问于2018-10-13得票数 5
回答已采纳
我对Java、android和Rxjava非常陌生。我最近注意到，在一个现有的项目(不是我写的)中，没有收到应该收到的聊天通知。因此，我开始做一些跟踪。下面是代码的一部分。我注意到的是，我没有收到通知，onSuccess和onError没有被调用，但onComplete被调用了。然而，我发现这很奇怪，因为我认为onSuccess或onError必
浏览 15提问于2020-01-28得票数 0
我是RxJava和RxAndroid的新手，我试着理解Observable.just和Single之间的区别。看起来每个项目的设计都是为其观察者发出一个项。下面是我使用两个按钮的简单Android活动的代码。第一个按钮创建一个Observable，第二个按钮创建一个Single
findViewById(R.id.just).setOnClickListener(view -> Observable.just当我按下“单一”按钮时，只调用Sing
浏览 3提问于2017-10-12得票数 11
回答已采纳
1回答
.annotations.NonNull Disposable d) { }
public void onSuccess(@io.reactivex.rxjava3annotations.NonNull List < CountryModel > countryModels) { }
public void onError(@io.reactivex.rxjava3.annotatio
浏览 10提问于2021-12-30得票数 0
我对RxJava还很陌生，虽然我对流比较熟悉，对Javascript的承诺也比较熟悉。我正在使用RxJava处理一些现有的代码，以及一些人对这些代码所做的一些评论。在继续阅读文档的同时，我想了解更多关于这方面的背景知识。<ShippingMethodResponse>create(source -> {
source.onSuccess(getProductOneowShippingMethodResponse我想这是
浏览 2提问于2018-05-23得票数 0
1回答
我正试图为硬件设备创建一个通信控制器，该设备总是以一定的延迟响应。如果我只请求一个值，我就可以创建一个Single<ByteArray>并在.subscribe{ ...}中完成最后的转换。但是，当我请求多个值时，我需要确保第二个请求发生在第一个请求完全关闭之后。
这就是我可以用RxJava做的事情吗，例如？或者我应该自己创建
浏览 0提问于2019-06-24得票数 1
回答已采纳
2回答
总的来说，我对RXJava还比较陌生(实际上只是在RXJava2中才开始使用它)，而且我可以找到的大多数文档都是RXJava1；现在我通常可以在两者之间进行转换，但是整个反应式的东西都是如此之大，以至于它是一个强大的API，有很好的文档(当您可以找到它时)。我正在努力简化我的代码，我想用婴儿的步骤来完成它。我想要解决的第一个问题
浏览 6提问于2017-04-11得票数 12
回答已采纳
.annotations.NonNull Disposable d) {
public void onSuccess(@io.reactivex.rxjava3annotations.NonNull List<CategoriesModel> categoriesModels) {
public void onError.annotations.NonNull Disposable d) {
@Over
浏览 4提问于2022-03-19得票数 0
我目前正试图在我与RxJava的网络中实现RxJava。我一直在使用Consumer的子类，但是对于RxLifeCycle，您需要处理onError。所以我搬到了Observer。这方面的问题是，当调用被释放时，它调用的是onComplete而不是onError，我更喜欢这一点。buildle.gradle: compile 'io.reactivex.<e
浏览 0提问于2017-12-08得票数 0
回答已采纳
我在一个扩展了Observable.OnSubscribe的volley请求上有一些监听器，我想在到达这些方法时使用rxjava发出一条消息。void onSucess() { // need to call call() // How can i call this method fr
浏览 2提问于2016-01-14得票数 1
1回答
Context：我的当前应用程序使用普通的retrofit calls从api获取数据。我真的很想把RX引入到呼叫中，但是我没有太多的经验。我在网上读了一些东西，但都没有给我一个简单的方法。我给你看看我有什么。这是我的代码:fun <T> performCall(call: Call<T>?Log.d(&quo
浏览 1提问于2019-03-16得票数 0
4回答
在我的安卓应用程序中，我使用的是领域和RxJava，我想通过传递一个新的值来更新一个对象。我用realm.executeTransactionAsync()来做这个。但我希望订阅此事件，以便在我使用此方法的类中进行错误处理。.setAge(age), subscriber::onError);
浏览 3提问于2016-11-23得票数 0
回答已采纳
1回答
我正在学习android上的RxJava，并且在我的应用程序上实现了MVP模式。我在rest API上使用RxJava，从模型和模型到展示者，从展示者，我想知道我是否也应该实现从展示者到视图(活动/片段)的RxJava？或者我应该更喜欢普通的接口方法？此外，还有关于何时使用RxJava以及何时不使用的指导原则。另外，如果在视图中实现RxJava是很好的，那么有没有一种方法可以</e
浏览 1提问于2017-10-27得票数 0
我发现了RxJava在的一个很好的例子 @(new Action1() { public void call(String value) { @Override
public voi
浏览 0提问于2016-04-28得票数 1
回答已采纳
我正在尝试编写一个林特规则，以捕捉RxJava2函数的结果不被使用的地方。::onError);}
搜索返回带有io.reactivex.annotations.CheckReturnValue注释的方法的结果的表达式。(th
浏览 0提问于2018-04-04得票数 3
1回答
Coroutines and RxJava3 我有以下方法，首先调用suspend方法，然后在相同的启动范围内调用RxJava。我想知道是否有一种方法可以将Rxjava代码从viewModelScope.launch作用域中移除并返回fetchRecentUseCase.execute()的结果。基本上，viewModelScope.launch是否有可能返回listOfProducts，而不是在启动范围内执行所有操作？}
.observ
浏览 45提问于2021-08-03得票数 0
回答已采纳
我有一个API服务类，它的方法返回Retrofit提供的调用。最近，Rx2Java引入了单机，所以我想改变对单机的调用，但我不想改变逻辑。例如：@GET}@GET是否有任何方式可以将单曲转换为“喜欢”：我想详细描述一下我的问题。 @GET
Call<Respon
浏览 1提问于2018-12-07得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
