android - doOnSubscribe 在主线程上被调用

Question

在阅读了多篇博文和文档之后，我得出的结论是以下doOnSubscribe 将在工作线程上执行:

Observable.just(1)
            .observeOn(Schedulers.io())
            .doOnSubscribe(__ -> Log.d("Testing", "Testing")) // Shouldn't this be on worker thread?
            .subscribe();

但是在调试之后，我看到 doOnSubscribe 是在主线程上执行的。我认为 doOnSubscribe 与其他运算符类似，因此在与 subscribeOn 和 observeOn 结合使用时具有类似的线程行为。

我错过了什么？如何将 doOnSubscribe 执行移至后台线程？

Answer 1

subscribeOn 和 observeOn 对 doOnSubscribe 没有影响，因为运算符之间的连接是在调用者线程上建立的，以支持立即取消。您必须以某种方式推迟对 doOnSubscribe 的订阅，例如:

Observable.defer(() ->
    Observable.just(1)
    .doOnSubscribe(s -> Log.d("Testing", "Testing"))
)
.subscribeOn(Schedulers.io())
.subscribe();

或

Observable.just(1)
.subscribeOn(Schedulers.io())
.flatMap(v ->
    Observable.just(1)
    .doOnSubscribe(s -> Log.d("Testing", "Testing"))
)
.subscribe()