主线程上的RxJava onCompleted和onTerminate

Question

我在Android上使用RxJava和Retrofit2.0来处理网络请求。

在创建可观察对象时，我向其添加以下内容：

observable = observable
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeOn(Schedulers.io())
    .unsubscribeOn(Schedulers.io())

observable = observable.doOnTerminate(new Action0() {
                @Override
                public void call() {
                    Log.d("OBS", "[" + Thread.currentThread().getName() + "] onTerminate");
                }
            });

是否有一个优雅的解决方案来解决这个问题，而不必手动地用一个块包装我的实现，以便将一些东西发布到主线程？

Answer 1

您应该将回调放在任何observeon之前，这样它们就会留在它的前一个线程上：

Observable.range(1, 10)
.subscribeOn(Schedulers.io())
.doOnTerminate(() -> System.out.println(Thread.currentThread()))
.map(v -> v + 1)
.observeOn(AndroidSchedulers.mainThread())
.map(v -> Thread.currentThread() + " / " + v)
.doOnNext(v -> Log.d("OBS", v))
.subscribe();