java - 我应该如何将 List> 压缩为 Observable> ？

Question

我有一个List<Observable<T>>我想转变成Observable<List<T>> 。

我知道Observable.zip ，这似乎是正确的函数，但我不确定如何定义 zipper范围。

这是我尝试过的:

final List<Observable<T>> tasks = getTasks();

final Observable<List<T>> task = Observable.zip(
    tasks, 
    x -> ImmutableList.copyOf(x)
        .stream()
        .map(x -> (T)x)
        .collect(ImmutableList.toImmutableList()));

但是，这需要未经检查的转换。

我应该如何在 RxJava 2 中解决这个问题？

<小时/>

请注意this question指的是 RxJava 1。

Answer 1

使用原语:

List<Observable<T>> tasks = getTasks();
Observable<List<T>> task = Observable.merge(tasks).toList();

但是，您真的需要一次完成所有任务吗？您可以跳过 toList 并在任务到来时处理它们；这将为您提供更好的响应能力和更轻松的并发控制。