Android RxJava2：关联PublishSubject的订阅如何添加到CompositeDisposable？

• 你写的disposable.add(getObservable().subscribe(subject))之所以直接报类型错，是因为RxJava2里，只要是传入完整Observer实现的subscribe()重载方法，返回值就是void，根本没有Disposable可以传进去，这是API本身的设计，不是你代码写错了方法。
• 之前尝试用subscribeWith时遇到的类型不兼容，基本都是因为链路里用了无泛型的原始类型（raw type），导致编译器没法做正确的类型推断。

PublishSubject本身同时实现了Observer和Disposable接口，完全可以直接作为订阅目标，借助RxJava提供的subscribeWith()方法完成关联：

• subscribeWith()的设计初衷就是解决“需要把订阅目标本身作为Disposable加入容器”的场景，这个方法会直接把你传入的订阅对象原样返回，不需要额外包装就能拿到绑定后的Disposable引用。
• 实现时只要把全链路的泛型补全，就能避免类型推断报错。

示例代码：

// 补全Observable的泛型声明，避免原始类型导致的类型校验失败
public Observable<Object> getObservable() {
  // 内部返回实际业务逻辑对应的Observable即可
}

PublishSubject<Object> subject = PublishSubject.create();
CompositeDisposable disposable = new CompositeDisposable();

// 用subscribeWith完成订阅关联，直接返回和上游绑定好的Subject实例
Disposable bindRef = getObservable()
    .subscribeWith(subject);

// 直接把引用加入Disposable容器即可，不会再有类型不兼容的报错
disposable.add(bindRef);

• 不要为了拿Disposable，硬套带Consumer参数的普通subscribe()方法做关联：这类重载虽然会返回Disposable，但需要手动把上游的Next、Error、Complete事件挨个转发给Subject，不仅代码冗余，还容易漏处理错误事件的透传，埋下崩溃隐患。
• 报类型不兼容时优先排查泛型：从getObservable()的返回值声明，到PublishSubject的创建，再到订阅逻辑的泛型参数要保持一致，编译器就能自动完成类型匹配，不会出现无意义的类型报错。
• 这种写法下，当你调用CompositeDisposable.clear()解绑订阅时，会直接切断上游Observable和Subject的事件流，不会出现内存泄漏。

内容的提问来源于stack exchange，提问作者user448250