这可能是个愚蠢的问题,但是在 RxJava 2.0 中,当将 Subject
订阅到 Observable 时,如何获得 Disposable
?
例如:
observable.subscribeWith( behaviorSubject)
不返回 Disposable
?我该如何取消此类订阅?
或者使用 CompositeDisposable
的另一个例子:
compositeDisposable.add( observable.subscribeWith( behaviorSubject) ) )
这无法编译,因为 subscribeWith( behaviorSubject )
没有返回 Disposable。
如何正确取消订阅/处置/取消主题?
最佳答案
您不是第一个遇到这个问题的人。例如issue #4438是关于它的。只需用 DisposableObserver
包装您的主题。在另一个关于Flowable
的issue中,有人提议使用其中一种take*()
方法来完成订阅。
关于java - 如何在 RxJava2 中获取作为订阅者的主题的 Disposable,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41018023/