RxJava 2.0 -如何将可观察性和可完成性结合起来

Question

假设有包含方法的接口：

Observable<Data> makeHttpCall(int param1, boolean param2);

Completable storeInDatabase(Data data);

Completable combinedCall(int param1, boolean param2);

实现combinedCall方法的最佳方法是：

1. 从makeHttpCall中获取数据
2. 使用storeInDatabase存储它
3. 当storeInDatabase完成时，返回完成的可完成性？

似乎在RxJava 1.0中可以执行Completable.merge(可观察的)，但是合并似乎不再接受可观察的。

Answer 1

首先，我不认为merge适合您的需要，因为storeInDatabase必须在makeHttpCall的结果上执行，而不是并行的。

这应该适用于你：

Completable combinedCall(int param1, boolean param2) {
    return makeHttpCall(param1, param2)
            .flatMapCompletable(new Function<Data, CompletableSource>() {
                @Override
                public CompletableSource apply(@NonNull Data d) throws Exception {
                    return storeInDatabase(d);
                }
            });
}