RxJava中Disposable与DisposableObserver的适用场景及区别

核心关系先理清 #

DisposableObserver本质是Observer的子类，同时实现了Disposable接口——它既是能接收事件的观察者，又自带取消订阅的能力。

什么时候用Disposable？ #

当你只需要控制订阅的生命周期（取消订阅），不需要处理onNext/onError/onComplete这些事件回调时，直接用Disposable就够了。比如你启动了一个不需要关心结果的后台任务，只需要在合适时机（比如页面销毁）取消它：

Disposable disposable = myObservable.subscribe();
disposable.dispose();

什么时候用DisposableObserver？ #

当你需要处理事件回调，同时还要能主动取消订阅的时候，就用DisposableObserver。它强制你实现三个事件回调方法，适合需要处理数据流中每个事件，同时要在生命周期变化时终止订阅的场景：

DisposableObserver<Type> disposableObserver = new DisposableObserver<Type>() {
    @Override
    public void onNext(Type type) {
        // 处理每个Next事件
    }

    @Override
    public void onError(@NonNull Throwable e) {
        // 处理错误情况
    }

    @Override
    public void onComplete() {
        // 处理流结束事件
    }
};
myObservable.subscribe(disposableObserver);
disposableObserver.dispose(); 

关键区别总结 #

• Disposable是单纯的订阅管理接口，只有dispose()、isDisposed()等方法，用来控制订阅是否继续。
• DisposableObserver是观察者+订阅管理器的结合体，既负责接收和处理事件，又能自己执行取消操作。

另外补充个小知识点：你也可以用普通Observer配合返回的Disposable来实现同样的逻辑，比如：

Observer<Type> observer = new Observer<Type>() {
    @Override
    public void onSubscribe(Disposable d) {}

    @Override
    public void onNext(Type type) {}

    @Override
    public void onError(Throwable e) {}

    @Override
    public void onComplete() {}
};
Disposable disposable = myObservable.subscribe(observer);
disposable.dispose();

这种方式和DisposableObserver的核心逻辑一致，只是把观察者和订阅管理器拆成了两个对象，怎么选全看你代码管理的习惯。

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