但是当我尝试执行我的代码时，尽管我使用了Schedulers.io()线程，我还是得到了NetworkOnMainThreadException。 }
repository.downloadImage(password, hashMapOf("username" to login)).subscribeOn(Schedulers.io
浏览 21提问于2019-08-16得票数 0
我们是否需要指定要取消订阅的线程，即使该线程与subscribeOn中使用的线程相同？mSubscription.add(myAppProvider .subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
.unsubscribeOn(
浏览 1提问于2016-11-09得票数 8
为什么doOnSuccess即使在设置了observeOn(Schedulers.io)之后也能触摸到observeOn(Schedulers.io).observeOn(Schedulers.io
浏览 4提问于2022-04-26得票数 1
回答已采纳
todayDataEntrySingle = openWeatherApi.getTodayData( "London,uk", FetchDataUtil.API_KEY).subscribeOn(Schedulers.io());
浏览 0提问于2018-07-24得票数 2
我正在使用此的更新版本将活动链接(绑定)到服务。bindService(intent, serviceConnection, BIND_AUTO_CREATE); }如果我使用observeOn(AndroidSchedulers.mainThread())，我得到NetworkOnMainThreadException，如果我使用observeOn(Schedulers.newThread我知道这两个错误意味着什么，在正
浏览 2提问于2019-03-07得票数 0
回答已采纳
1回答
在我的项目中，我需要处理不同线程中的对象。apiService.getObjects(token) // Retrofit .subscribeOn(Schedulers.io.map(Observable::just) // create new one, to change thread for it
.observeOn(Schedulers.io</e
浏览 1提问于2015-09-28得票数 5
回答已采纳
我非常理解订阅的概念( subscribeOn下面的任何代码都将在该特定线程中执行)，并在rxandroid/rxjava中观察(与subscribeOn相同)。我想要做的是在后台线程中执行长io操作，然后在操作完成时通知主线程。为此，我正在考虑在Schedulers.io()中订阅一个subscribe，然后在AndroidSchedulers.mainThread()中观察一个subscribe，如下所示： .sub
浏览 5提问于2016-08-25得票数 0
emitter.onSuccess(someValue)} someOtherSingle(it) // Executes on main thread.subscribeOn(Schedulers.ioobserveOn(AndroidSchedulers.mainThread())ThirdPartySDK.doSomeAction回调在主线程上发布，因此发射器也会在主线程上发出，而不是在订阅线程上发出(如果我
浏览 8提问于2020-06-04得票数 0
回答已采纳
我有一个长时间运行的手术(一个可以观察到的)。我想要实现的是一个可以观察到的：
当所有订阅者取消订阅时，下一个订阅者仍应附加到已经长期运行的操作(除非已完成)。在指定的时间之后，一切都重置，回到原点。现在，我的长时间运行操作被包装在一个可观
浏览 1提问于2016-02-15得票数 0
我的代码是不言自明的，所以不会提供更多细节e1={ "last_name":"panwar", "about": "Love to play cricket",
"interests": ['sports','music']
浏览 11提问于2019-10-23得票数 0
在我的Android项目中，我做了很多网络请求(使用Retrofit和RxJava)，这些请求作为响应返回一个自定义的超级响应类型，它可以由一个有效的或错误的响应组成。对于所有网络请求，大约有4-5个错误代码是相同的，例如会话被超时了。因此，我将编写一个泛型方法，检查这些错误代码的所有响应，并设置对策，比如请求一个新会话。首先，我考虑使用OkHttp拦截器，但由于我需要将结果解析为适当的格式，所以不能使用它。在解析结果之后，我使用Rx
浏览 1提问于2016-02-09得票数 2
回答已采纳
1回答
()调用的，但是log语句显示.flatMap()内部的代码运行在主线程上：
我再次清理了构建，然后关闭并打开了
浏览 0提问于2018-01-17得票数 2
我正在使用带有RxJava/RxKotlin Flowable的房间，下面是this的文章。我让它运行了，但在ViewPager中使用它时遇到了问题，它有3个片段。前两个片段包含可以添加到收藏夹的数据列表。 在favorite fragment中，我使用Flowable来监听A和B所做的更改，并相应地更新列表。但是，当项目在A和B中成为收藏时，应用程序崩溃，因为收藏片段中的可流动订阅即使在片段不在前台时也会
浏览 104提问于2018-08-03得票数 0
回答已采纳
我在我的安卓应用程序中使用RxJava，它多次碰到OutOfMemoryError。因此，我搜索并发现，Schedulers.io可以创建无限的线程。当我用Schedulers.computation替换每个Schedulers.computation时，问题就消失了，但这是没有意义的，因为我使用Schedulers.io就像它应该使用的那样。那么我如何使用Schedulers.io并确保它不会创建太多的线程呢？更新
浏览 5提问于2015-07-08得票数 6
回答已采纳
我有一个一次性的，在某个时间间隔内执行对API的请求。add(it) } } .observeOnadd(disposable)override fun onBackPressed() { disposablesdispose()但是，它没有被清除，我在中
浏览 1提问于2018-04-20得票数 0
回答已采纳
我只是尝试在Java脚本中使用getter和setter方法，我编写了以下代码 var Circle = functiondocument.write("A circle with radius " + circ.radius + " Have an area of " + circ.area);所以我在浏览器中得到了这个输出A
浏览 5提问于2017-02-20得票数 1
回答已采纳
1回答
我有一个加载页面，在该页面中，我希望对不相关的信息执行两个网络请求(追溯器2-rxjava)。我不想继续到下一页，直到这两个请求完成，即使其中一个或两者都失败。使用zip将请求绑定在一起。是否有一种不强制使用BiFunction而不必返回null的方法？
浏览 0提问于2019-01-18得票数 0
回答已采纳
2回答
我已经试了几天了，代码现在看起来更易读了，但遇到了一个我似乎找不到解决办法的问题。我正在尝试执行一次登录(这将返回一个API令牌)，然后使用这个令牌来获取同一链中的一些初始数据，这样链的输出就是令牌+数据。为了做到这一点，我用 .login() .observeOn(AndroidSchedulers.mainThread所以我也给它添加了一个.doOnSubscribe()和一个.doOnUnsubscribe()。然
浏览 31提问于2015-12-13得票数 16
1回答
然而，还有其他与这个模拟的交互：
、、、、
service.login(phone,password) .subscribeOn(Schedulers.io但我明白了：loginView.hideProgress();
-> at hos.wellhos.com.hosapps.login.LoginPresenterTest.clickBtnLogin
浏览 4提问于2017-01-13得票数 1
回答已采纳
2回答
无论UI订阅与否，对ModelProvider.update的调用都应该保持对模型的更改。but need it to execute exactly once }我正在移动一个代码库，以使用RxJava和反应性模式，因此对repository.save(model)的调用是同步的，但是仍然需要逻辑来精确地执行一次之后，无论是否有UI订阅者。());}
但这迫使IO在主线程上工作，并阻止它。(
浏览 1提问于2016-10-20得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
