问分组Java8流而不收集它

EN

使用标准的Stream无法做到这一点。通常，您不能这样做，因为将来总是有可能出现属于任何已经创建的组的新项，所以在处理所有输入之前，不能将组传递给下游分析。

但是，如果预先知道要分组的项在输入流中总是相邻的，则可以使用第三方库增强stream来解决问题。其中一个类库是StreamEx，它是免费的，由我编写。它包含了一些“部分约简”操作符，这些运算符根据某种谓词将相邻项折叠为单个。通常，您应该提供一个BiPredicate，它测试两个相邻的项，如果应该将它们分组，则返回true。一些部分削减行动列示如下：

• collapse(BiPredicate)：用组的第一个元素替换每个组。例如，collapse(Objects::equals)对于从流中删除相邻的重复项非常有用。
• groupRuns(BiPredicate)：用组元素列表替换每个组(因此StreamEx<T>被转换为StreamEx<List<T>>)。例如，stringStream.groupRuns((a, b) -> a.charAt(0) == b.charAt(0))将创建字符串流，其中每个列表包含以相同字母启动的相邻字符串。

其他部分还原操作包括intervalMap、runLengths()等。

所有的部分缩减操作都是懒惰的，并行友好的，而且效率很高.

请注意，您可以使用StreamEx轻松地从常规Java8流构造一个StreamEx.of(stream)对象。此外，还有一些方法可以从数组、集合、阅读器等方面构建它。StreamEx类实现了Stream接口，并且100%与标准的Stream兼容。