- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我有一个 Button
我从中创建了一个 Observable<OnClickEvent>
.
单击按钮时,我希望从网络中获取文件,但我遇到了有关网络和线程的问题。
这个例子抛出 android.os.NetworkOnMainThreadException
:
Observable<OnClickEvent> networkButtonObservable = ViewObservable.clicks(testNetworkButton);
networkButtonObservable
.map(new Func1<OnClickEvent, List<String>>() {
@Override
public List<String> call(OnClickEvent onClickEvent) {
return TestAPI.getTestService().fetchTestResponse();
}
}
)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Object>() {
@Override
public void call(Object o) {Log.w("Final result: " + o);
}
}
);
所以我从另一个线程尝试。
以下抛出 rx.exceptions.OnErrorNotImplementedException: Observers must subscribe from the main UI thread, but was Thread[RxNewThreadScheduler-1,5,main]
:
networkButtonObservable
.subscribeOn(Schedulers.newThread())
.map(new Func1<OnClickEvent, List<String>>() {
@Override
public List<String> call(OnClickEvent onClickEvent) {
return TestAPI.getTestService().fetchTestResponse();
}
}
)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Object>() {
@Override
public void call(Object o) {Log.w("Final result: " + o);
}
}
);
好的..现在我尝试使用 .debounce()
一开始:
networkButtonObservable
.debounce(10, TimeUnit.MILLISECONDS)
.map(new Func1<OnClickEvent, List<String>>() {
@Override
public List<String> call(OnClickEvent onClickEvent) {
return TestAPI.getTestService().fetchTestResponse();
}
}
)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Object>() {
@Override
public void call(Object o) {Log.w("Final result: " + o);
}
}
);
这就成功了。
显然我不喜欢在我的代码中添加延迟,所以我试图弄清楚线程方面发生了什么。为什么第一个示例不执行 .map()
中的代码在后台线程中?
或者我在这里缺少什么?
---更新
我更改我的 TestAPI 以返回一个 Observable,并将对 networkButtonObservable 的第一次调用更改为 .flatMap()
.这也能正常工作。但我仍然不知道为什么原来的方式使用.map()
应该会失败。
networkButtonObservable
.flatMap(new Func1<OnClickEvent, Observable<?>>() {
@Override
public Observable<?> call(OnClickEvent onClickEvent) {
return TestAPI.getTestService().fetchTestResponseObservable();
}
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Object>() {
@Override
public void call(Object o) {Log.w("Final result: " + o);
}
}
);
最佳答案
我不是 Android 方面的专家,但根据错误消息,我认为您需要在主线程和后台线程之间反弹值。通常,Android 示例会向您展示如何将 subscribeOn
/observeOn
对添加到您的流处理中:
Observable.just(1)
.map(v -> doBackgroundWork())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(v -> {});
但在这些情况下,“源”通常是您可以控制的冷可观察量。
在你的问题中,源是一个热的Observable
,你需要在主线程上订阅特定的要求,但你需要在后台线程上进行网络调用,然后显示结果在主线程上。
在这种情况下,您可以多次使用observeOn
:
networkButtonObservable
.subscribeOn(AndroidSchedulers.mainThread()) // just in case
.observeOn(Schedulers.io())
.map(v -> TestAPI.getTestService().fetchTestResponse())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(v -> updateGUI(v));
我认为 fetchTestResponseObservable
有自己的 subscribeOn
或 observeOn
应用于它,因此它不会抛出网络异常。
我还想提一下,使用多个 subscribeOn
在功能上等同于仅使用一个最接近发射源的订阅,但从技术上讲,它会占用未使用的线程资源。然而,在流中使用多个 observeOn
具有相关性,因为您可以有意义地“管道化”线程之间的流处理。
关于android - RxAndroid ViewObservable NetworkOnMainThreadException,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30482465/
这个问题在这里已经有了答案: How can I fix 'android.os.NetworkOnMainThreadException'? (66 个回答) 关闭2年前。 我刚刚发现 Networ
这个问题在这里已经有了答案: How can I fix 'android.os.NetworkOnMainThreadException'? (65 个回答) 7年前关闭。 嗨,我正在尝试使用 an
这个问题已经有答案了: How can I fix 'android.os.NetworkOnMainThreadException'? (64 个回答) 已关闭 3 年前。 我在 Android 应
我的 Android 项目中有一个名为 EditTrip_Activity.java 的类/Activity ,并且我不断收到此 NetworkOnMainThreadException。我之前已经得
我试图从 MySQL 数据库获取产品的详细信息,但是当我编译代码时,即使我在调用 GetProductDetails 类来执行时将其用作 AsyncTask,也会收到 NetworkOnMainThr
这个问题已经有答案了: How can I fix 'android.os.NetworkOnMainThreadException'? (64 个回答) 已关闭 7 年前。 实际上,我尝试将图像文件
我想将视频(从图库中选择)上传到服务器(localhost-Wampserver 在我的计算机上运行 Apache 2.4.4)。从异常和搜索中,我发现网络操作不应该发生在UI运行的线程中。但我该怎么
我正在尝试将 Android 应用程序与 Twitter 连接,但我不知道这部分代码有什么问题: Thread thread = new Thread(){ @Override
为什么当我在 Android 4.0 版本中运行时,此错误通常出现在 listview 中,任何人都可以帮助我解决这个问题。我搜索了一些网站,发现像在 中使用 asynctask >url 我该如何实
在主线程上没有网络调用,但我仍然得到同样的错误:NetworkOnMainThreadException。 MainActivity.class: public class MainActivity
熟悉Android开发,习惯了在UIThread上进行网络调用时的NetworkOnMainThreadException异常。 但是在下面的情况下会抛出 IOException 而不会抛出 Netw
我了解到在 GUI 线程上不允许进行网络操作。对我来说还可以。但是为什么在 Dialog 按钮点击回调上使用这段代码仍然会产生 NetworkOnMainThreadException ? new T
我正在尝试使用套接字在 android 中编写一个服务器/客户端应用程序,并且我在 AsyncTask 中处理客户端套接字(服务器不是 android,只是普通的 java)。当我得到异常时我正在尝试
我已经通过所有 SO 的解决方案来解决 NetworkOnMainThreadException 包括 ASync 类 - 但仍然有问题 这是我的简单代码: ActivityMain 类: publi
这个问题已经有答案了: How can I fix 'android.os.NetworkOnMainThreadException'? (65 个回答) 已关闭 9 年前。 我开发了一个使用 and
我正在尝试通过启动 TCP 服务器来访问 android 网络。但是当我创建一个新线程时,要么 Thread t = new Thread(runnable); t.start(); 或FutureT
我尝试从 POST 请求中获取响应。问题是,尽管我正在使用 AsyncTask 进行网络通信,但有时我会得到 NetworkOnMainThreadException。这意味着有时我成功获得响应,有时
我按照此说明使用传感器模拟器在模拟器上调试我的应用程序: http://code.google.com/p/openintents/wiki/SensorSimulator#How_to_use_th
我在下面有一些代码: protected void testConnection(String url) { DefaultHttpClient httpclient = new Defaul
我的应用程序中有一些网络请求,每当调用网络相关代码时,我都会收到此异常。我已经把它们放在后台了: @Background protected void getBitmapFromURL
我是一名优秀的程序员,十分优秀!