从一个长流创建流

Question

我想一个拆分Stream成Stream的Streams基础上的内容Streams。结果将Stream包含原始流数据的一部分。

我的实际应用程序更加复杂（将时间间隔列表中的日志行分组），但是我的问题是如何处理流，因此在这里我问一个简化的示例。

我希望能够基于重复的相同数字将a拆分Stream<Integer>为一个Stream<Stream<Integer>>，而仅将流保留为奇数。

例如，以下流包含：

{1,1,1,2,2,2,3,6,7,7,1,1}

需要产生包含以下内容的流：

{{1,1,1},{3},{7,7},{1,1}}

通过使用过滤器开始（或结束），可以省去偶数：

Stream<Integer> input = ...;
Straem<Stream<Integer>> output = input.filter(this::isOdd).someOtherOperation();

这是不希望的，因为这意味着对每个输入值进行两次评估，这是可以接受的，但我希望避免这种情况。

解决方案的想法

我当前的解决方案是对流的内容进行迭代，并创建一个List<List<Integer>>并将其转换为Stream<Stream<Integer>>。但是，这意味着完整的结果将保留在内存中（这对于我的应用程序来说是不希望的）。

我还认为我可以编写自己的Iterator内容（从流中读取）来实现这一点，但是我不确定这将如何工作。

题

我如何基于原始内容将a Stream转换为Streamof
，而又不将完整结果存储为first。Streams``Stream``List``Lists

Answer 1

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

请注意，您将获得一个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]