RxJava2 并行执行一堆 Completable 并等待全部完成

Question

我想执行几个阻塞方法（网络调用、计算任务）。我想并行执行它们，并在它们全部完成时收到通知，或者如果它们中的任何一个失败（抛出异常）则收到错误消息。他们不会发出结果，所以Observable.zip() 不会帮助我。

到目前为止我有：

Completable a = computationTaskA();
Completable b = computationTaskB();
Completable c = computationTaskC();
Completable all = Completable.concat(Arrays.asList(a, b, c))
            .subscribe(() -> {
               // all succeed
            }, e -> {
               // any fails
            });

但是Completable.concat() 文档说Returns a Completable which completes only when all sources complete, one after another.。我没有找到可以并行执行它们的解决方案。

Answer 1

您可能想使用Completable.merge/mergeArray

Completable a = computationTaskA();
Completable b = computationTaskB();
Completable c = computationTaskC();
Completable all = Completable.mergeArray(a, b, c);

all.subscribe(
    () -> { /* success all around! */ },
    e -> { /* at least one failure :( */ }
);