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. 使用store InDatabase存储它
3. 返回在store InDatabase完成时完成的完成？

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

Answer 1

首先，我不认为合并很适合您的需求，因为store InDatabase必须在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);
                }
            });
}