合并一个可观察对象列表，然后等待所有完成

Question

TL; DR 如何转换Task.whenAll(List<Task>)成RxJava？

我现有的代码使用Bolts构建了一系列异步任务，并等待所有这些任务完成后再执行其他步骤。本质上，它会构建a
List<Task>并返回一个列表，当Bolts站点上的示例按照列表中的 所有 任务Task完成时，将其标记为已完成。
__

我正在寻找替换方法Bolts，RxJava并且我假设这种方法可以构建异步任务列表（大小未知）并将它们全部包装为一个Observable，但是我不知道如何。

我试着看merge，zip，concat等…但不能去工作的List<Observable>，我会被建立，因为他们似乎都面向工作的只有两个Observables，如果我理解正确的文档在一个时间。

我正在尝试学习RxJava，但仍然很陌生，因此如果这是一个明显的问题或在文档中的某个地方进行了解释，请原谅我；我尝试搜寻。任何帮助将非常感激。

Answer 1

听起来您正在寻找Zip运算符。

有几种不同的用法，让我们来看一个例子。假设我们有一些不同类型的简单可观察物：

Observable<Integer> obs1 = Observable.just(1);
Observable<String> obs2 = Observable.just("Blah");
Observable<Boolean> obs3 = Observable.just(true);

等待他们全部的最简单方法是这样的：

Observable.zip(obs1, obs2, obs3, (Integer i, String s, Boolean b) -> i + " " + s + " " + b)
.subscribe(str -> System.out.println(str));

请注意，在zip函数中，参数具有与要压缩的可观察对象类型相对应的具体类型。

也可以直接压缩可观察对象的列表：

List<Observable<?>> obsList = Arrays.asList(obs1, obs2, obs3);

Observable.zip(obsList, (i) -> i[0] + " " + i[1] + " " + i[2])
.subscribe(str -> System.out.println(str));

…或通过将列表包装到中Observable<Observable<?>>：

Observable<Observable<?>> obsObs = Observable.from(obsList);

Observable.zip(obsObs, (i) -> i[0] + " " + i[1] + " " + i[2])
.subscribe(str -> System.out.println(str));

但是，在这两种情况下，zip函数只能接受一个Object[]参数，因为列表中的可观察对象的类型及其数量是未知的。这意味着zip函数必须检查参数的数量并进行相应的转换。

无论如何，以上所有示例最终都会打印出来 1 Blah true

编辑：
使用Zip时，请确保Observables所有被压缩的拉链发出相同数量的项目。在以上示例中，所有三个可观察对象都发出了一个项目。如果我们要将它们更改为以下内容：

Observable<Integer> obs1 = Observable.from(new Integer[]{1,2,3}); //Emits three items
Observable<String> obs2 = Observable.from(new String[]{"Blah","Hello"}); //Emits two items
Observable<Boolean> obs3 = Observable.from(new Boolean[]{true,true}); //Emits two items

然后1, Blah, True和2, Hello, True是传递到zip函数中的唯一项目。3由于其他可观察物均已完成，因此该项目永远不会被压缩。