java - 如何在 RxJava2 中获取作为订阅者的主题的 Disposable

Question

这可能是个愚蠢的问题，但是在 RxJava 2.0 中，当将 Subject 订阅到 Observable 时，如何获得 Disposable？

例如:

observable.subscribeWith( behaviorSubject)

不返回 Disposable？我该如何取消此类订阅？

或者使用 CompositeDisposable 的另一个例子:

compositeDisposable.add( observable.subscribeWith( behaviorSubject) ) ) 

这无法编译，因为 subscribeWith( behaviorSubject ) 没有返回 Disposable。

如何正确取消订阅/处置/取消主题？

Answer 1

您不是第一个遇到这个问题的人。例如issue #4438是关于它的。只需用 DisposableObserver 包装您的主题。在另一个关于Flowable的issue中，有人提议使用其中一种take*()方法来完成订阅。