何时在 ViewModel 中处理 RxJava2 Disposable？

Question

我在我的应用中使用来自 Android 架构组件的ViewModel。在 ViewModel 中，我使用 RxJava2 订阅，并在订阅后保留 Disposable 对象。之前，当我在Activity 中执行此操作时，我习惯于在onDestroy() 中处理Disposable - 以避免内存泄漏：

@Override
protected void onDestroy() {
    disposable.dispose();
    super.onDestroy();
}

我应该何时以及如何在ViewModel 中处理它？我真的需要这样做吗？

Answer 1

使用 onCleared 方法

@Override
protected void onCleared () {
    disposable.dispose();
    super.onCleared ();
}

Answer 2

您可以使用LiveDataReactiveStreams#fromPublisher(Publisher<T>) 并从视图模型中公开生成的LiveData，而不是在视图模型中订阅和处置。

例如：

public class ExampleViewModel {

    private static final long TIME_FOR_ANSWER = 1000;
    private static final long DELAY = 25;

    private final LiveData<Long> remainingTime;

    ExampleViewModel() {
        long start = 0;
        long count = TIME_FOR_ANSWER / DELAY + 1;
        Flowable<Long> flowable =
              Flowable.intervalRange(start, count, 0, DELAY, TimeUnit.MILLISECONDS)
                      .map(i -> TIME_FOR_ANSWER - DELAY * i);
        remainingTime = LiveDataReactiveStreams.fromPublisher(flowable);
    }

    public LiveData<Long> getRemainingTime() {
        return remainingTime;
    }
}