如何在java rx中观察调用线程？

Question

是否有无论如何告诉java rx在观察函数中使用当前线程？我正在为android sync适配器编写代码，我希望在同步适配器线程中而不是在主线程中观察结果。

使用Retrofit RXJava的示例网络调用如下所示：

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())))
...

这与android rx为主线程创建调度程序的方式相同，但一旦我替换了Looper，它就不再工作了。myLooper（）用于活套。getMainLooper（）。

我可以使用调度程序。newThread（），但由于其复杂的同步代码与大量服务器调用，我会不断创建一个新线程，以启动新的网络调用，再次创建新线程以启动更多的网络调用。有没有办法做到这一点？还是我的方法本身完全错了？

Answer 1

哦，我刚在维基上找到这个：https://github.com/ReactiveX/RxAndroid#observing-在任意线程上

new Thread(new Runnable() {
    @Override
    public void run() {
        final Handler handler = new Handler(); // bound to this thread
        Observable.just("one", "two", "three", "four", "five")
                .subscribeOn(Schedulers.newThread())
                .observeOn(HandlerScheduler.from(handler))
                .subscribe(/* an Observer */)

        // perform work, ...
    }
}, "custom-thread-1").start();

我认为这也适用于你的情况-当然，除了创建一个新线程之外。。。所以只要：

final Handler handler = new Handler(); // bound to this thread
MyRetrofitApi.getInstance().getObjects()
    .subscribeOn(Schedulers.io())
    .observeOn(HandlerScheduler.from(handler))
    .subscribe(new Subscriber<Object>() {
        //do stuff on the sync adapter thread

    }

Answer 2

尝试使用调度程序。立即（）

MyRetrofitApi.getInstance().getObjects()
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.immediate())
.subscribe(new Subscriber<Object>() {
    //do stuff on the sync adapter thread

}

它的描述是：创建并返回一个调度程序，该调度程序立即在当前线程上执行工作。

注意：
我认为将所有工作保留在SyncAdapter的线程上是可以的，因为它已经在使用不同的线程