为什么不调用 doOnDispose？

当创建这样的 Observable 时：

public void foo() {

    Observable observable = Observable.fromCallable(() -> {
        bar();
        return "";
      })
      .doOnSubscribe(disposable -> System.out.println("onSubscribe"))
      .doOnDispose(() -> System.out.println("onDispose"));

    Disposable disposable = observable.subscribe();
    disposable.dispose();    
}

private void bar() {
    System.out.println("bar");
}

doOnSubcribe叫做，doOnDispose不被调用。

这是为什么？

您需要使用doFinally()操作员。

doOnDispose()有一个非常狭窄的用例，其中可观察值是显式处理的。在您的示例中，可观察的“自然”终止为onComplete()。当你打电话的时候dispose()，可观察量已完成，并且不会发生任何事情 - 处置已完成的可观察量没有任何效果。