小编exc*_*bot的帖子

GroupedFlux<T> 创建的 groupBy 运算符的数量是否有限

根据文档参考, 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 个组?

java project-reactor

4
推荐指数
1
解决办法
2189
查看次数

标签 统计

java ×1

project-reactor ×1