ReactiveX中的嵌套可观测

Question

我有两个手术：

1. 从服务器加载项(该项仅包含某些文件)
2. 从本地数据库加载项( db中的项可能包含其他文件)
3. 将项合并为一个更新UI
4. 数据库中的更新项

我知道如何在每个操作中使用rx，但是一旦调用所有这些操作，我只会想到其他操作中可以观察到的嵌套，这将导致回调地狱。

完成这些工作的正确方法是什么？

Answer 1

根据您的描述，服务器和本地DB查询应该并行进行，在我们将这两个数据合并之后，您需要使用zip操作符。zip将订阅服务器和本地DB可观测值，当这两个可观测的发出值时，您将继续处理服务器和DB数据，然后将它们合并到zip运算符func中，然后可以观察到发出合并的数据。

在每次发射组合数据(doOnNext)时，在后台启动保存操作，并在用户中根据组合数据更新Ui。

Observable<ServerData> getServerData = ...;
Observable<LocalDbData> getLocalDbData = ...;

Observable
    .zip(getServerData, getLocalDbData,
        (serverData, localDbData) -> combinedData(serverData, localDbData))
    .doOnNext(combinedData -> updateDataInDb())
    .subscribe(combinedData -> updateUi(combinedData));