Cách lấy một lần dùng cho các chủ thể là người đăng ký trong RxJava2

Question

Có thể là một câu hỏi ngớ ngẩn, nhưng làm thế nào để tôi nhận được Disposable khi đăng ký Subject vào một Observable trong RxJava 2.0?

Ví dụ:

observable.subscribeWith(behaviorSubject) 

không trả lại một Disposable? Làm cách nào để hủy đăng ký như vậy?

Hoặc một ví dụ khác với CompositeDisposable:

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

này không biên dịch vì subscribeWith(behaviorSubject) không trả lại một Disposable.

Làm cách nào để hủy đăng ký/hủy bỏ/hủy đúng đối tượng?

Answer 1

Bạn không phải là người đầu tiên vấp ngã về điều này. Ví dụ: issue #4438 là về nó. Chỉ cần quấn chủ đề của bạn với DisposableObserver. Trong một vấn đề khác về Flowable một người nào đó được đề xuất sử dụng một trong các phương pháp take*() để hoàn thành đăng ký.