当我设置了subscribeOn(Schedulers.io())时，RxJava调用返回NetworkOnMainThreadException

文章/答案/技术大牛

发布

1回答

android、rx-java2

根据我对RxJava的理解，sendMessage()必须在后台io线程上执行，其结果可以在Android主线程上看到。然而，无论如何，sendMessage()方法似乎是在安卓主线程上运行的，我的应用程序因为android.os.NetworkOnMainThreadException而崩溃(我在catch (e: ExceptionSingleTransformer<T, T> { observable .<

浏览 37提问于2019-01-31得票数 0

回答已采纳

2回答

在RestClient中，RxJava与Android中的可观察性不太好。

java、android、gradle、rx-java

使java.lang.IllegalArgumentException:无法为rx.Observable for method ApiInterface.login创建调用适配器时，我正在使用RestClienthit with Observable (RxJava) RestClient.getApiInterface().login(commonParams.getMap())

浏览 0提问于2017-06-29得票数 0

回答已采纳

4回答

Android上rxjava的默认调度程序

java、android、multithreading、retrofit、rx-java

我使用Retrofit来返回rxjava可观察到的异步网络调用。我发现自己重复了以下调用：似乎我总是订阅有办法通过默认的subscribeOn和observeOn线程来删除这个样板吗？我可以通过干扰在网络边界上设置默

浏览 5提问于2014-07-16得票数 15

回答已采纳

5回答

背景中的AndroidRX运行方法

android、android-asynctask、rx-java

我创建了带有无限进度条的简单活动，我试图使用RxJava运行耗时方法，以防止UI线程阻塞，但每次UI线程都被阻塞。我认为我的解决方案有问题，发射可观察。有谁可以帮我？我是RX的乞丐。setContentView(R.layout.activity_main); doHeavyStuff() .subscribeOn

浏览 5提问于2015-07-19得票数 20

回答已采纳

1回答

然而，还有其他与这个模拟的交互：

android、unit-testing、rx-java、retrofit2、mvp

= service.login(phone,password) .subscribeOn(Schedulers.io()) //Log.d("Login", new Gson().toJson但我明白了：loginVi

浏览 4提问于2017-01-13得票数 1

回答已采纳

0回答

重新运行retrofit2 rxjava Observable

rx-java、observable、retrofit2

给定一个类似如下的通用Retrofit2 Rxjava调用：.subscribeOn(Schedulers.io我认为像这样的东西可以做到这一点(只需要订阅就可以了，但我添加了取消订阅以防万一)： .

浏览 4提问于2016-07-03得票数 0

2回答

用于执行异步工作的RxJava循环

android、rx-java、rx-android、rx-java2

我正在使用库，我想用RxJava压缩图像。以下是库文档中的示例。new Compressor(this) .subscribeOn(Schedulers.io我尝试在for循环中添加此方法，但返回的列表为空，因为accept方法甚至没有调用一次，并且代码到达了return语句。更改此方法，以便accept方法仅在所有文件都已压缩且列表已填满时触发？我试着搜索<e

浏览 0提问于2017-10-10得票数 0

1回答

使用RX可观测值并行调用多个REST

asynchronous、java-8、rx-java、microservices、reactive-programming

我试图使用可观测数据并行调用REST。在这方面，我正面临一些问题。我在这里描述了问题。有人能帮我吗？我的用例是，我有5个customerid，我需要通过并发传递这个用户id来调用另一个REST来获得响应。我尝试了3下面的选项。但我觉得，它们都提供了相同的响应时间。我看不出所有这些电话的响应时间有什么不同

浏览 2提问于2019-02-17得票数 1

1回答

RxJava subscribeOn和observeOn以前没有覆盖原始计划程序集吗？

android、rx-java

我在android中使用了RxJava和Retrofit 2，并且在订阅()之前调用了subscribeOn(Schedulers.io())、android observeOn(AndroidSchedulers.mainThread但是，有时我想调用subscribeOn(Schedulers.immediate()) android observeOn(Schedulers.immediate())来覆盖之前设置的调度器以获得同步进程

浏览 1提问于2016-02-27得票数 5

回答已采纳

2回答

轮询服务器应答，n次后失败返回异常

java、rx-java、rx-java2

我正在尝试使用RxJava2库创建一个服务器调用，它将尝试轮询服务器以获取应答，如果连续接收到异常3次，则返回该异常final Observable<ResponseValue} .retry(3)

浏览 0提问于2019-01-21得票数 0

2回答

如何使用rxJava正确调用改造服务？

java、android、kotlin、rx-java

我正在努力理解rxJava，我正在寻找一位专家或有经验的人来尝试解决我的问题，问题是我已经使用RxJava一年了，但只针对Retrofit调用，我一直在使用Disposable，并做了一些类似的事情：myService.myInterface.getData() .subscribeOn(Schedulers.io())

浏览 0提问于2019-05-06得票数 0

1回答

我是使用可观察的(RxJava2)还是调用(retrofit2)？

android、retrofit2、rx-java2

TL;DR:我想执行多个Calls (Retrofit)，就像您可以.zip()多个Observables (RxJava2)一样。public void onFailure(Call<JsonObject> call, Throwable t) { }现在，我希望一次执行多个Call(获得多个书名)，并在完成所有请求时得到通知(@Query("id") String id, @Query("lang") String lang); 然后合并下面示例中的调用。merge resp

浏览 1提问于2019-08-29得票数 5

回答已采纳

1回答

为什么要在RxJava中的每个可观察方法中使用subscribeOn

android、rx-java、rx-java2、rx-android

在试图理解本例中的RxJava时，我发现了这一点pr

浏览 2提问于2018-10-27得票数 0

1回答

RxJava 2.x -由PublishSubject触发并与其他可观测对象合并的可观察对象获取flatMap不会被订阅/执行

android、rx-java2

在ViewModel中，这是以直接的方式使用的： interactor.stateObservable() .subscribeOn(Schedulers.io(firstPage和refresh (也是在PublishSubject的帮助下触发的)工作得很好，但是由于某些原因，分页解决方案需要在flatMap中返回getPage Observable，但是这个页面Observable永远不会被触发/订阅，flatMap之后的doOnNext显然也不会被调用。我已经在<em

浏览 16提问于2019-10-07得票数 1

回答已采纳

1回答

RxJava应用程序中线程、CompositeDisposable和Scheduler的问题

java、android、multithreading、rx-java、rx-java2

(Schedulers.io()) . .在RxJava的RxThreadFactory类和newThread()方法中有一行t.setDaemon(true)，那么所有RxJava线程都是守护进程线程吗？--我正在将订阅()的一次性返回添加到compositeDisposable中，并在服务/活动类的onDestory()中

浏览 1提问于2020-06-25得票数 0

回答已采纳

4回答

在android上使用rxjava的android.os.NetworkOnMainThreadException

java、android、rx-java

我在实现rxJava时遇到了问题，为了检查安卓系统上是否有互联网连接，我是这样做的：AndroidObservable.bindActivity(this, .subscribeOnactiveNetwork) { }

浏览 0提问于2014-12-29得票数 12

1回答

在新线程上使用Rx java解决Spring中的本地化问题

java、spring、multithreading、locale、rx-java

我正在尝试使RxJava适应现有的Spring项目。我的目标是异步提供WS REST调用(我知道@Async，但让我们忽略这一点)。 customerServiceService.getPrintableByCustomerLogin(username) .subscribeOn如果我省略了.subscribeOn

浏览 5提问于2016-06-14得票数 0

回答已采纳

1回答

RxJava单间错误处理问题

android、exception-handling、rx-java、android-room、rx-android

我有这个问题的空数据库返回房间和RxJava单。我知道我的数据库是空的，所以我希望在触发时得到一个空的返回fun getTimes(timestamp: String): Single<Times>timeDao.getTimes("1398332113")

浏览 43提问于2018-10-28得票数 4

回答已采纳

1回答

Retrotif2 + RxJava发送POST请求失败

http-post、retrofit2、rx-java2

我想用Retrofit + RxJava发送POST请求，但它失败了，我不知道原因。info attempt failed. " + exception.getMessage()); }.subscribeOn(Schedulers.from(threadExecutor))尝试使用此命令，但没有效果： .subscribeOn</

浏览 45提问于2018-08-24得票数 0

回答已采纳

6回答

Rxjava2 just方法-如何在另一个线程上运行房间插入？

android、rx-java、android-room

下面是我如何定义我的数据库：我正在尝试使用rxjava2countriesList) { .subscribeOn(Schedulers.io()) .obse

浏览 73提问于2017-06-16得票数 20

回答已采纳

点击加载更多