我有一个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);
}
}
);
.subscribeOn(Schedulers.io())
必须放在你的 map 后面,因为 map 中的函数在订阅时被调用。 - njzk2