根据文档参考, groupBy 运算符根据运算符的键盘映射器功能将给定的 Flux 拆分为多个 GroupedFlux。如果我使用 257 个整数范围执行以下代码,它可以正常工作,但不能使用 258 个整数
public void groupByTest() {
Flux.range(1, 258)
.groupBy(val -> val)
.concatMap(g -> g.map(val -> val + "test"))
.doOnNext(System.out::println)
.blockLast();
}
Run Code Online (Sandbox Code Playgroud)
这是否意味着 groupBy 运算符不能创建超过 257 个组?