android - RxJava即时类调度程序

Activity.runOnUiThread()具有以下内容:

if (Thread.currentThread() != mUiThread) {
    mHandler.post(action);
} else {
    action.run();
}

这意味着，如果我在UI线程中，它将立即运行操作，如果不是，则将操作发布到处理程序。
我正在寻找类似此功能的RxJava Scheduler。是否存在？

最佳答案

是的，很简单。

getSomeObservable().observeOn(AndroidSchedulers.mainThread())

在 .observeOn(AndroidSchedulers.mainThread())之后，您可以订阅您的o​​bservable，回调将进入主线程。

.subscribe(new Subscriber<Object>() {
                @Override
                public void onCompleted() {
                    Log.i(TAG,Thread.currentThread().getName());
                }

                @Override
                public void onError(Throwable e) {
                    Log.i(TAG,Thread.currentThread().getName());
                }

                @Override
                public void onNext(Object o) {
                    Log.i(TAG,Thread.currentThread().getName());
                }
            });

关于android - RxJava即时类调度程序，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/46968498/