Api 调用链接到某个限制 Rxjava2 + Retrofit2

Question

我正在使用 Retrofit2 和 Rxjava 进行 API 调用。我必须进行多个 API 调用（同一个 API），比如说 100 个。现在我希望最多并行执行 5 个。所以如果 5 个 API 调用正在进行，第 6 个应该等待。一旦完成了正在进行的 5 个呼叫中的任何一个，就应该开始第 6 个。我不希望在前 5 个完成并且仅在接下来的 5 个发生之后才在 5 个中进行此操作。

我不确定如何使用Rxjava 实现，这就是为什么我没有任何sn-p 可以发布。任何帮助都会很棒

Answer 1

RxJava 有一些可以限制线程数量的操作符。

observable
  .flatMap( input -> apiCallReturningObservable( input ), 5 )
  .subscribe();

一次最多可以调用 5 次 apiCallReturningObservable()。