无论如何要告诉java rx使用observeOn函数中的当前线程？我正在为android syncadapter编写代码,我希望在同步适配器线程中观察结果,而不是在主线程中.
使用Retrofit + RX Java的示例网络调用看起来像这样:
MyRetrofitApi.getInstance().getObjects()
.subscribeOn(Schedulers.io())
.observeOn(<current_thread>)
.subscribe(new Subscriber<Object>() {
//do stuff on the sync adapter thread
}
我尝试过使用
...
.observeOn(AndroidSchedulers.handlerThread(new Handler(Looper.myLooper())))
...
这是相同的方式安卓RX创建主线程调度程序,但只要我代替不工作Looper.myLooper()的Looper.getMainLooper().
我可以使用Schedulers.newThread(),但作为其复杂的同步代码与许多服务器调用我将不断创建一个新的线程,只是为了触发新的网络调用,再次创建新的线程,以启动更多的网络调用.有没有办法做到这一点？或者我的方法本身是完全错误的？