在RxJava1中执行以下操作时，onNext中的异常会重新路由到同一订阅者的onError中： }输出：D&
浏览 7提问于2017-01-25得票数 5
回答已采纳
我想运行一个新的线程，当用户点击按钮。在这个线程中，我在"i++“之后调用睡眠(2000)，并在TextView中返回字符串("Text”+ i)。super Void> subscriber) { i++;
subscriber.onNext(null
浏览 17提问于2020-12-02得票数 0
回答已采纳
在Rxjava1中，我们可以订阅一个可观察对象，如下所示：Observable<T>.subscribe(asyncSubject不知道如何在Rxjava2 Flowable中实现同样的功能？我在想像这样的事情.doOnComplete { t -> asyncSubject.OnComplete() }
.subscribe {
浏览 6提问于2019-07-23得票数 0
回答已采纳
1回答
我看了一个用MVP ()编写的安卓应用程序的例子。但是现在我想将本教程中给定的RxJava1代码重新编码为RxJava2代码。我试图改变它，我将分享我的尝试。RxJava1代码： cancelSubscription(); getView().showE
浏览 3提问于2017-01-06得票数 2
我刚刚继承了一个同时使用rxandroidble和rxjava2 (以及相关的rxandroid)的项目。之前的开发人员似乎已经摆脱了使用它们的同时，版本只是.但是，更新任何相关的依赖项都会导致各种错误。是否有一种安全(读为:稳定)的方法，让两者在同一个应用程序中共存？
浏览 1提问于2018-02-27得票数 0
回答已采纳
我使用rxjava jdbc库查询数据库，但使用rx1支持的库。io.reactivex.Observable.fromIterable(BlockingObservable.from(rx1).toIterable()); 但是它不工作，我能得到RX Java2的等效代码吗我的意思是我想返回io.reactivex.Observable<T>而不是rx.Observable<T>。 谢谢你的帮助。
浏览 70提问于2020-06-27得票数 0
回答已采纳
1回答
我有一个返回Observable的网络调用，我还有另一个网络调用，它不是依赖于第一个Observable的Rx，我需要以某种方式将其全部转换为rx。Observable<Response> responseObservable = apiclient.executeRequest(request);
在执行之后，我需要做另一个不返回Observable的http
浏览 12提问于2017-02-15得票数 4
回答已采纳
我在我的Android项目中遇到了以下问题： return id; public String getName() { }实际上，类别是由20个元素组成的。为此，products API将类别中的id作为查询参数。在获得某个目录的产品列表后，我将其添加到内部SQLite
浏览 6提问于2017-07-17得票数 0
因此，我必须在UI线程上运行一些代码(具体地说，在地图上添加一些来自coursor的标记，这些标记来自更新的数据库SELECT查询)。这是我的启动设置：resolver = sqlBrite.wrapContentProvider(mContentResolverresolver.createQuery(SmogContract.MeasurementEntry.CONTENT_URI, null, null, null, null, true);
然而
浏览 11提问于2017-02-21得票数 0
2回答
在RxJava2中引入了新的Flowable。如何在android中使用它。在RxJava1中没有可流动的。
浏览 0提问于2016-08-29得票数 10
回答已采纳
我遇到了一种情况，即长时间运行的进程被包装在Observable.fromCallable()中。此进程是一个OkHttp调用，如果终止，将引发一个IOException。如果订阅了可观察到的内容，则一次性存储在CompositeDisposable中，并按预期处理异常。但是，在某些情况下，我的代码将清除CompositeDisposable，触发OkHttp线程终止而没有错误处理，导致应用程序因未处理的异常而崩溃。下面是这个问题的一
浏览 5提问于2017-03-23得票数 0
回答已采纳
2回答
我有一个rx方法来进行api调用，该方法的调用者可以在很短的时间内多次调用。Schecdulars.io()) .subscribe(
// onNext但问题是，当我从第二次或任何特定的时间打电话时，我有时无法得到响应。onNext、onError或onComplete都不被调用。我在想，这是因为缓冲还是背压。试着用rxjava1
浏览 1提问于2017-09-14得票数 0
我要在片段的onCreate中创建展示者。我想在演示者的构造函数中订阅一个Observable。当片段的onViewCreated触发(它调用Presenter中的某个方法-即onViewReady)时，这个可观察对象应该发出。我遇到的问题是，当我创建Observable (在展示者的构造函数中)时，我也必须传递发射器。如何在构造函数中订阅可观察对象并稍后在onViewReady中发出 我试着搜索了
浏览 28提问于2019-05-28得票数 1
回答已采纳
2回答
在我看来，RxJava2通常是顺序的，除非通过并行()之类的东西来表示。counter.decrementAndGet();.subscribe();
Thread.sleep(10);}
无论我如何更改这个示例--除非我使用.toFlowable(.).parallel().runOn(.)硬核，否则不会看到doOnNext同时在不同的线程上运行。我想依赖这个特性，
浏览 1提问于2019-07-23得票数 2
回答已采纳
io.reactivex.rxjava2/rxjava
compile group: 'io.reactivex.rxjava2', name: 'rxjava', version: '2.2.16' 我开始怀疑它是在RxJava1和RxJava2之间丢弃的。如果是这样，那么RxJava2替代方案是什么呢？如果它是RxJava2的一部分，我需要在build.gradle中包含什么才能导入它？
浏览 20提问于2019-12-30得票数 1
回答已采纳
我正在尝试将rxjava迁移到rxjava2。我可以使用下面这行代码将它转换为Observable<List<Task>>。Observable.from(mCachedTasks.values()).toList()
但是，我不能在rxjava2上转换它。1-我尝试了以下代码。如何在rxjava2上将Map<String, Task>转换为Observable<List<Task>>？
浏览 0提问于2017-04-05得票数 0
我创建了下面的类来演示de problem： // RxJava2testSingleRxJava2 RxComputationThreadPool-1我不明白这个结果中的一些东西有时，输出甚至更令人困惑，而返回的内容只是：
complet
浏览 0提问于2019-06-12得票数 0
回答已采纳
我正在尝试将这个RxJava1代码转换为RxJava2 return; subscriber.onError(ioe); });问题是，在Rxjava2中，我没有让订阅者向它添加新的订阅。
浏览 2提问于2016-11-01得票数 4
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号