分组Java8流而不收集它

Question

在Java8中有什么方法可以在Java.util.stream.stream中分组元素而不收集它们吗？我希望结果再次成为流。因为我必须处理大量的数据，甚至是无限的流，所以我不能首先收集数据，然后再次流化结果。

所有需要分组的元素在第一个流中是连续的。因此，我喜欢保持流评估懒惰。

Answer 1

没有办法使用标准的流API来做这件事。一般来说，您不能这样做，因为将来总是有可能出现属于任何已经创建的组的新项，所以在处理所有输入之前，您不能将组传递给下游分析。

但是，如果您事先知道要分组的项在输入流中总是相邻的，那么您可以使用增强流API的第三方库来解决这个问题。StreamEx就是这样一个库，它是免费的，由我编写。它包含许多“部分缩减”运算符，这些运算符基于某个谓词将相邻项折叠为单个项。通常，您应该提供bipredicate，它测试两个相邻的项，如果它们应该分组在一起，则返回true。以下列出了部分还原操作：

• 折叠（双谓词）:用组的第一个元素替换每个组。例如，collaph(objects::equals)对于从流中删除相邻的重复项非常有用。
• groupruns(BiPredicate):用组元素列表替换每个组（因此streamex 转换为streamex > )。例如，stringstream.groupruns((a，b)->a.charat(0)==b.charat(0))将创建字符串列表流，其中每个列表包含以相同字母开头的相邻字符串。

其他部分约简操作包括intervalmap、runlengths()等。

所有的部分约简操作都是懒惰的，并行友好的，并且相当高效。

注意，您可以使用streamex.of(stream)从常规Java8流轻松地构造streamex对象。还有从数组、集合、读取器等构造它的方法。Streamex类实现Stream接口，并且与标准流API 100%兼容。