java - RxJava : How to make observable to create on different thread than main thread

Question

我希望可观察代码在与主线程不同的线程上运行。我该怎么做，我这样做:

Observable operationObservable = Observable.create(new ObservableOnSubscribe() {
        @Override
        public void subscribe(ObservableEmitter e) throws Exception {
            e.onNext(longRunningOperation());
            e.onComplete();
        }
    })
    .subscribeOn(Schedulers.io()) // subscribeOn the I/O thread
    .observeOn(AndroidSchedulers.mainThread());

Answer 1

如果您需要一个新线程来运行某些内容，只需使用subscribeOn(Schedulers.newThread())即可。

另一种选择是创建您自己的调度程序和执行程序，这在大多数情况下实际上是不必要的。

进一步阅读: link1 link2 link3