在 Android 分页库数据源中处理 Observable

Question

我想观察我的 PageKeyedDataSource 中的网络调用变化，并在用户退出导致数据源破坏的 Fragment 后处理 RxJava 订阅。

class ProjectDataSource : PageKeyedDataSource<Int, ProjectPresenter>(), KoinComponent {
    ...

    override fun loadInitial(
        params: LoadInitialParams<Int>,
        callback: LoadInitialCallback<Int, ProjectPresenter>
    ) {
        val subscription = mProjectRepository.getProjects(DEFAULT_TAKE, 0)
            .subscribe(
                { projectPresenters ->
                    ...
                },
                { throwable ->
                    ...
                }
            )
          //Where to dispose `subscription`
    }

    ...
}

我的 Repository 和 DataSource 都有 RxJava 订阅，它们都对数据执行不同的操作。 Repository 将远程模型转换为演示者模型，然后...

我不确定在 DataSource 中观察数据是否是个好主意。

Answer 1

我无法提供任何实质性证据证明我的方式是“正确的方式”，但这是我的想法，并且在实施过程中通常会遵循：

1. 除非有一些非常特殊的情况，否则我不会在存储库或数据源下处理配置
2. 如果我的存储库正在使用 Rx，我只是将我的所有 Rx 实体（Completable's、Single's 等）暴露给消费者（通常是视图模型），他们订阅并管理处置（在许多情况下通过在 onCleared 中清除它们） )
3. 如果我的分页数据源正在使用 Rx（顺便说一下，这可能会在失效期间导致不需要的 UI 效果，最好在数据源 loadInitial 和类似方法中运行阻塞操作），我正在路由 CompositeDisposable 实例从视图模型到数据源工厂。