为什么在这种情况下处理DisposableObserver很重要

Question

我用干净的架构在android项目上工作。

我有以下课程：

public abstract class RxBaseInteractor<T, Params> {

  private final CompositeDisposable disposables;

  public RxBaseInteractor() {
    this.disposables = new CompositeDisposable();
  }

  abstract public Observable<T> buildUseCaseObservable(Params params);

  public void execute(DisposableObserver<T> observer, Params params) {
    Preconditions.checkNotNull(observer);
    final Observable<T> observable = this.buildUseCaseObservable(params)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread());
    addDisposable(observable.subscribeWith(observer));
  }

  public void dispose() {
    if (!disposables.isDisposed()) {
      disposables.dispose();
    }
  }

  protected void addDisposable(Disposable disposable) {
    Preconditions.checkNotNull(disposable);
    Preconditions.checkNotNull(disposables);
    disposables.add(disposable);
  }
}

 @Override public void destroy() {
        super.destroy();
        myInteractor.dispose();
    }

    @Override public void onDestroy() {
    super.onDestroy();
    if (getPresenter() != null) {
      getPresenter().destroy();
    }
  }

使用public dispose（）方法从onNext实现中释放序列。

但我还是不明白使用它的好处。是否用于在销毁视图时从observable取消订阅，以便从onNext()转到onComplete()并关闭发射器上的订阅？

Answer 1

使用dispose方法背后的原因是，在系统启动视图(activity或fragment)后，订阅启动，然后您决定返回或启动另一个视图，而旧的订阅仍在执行且未完成其工作。这意味着它仍在内存中，这将导致内存泄漏。因此必须调用Disposite方法进行取消订阅。