android - RxJava 如何从订阅创建 Observable

Question

我正在寻找一种在处理 subscribe 中的结果后创建 Observable 的方法.

假设我有来自 productRepo.list() 的 Observable这是 Retrofit 返回 Observable<Response<ProductResponse>> .

productRepo
    .list()
    .retry(3)
    .subscribe { response ->
        if (response.isSuccessful) {
            response.body().apply {
                cache.saveProducts(data)
            }
        }
    }

这样做的目的是将结果保存到本地DB cache .这加上另一个非常相似的调用用来自 API 的远程数据填充本地数据库。

两个调用完成后，我想从 cache 加载数据.

我不想以任何方式将两个可观察到的结合起来。之后只想运行一些任务。

我希望将此处理作为 Rx 调用图中的一个单元，以便它同时执行 Call1 和 Call2，并在 Call1 和 Call2 完成后运行 Task3。在这种情况下最好的方法是什么？如果每个调用的用户是分开的，我真的更喜欢。

是flatMap这里的最佳选择是什么？

Answer 1

.doOnNext()

是您的答案，因为将返回您的最终回复或每个回复(如果有多个回复)。试一试。