当我取消订阅 Observable 链时会发生什么？

Question

我在我正在使用的 Android 应用程序中使用 RxJava。我想知道当我取消订阅 Observable 链时会发生什么。

假设我指的是以下可观察链：

sourceObservable
    .map { ... }
    .doOnNext { ... }
    .flatMap { ... }

我看到了 3 个可能的答案：

1. 当我取消订阅时，源 observable 停止，即 sourceObservable 停止发射项目。最后一个发出的项目沿着链向下直到它结束。它会导致每个操作员触发。

2. 当我取消订阅时，源 observable 停止。最后发出的项目不会关闭，但它当前正在经历的操作员（比如doOnNext）被允许完成。

3. 当我取消订阅时，源 observable 停止并且根本不再执行任何代码。这意味着假设我正在使用doOnNext，doOnNext 中的代码将停止在它所在的位置并且不允许完成。

其中哪一个（如果有的话）是正确的？答案是否取决于源 observable 是热的还是冷的？关于运营商？

Answer 1

如果发射了一个项目并且您立即处置了该项目想要停止的流，它将被处理直到它完成处理但不会发射更多项目。

所以如果你看这个例子，也许你会更好地理解

     observable = Observable.interval(100, TimeUnit.MILLISECONDS)
            .map(aLong -> {
                System.out.println("1");
                return aLong;
            })
            .map(aLong -> {
                observable.dispose();
                System.out.println("2");
                return aLong;
            })
             .map(aLong -> {
                 observable.dispose();
                 System.out.println("3");
                 return aLong;
             })
             .doOnNext(aLong -> System.out.println("4"))
             .map(aLong -> {
                 observable.dispose();
                 System.out.println("5");
                 return aLong;
             })
            .subscribe();
}

在这个流中，只有第一个项目会被处理到流的末尾，所以即使我们做的第一个工作是取消订阅，我们仍然会处理发射的项目，所以我们从发射源取消订阅