Rx Android将对同一服务的多次调用并行组合

Question

我必须改进一个旧的服务，它对同一个服务进行多个连续调用，并将所有结果合并到一个列表中。

假设我们有一个ID列表=[1，2，3，…6]，所以我必须用每个ID调用相同的API（带有改装和可观察）。

为此，我想使用Rx Android，但我对如何合并结果有疑问。

        Integer[] ids = {1, 2, 3};

        Observable.from(ids)
                .map(id -> mApi.getData(id))

我们可以进行并行调用并按照相同的顺序合并结果吗？

为了提高时间响应，我们的想法是并行执行，但我不知道如何确保结果将按照与服务器调用相同的顺序进行组合。

我想使用concat（http://reactivex.io/documentation/operators/concat.html），但它等待前一个可观察到的等待。

Answer 1

请参见ConcatmaPagear及其变体。

Observable.fromArray(1, 2, 3)
.concatMapEager(id -> 
    Observable.fromCallable(() -> mApi.getData(id))
    .subscribeOn(Schedulers.io())
)
.subscribe(...);