Android RxJava2-添加订阅到CompositeDisposable

Question

我有一个Observable和PublishSubject，它们已经订阅了。我尝试使用subscribe和subscribeWith，但由于类型不兼容，两者都不起作用。你能建议我如何将此订阅添加到CompositeDisposable吗？

public Observable getObservable() {
//returns Observable object;
}
PublishSubject<Object> subject = PublishSubject.create();
CompositeDisposable disposable = new CompositeDisposable();
// The below statement gives error: requiredtype Disposable but provided void. 
disposable.add(getObservable().subscribe(subject));

Answer 1

试试这个

disposable.add(getObservable().subscribe(yourObject -> {
subject.onNext(yourObject);
}));

Answer 2

你可以这样做：

Disposable d = getObservable().subscribe(
subject::onNext,
subject::onError,
subject::onComplete
);
disposable.add(d);

只要记住处理发布者的订阅，你就会没事的。