Spring reactor webclient使用flatmap和takewhile进行顺序请求

Question

我想从第三方资源检索所有页面。为此，我写了这个：

final WebClient webClient = WebClient.builder()
     .baseUrl("http://resource.com")
     .build();
Flux.fromStream(IntStream.iterate(0, i -> i + 1).boxed())
     .flatMap(i -> webClient.get()
          .uri("/data?page={page}", i)
          .retrieve()
          .bodyToMono(Page.class))
     .takeWhile(Page::isMoreAvailable)
     .flatMapIterable(Page::getData)

但它不能正常工作flatMap被多次调用，在takeWhile检索第一个响应之前，它会使用不同的页面执行多个请求。

如果我改成这个：

.map(i -> webClient.get()
        .uri("/data?page={page}", i)
        .retrieve()
        .bodyToMono(Page.class)
        .block())

效果很好。

那么，我如何使用平面地图实现这一点呢？

Answer 1

平面图处理是并发的

.flatMap(i -> webClient.get()
   .uri("/data?page={page}", i)
   .retrieve()
   .bodyToMono(Page.class), 1)

成功了。