你好， getInfo()服务调用是由多个片段同时订阅的，所以我只想调用服务一次，存储信息并返回它。我通过使用blockingGet()找到了解决方案 addDisposable(getInfoUseCase().get() @Query(SERVICE_ID) String serviceId
); 乍一看，一切都很好，但后来我发现了这个答案： never use observ
浏览 39提问于2020-08-13得票数 0
我试图以同步的方式调用RxJava，但是这样做会导致阻塞主线程。@Override return getSettings().blockingGet(.subscribeOn(Schedulers.newThread())}
但它仍然被屏蔽了。如果我做错了什么，我将非常感谢你<
浏览 1提问于2017-10-07得票数 8
我已经尝试理解rxJava Observable一天多了，但我就是想不出我的案例需要什么。我想，因为我不是在创建一个Observable，而只是从API调用中返回一个，并且我需要Observable类型的类，所以我可以使用该类的对象属性。下面是我的代码，但是当我运行print语句时，它会被完全跳过。如何使用包装在观察者中的对象属性？.rx.Observ
浏览 18提问于2019-10-25得票数 0
我正在尝试使用来自thesportsdb的API来显示来自特定联赛的最后一场比赛。在我的回收视图中，我想要显示每个团队的团队徽章，但当我请求lastmatch API时，它没有包括团队徽章，只有每个团队的id，如果我想显示徽章，它要求我请求包括团队徽章的url的团队简介。因为我是rxJava的新手，所以我对它还比较熟悉。一些帖子建议使用平面地图，但对于像我这样的初学者来说，实现它有点困难。) {
compositeDispos
浏览 0提问于2018-09-01得票数 1
1回答
我一直在寻找新的rx java2，我不太确定我是否已经理解了backpressure的想法…… .subscribe(new Consumer<Long>() {Exception {
/
浏览 19提问于2016-10-30得票数 146
回答已采纳
如何在安卓系统中每一秒使用RxJava更新UI？我想做这样的事： rx.Observable.just(getSleep()).subscribeOn(Schedulers.newThread())
浏览 3提问于2016-11-10得票数 3
回答已采纳
我有一个上传音频文件列表到Firebase实时数据库的功能。每次成功上传文件都会返回一个downloadUrl，我将其存储在一个list中，直到递归停止。是否可以将此函数包装在RxJava中以返回Single<List<String>>
fun uploadAudioList(list: MutableList<Audio>, userId: String
浏览 0提问于2019-02-13得票数 0
我使用rxjava jdbc库查询数据库，但使用rx1支持的库。rx.Observable<T> rx1 =Database.from(url, user,password).autoMap(resultType); 我正在尝试将其转换为 io.reactivex.Observable.fromIterable(BlockingObservable.from(rx1).toIterable()); 但是它不工作，我能得到RX Java2的等
浏览 70提问于2020-06-27得票数 0
回答已采纳
1回答
我有这样的代码： compositeDisposable.addviewModel.getTaskConditionByChapterIdAndTaskId(chapterId, taskId) .observeOn(AndroidSchedulers.mainThread我<
浏览 9提问于2022-10-04得票数 0
我在RxJava方面非常初级，如果我选择了一个糟糕的方法或者有更好的方法，我需要帮助找到一个更好的方法。 try { } }回到Curr
浏览 3提问于2017-01-30得票数 1
我有两个稍微不同的问题课。一个是更新调用结果对象，另一个是我的Android应用程序中的Room @Entity。现在，我希望从Interactor类(用例)中执行以下操作：
成功后，在“我的房间”数据库中创建一个新的游戏对象。转换器方法接受两个参数，retrofit.Question对象和步骤(2)中返回的ID。转换后，添加到数据
浏览 0提问于2019-04-08得票数 1
回答已采纳
1回答
我使用okhttp作为我的http客户端，它支持身份验证，但问题是，在身份验证方法中，我必须返回一个包含新访问令牌的请求对象。要做到这一点，首先我必须等待api调用来使用我提供的刷新令牌检索新的访问令牌，如您所知，这个过程需要一段时间才能完成。 val newToken = getTokenFromServer()?.第一次协同器尝试
浏览 4提问于2021-06-17得票数 0
回答已采纳
当需要在Rx操作链中执行一些异步操作时： return Single.just1) }
有没有可能在没有flatMap或blockingGet的情况下编写Rx chain
浏览 46提问于2020-05-22得票数 2
1回答
下面的代码包装在AsyncTask类中 mIndicatorTable.sync().blockingGetfinal MobileServiceList<IndicatorModel> results = mIndicatorTable
浏览 1提问于2017-02-21得票数 1
回答已采纳
4回答
我正在尝试在Rx3中找到subscribeOn的主线 .subscribeOn(Schedulers.io()) }
浏览 0提问于2019-10-16得票数 5
我的应用程序的Room数据库封装在一个Schedulers.io()数据访问层中，该层修改所有的Singles、Maybe等，使之成为AndroidSchedulers.mainThread()调度程序的());现在，我的应用程序中有一部分需要从数据库中同步检索元素。我的设计没有预料到这一点。当我执行#blockingGet()时，我会得到死锁，这是我在其他问题(如 )中所读到的。--
在我的
浏览 0提问于2019-05-23得票数 1
回答已采纳
2回答
在大多数情况下，getChannels是在getEPG之前完成的，我可以将EPG连接到通道。但是，我想处理在getChannels之前完成getEPG的情况。换句话说，
和Single都是并行运行的。要连接EPG，必须加载通道。我如何在不依赖回调和while循环的情况下完成这一任务？我想应该有一种反应的方法来处理这个案子。提前谢谢。
浏览 3提问于2020-03-02得票数 0
我在我的oncreate中有一个可以观察到的，我想在我的主线程上得到结果。但是，由于AndroidScheduler.mainThread只使用可观察到的Java，所以我无法编译它。这是密码val a=Observable.from(L).observeOn(AndroidSchedulers.mainThread()).subscribe(i=>println(i))
这里的“a”是一个可观察到的rx.sc
浏览 2提问于2014-12-16得票数 5
回答已采纳
我的问题是加载具有不同类型的项目，然后按类型对其进行排序。val type: ProType, val profiles: ArrayList<ProImpl>)我的代码： .flatMap {
浏览 2提问于2019-03-20得票数 0
回答已采纳
1回答
我是Rx Java的新手，我在这里已经看到这个问题被回答了很多次，但是给出的答案似乎对我不起作用。2018-12-04 10:51:03.072 17083-17227/com.test.test.mybooks E/AndroidRuntime: ... 26 more
我有一个通过我的视图模型检索的书籍列表、使用rx并在活动中观察来检索图书。当我返回并返回到之前的活动/片段时，如果我拉到刷新，我会得到上面的错误。这仅在从deta
浏览 0提问于2018-12-04得票数 1
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号