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

【问题标题】：How to get a Disposable for subjects as subscriber in RxJava2如何在 RxJava2 中获取主题作为订阅者的 Disposable
【发布时间】：2016-12-07 12:53:27
【问题描述】：

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

例如：

observable.subscribeWith( behaviorSubject)

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

或者CompositeDisposable的另一个例子：

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

这不会编译，因为 subscribeWith( behaviorSubject ) 不返回 Disposable。

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

【问题讨论】：

【解决方案1】：

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

【讨论】：