从一个长流创建流

从一个长流创建流

您可能想要实现自己的聚合拆分器来执行此 *** 作。在质子包装库中已经有类似的东西（第一个链接重定向到在质子包装中实现的链接）。

请注意，您将获得一个

Stream<List<Integer>>

（您可以尝试将实现修改为

Stream<Stream<Integer>>

直接具有一个，但是您始终需要缓冲少量元素；具体取决于窗口的大小；以测试是否应创建一个新窗口）。因此，例如：

StreamUtils.aggregate(Stream.of(1, 1, 1, 2, 2, 2, 3, 6, 7, 7, 1, 1), Objects::equals).forEach(System.out::println);

输出：

[1, 1, 1][2, 2, 2][3][6][7, 7][1, 1]