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

Question

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

我不确定如何使用 Rxjava 实现，这就是为什么我没有 post 的任何片段。任何帮助都会很棒

Answer 1

RxJava 有一些运算符可以限制运行中的线程数。

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

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