java - 如何在另一个线程上运行 RxJava 观察者

Question

如何在另一个线程上运行 RxJava，因为主线程上的工作太多。

我在一个方法内运行观察者，下面是代码 fragment :

public void updatePie() {

RxJavaPlugins.setErrorHandler(Functions.<Throwable>emptyConsumer());

Observable<Long> intervalObservable = Observable
        .interval(1, TimeUnit.SECONDS)
      //.doOnError(Functions.<Throwable>emptyConsumer())
        .subscribeOn(Schedulers.io())
        .takeWhile(new Predicate<Long>() {
            @Override
            public boolean test(Long aLong) throws Exception {

                if (isMyServiceRunning(MyService.class) == false) {
                    RxB = false;
                }
                return RxB;
            }
        })
        .observeOn(AndroidSchedulers.mainThread());

Answer 1

Observable.interval 默认在后台线程中工作。所以你不需要做任何事情。

.subscribeOn() 负责 observable 应该在哪里工作。

.observeOn() 负责以下方法调用的工作位置(通常是 MainThere)