如何使用 RxJava 并行化网络调用？

Question

final List<Order> orders = Observable
            .from(searchAttributes)
            .filter(searchAttribute-> !searchAttribute.isEmpty())
            .flatMap(searchAttribute-> Observable.just(networkCall(searchAttribute)).subscribeOn(Schedulers.io()))
            .toList()
            .toBlocking()
            .single();

我正在使用以下文章来学习 RxJava ： https://proandroiddev.com/understanding-rxjava-subscribeon-and-observeon-744b0c6a41ea

在上面的代码中，networkCall 函数应该发生在一个单独的 IO 线程上，但是网络调用基本上是按顺序发生在同一个 IO 线程上的。如何使用 RxJava 并行化调用？

Answer 1

使用 RxJava 2 可以使用.parallel。

来自this answer：

Flowable<Integer> vals = Flowable.range(1, 10);

vals.parallel()
        .runOn(Schedulers.computation())
        .map(i -> intenseCalculation(i))
        .sequential()
        .subscribe(val -> System.out.println(val));