rx java—rx中的unsubscribe方法是只取消最后一个订阅者的订阅，还是停止整个流的事件发布

Question

我对Rx如何处理Subscription#unsubscribe方法很感兴趣。例如，我们有

Subscription subscription = Observable.from(veryBigList)
                .map(value -> convertValue(value))
                .map(value1 -> saveToDb(value))
                // .... maybe more operators
                .subscribeOn(Schedulers.io())
                .subscribe();
        // ...
        subscription.unsubscribe();

它是否提供了一个保证，取消订阅将停止在整个流中发出事件?

Answer 1

看情况;如果您有cache()或share()，那么退订传播将在那里停止。