java - 如何在 Spring webflux 层次结构中发布数据？

Question

我正在使用 spring webflux 开发一个代理应用程序。客户端发送请求以获取前 100 条记录。服务器 1（Spring webflux 项目）向服务器 2 发送请求，并获取前 100 条记录（Flux<MyData>）然后对其应用过滤器（拒绝一些数据），现在服务器 1 的记录少于 100 条，所以它必须发送另一个请求准确地获取 100 条正确记录。但是我不能用 Spring webflux 动态地做到这一点。如何动态收集 100 条记录？

注意：我有fetchData通过 WebClient 发送请求的方法，以便max从记录中获取first记录。

Flux<MyData> fetchData(int first, int max){
   ...
}