是否建议在订阅完成后立即调用 Disposable.dispose()？

Question

我有一个Activity，我在其中创建和订阅Single 类的多个实例（每个实例都在单独的后台线程中做一些工作）。对于每个订阅，我将创建的Disposable 实例添加到CompositeDisposable 实例，该实例的范围为Activity。当Activity 被销毁时，我正在调用CompositeDisposable.clear() 方法来处理Activity 中的所有订阅。当然，这意味着所有Disposable 实例（包括那些已完成工作的订阅）都在我的Activity 中徘徊，直到Activity 被销毁。

这样可以吗，还是应该在每次特定的Single 实例完成工作时为每个单独的订阅调用Disposable.dispose()（即当SingleObserver 收到onSuccess 或onError 回调时）？后一种方法的问题是我必须跟踪哪个Disposable 链接到哪个SingleObserver，这违背了使用CompositeDisposable 的意义。

Answer 1

不，你不应该。当 Observable 完成时，Observable 会自行处理。这是Observable contract的一部分：

当 Observable 向其观察者发出 OnError 或 OnComplete 通知时，这将结束订阅。观察者不需要发出 Unsubscribe 通知来结束 Observable 以这种方式结束的订阅。

Answer 2

Yosriz's answer 是正确答案，但如果您确实想在Single 订阅完成工作后立即从您的CompositeDisposable 实例中删除Disposable 实例（并且没有Disposable 实例挂起），然后我整理了以下抽象类：

public abstract class MySingleObserver<T> implements SingleObserver<T> {

    private Disposable disposable;

    @Override
    public void onSubscribe(@NonNull Disposable disposable) {
        this.disposable = disposable;
        onStart();
    }

    public Disposable getDisposable() {
        return disposable;
    }

    public abstract void onStart();
}

您可以将此类的具体扩展作为SingleObserver 传递给您的Single 订阅，如下所示：

Single.just(1)
      .subscribe(new MySingleObserver<Integer>() {

          @Override
          public void onStart() {
              MyActivity.this.myCompositeDisposable.add(getDisposable());
              // do something further
          }

          @Override
          public void onSuccess(@NonNull Integer success) {
              MyActivity.this.myCompositeDisposable.remove(getDisposable());
              // do something further
          }

          @Override
          public void onError(@NonNull Throwable error) {
              MyActivity.this.myCompositeDisposable.remove(getDisposable());
              // do something further
          }
      });

Answer 3

没有。它会在需要时自动处理。