如何在Reactor中将Flux拆分为最多包含20个元素的列表或子Flux

针对你需要将Flux拆分为最大元素数为20的单元的需求，可直接使用Reactor内置的操作符实现，以下是两种目标输出对应的实现方式：

1. 输出多个List<String>实例 #

使用buffer操作符，会自动将上游元素按指定大小打包为List输出：

// 你的原始Flux数据源
Flux<String> sourceFlux = Flux.just("a", "s", "x", ...);
// 拆分后得到元素为List<String>的Flux，每个List最大长度为20
Flux<List<String>> splitResult = sourceFlux.buffer(20);

• 若最后一组元素不足20个，剩余元素会单独打包为一个List输出
• 若需要一次性获取所有拆分后的List，可追加.collectList()得到Mono<List<List<String>>>类型的结果

2. 输出多个Flux<String>子流 #

使用window操作符，拆分结果为嵌套的Flux结构，适合不需要一次性加载整组元素到内存的流式处理场景：

// 你的原始Flux数据源
Flux<String> sourceFlux = Flux.just("a", "s", "x", ...);
// 拆分后得到元素为Flux<String>的Flux，每个内部子流最多包含20个元素
Flux<Flux<String>> splitResult = sourceFlux.window(20);

• 每个子流支持独立消费，原生兼容Reactor背压机制
• 若需要搭配超时、条件拆分等逻辑，可使用bufferTimeout/windowTimeout等衍生操作符调整拆分规则

内容的提问来源于stack exchange，提问作者pixel