Webflux生产者消费者问题（webClient）

Question

    Flux.range(0, 100)
            .flatMap((Integer y) -> {
                return reallySlowApi(); 
            })
            .doOnEach((Signal<String> x1) -> {
                log("next-------" );
            })
            .subscribeOn(Schedulers.elastic())
            .subscribe()
    ;

我如何将电话限制在每5秒一次。注意：只能修改reallySlowApi。

private Mono<String> reallySlowApi() {
    return webClient
            .get()
            .retrieve()
            .bodyToMono(String.class);
}

编辑：我知道DelayElements，但是如果Api变得更慢，它就不能解决问题。我需要使用reallyslowapi的最佳方式。

Answer 1

一种方法是使用delayElements（）

  public void run() {
    Flux.range(0, 100)
        .delayElements(Duration.ofSeconds(5)) // only emit every 5 seconds
        .flatMap(y -> reallySlowApi())
        .doOnNext(x1 -> System.out.println("next-------"))
        .blockLast(); // subscribe AND wait for the flux to complete
  }

  private Mono<String> reallySlowApi() {
    return Mono.just("next");
  }

您还可以使用flux.interval（）加上take（）来限制迭代次数。

   Flux.interval(Duration.ofSeconds(5))
        .take(100)

请注意，示例中的subscribeOn不做任何部分工作，因为subscribe操作应用于0-100范围的生成，这不是阻塞。