如何在RxJava2中以訂戶的身份獲得一次性使用

Question

這可能是一個愚蠢的問題，但在RxJava 2.0中訂閱Subject時，如何獲得？

例如：

observable.subscribeWith(behaviorSubject) 

不返回Disposable？我如何取消這種訂閱？

或者與CompositeDisposable另一個例子：

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

這並不編譯，因爲subscribeWith(behaviorSubject)不返回一次性的。

如何取消訂閱/處理/取消主題？

Answer 1

你不是第一個絆倒這個的人。例如issue #4438就是關於它的。只需用DisposableObserver包裝你的主題。在另一個關於Flowable的問題中，有人提議使用take*()方法之一來完成訂閱。