java - Java8中如何将一个流缩减为另一个流？

Question

举个例子，我想创建一个无限的十组流，如下所示:

0=[0, 1, 2, 3, 4, 5, 6, 7, 8, 9]
1=[10, 11, 12, 13, 14, 15, 16, 17, 18, 19]
2=[20, 21, 22, 23, 24, 25, 26, 27, 28, 29]
...

我想使用 inifinte 整数流作为输入，然后对其进行分组。如果第一个流迭代 10 次，则结果流应该只迭代一次。

我的工作但不是很优雅的代码如下所示:

// create a stream from 0 (inclusive) to 100 (exclusive)
IntStream.iterate(0, i -> i+1).boxed().limit(100)

// slow down
.peek((i) -> {try {Thread.sleep(50);} catch (InterruptedException e) {}})

// group by tens
/* ugly: */.collect(Collectors.groupingBy(i -> i / 10)).entrySet()
/* not working: */ //.makeSequentialGroups(i -> i / 10)

// print to console
.forEach(System.out::println);  

如何对 int 流进行分组，而无需收集和重新流式传输？ (如果可能的话，甚至不必使用拳击)

Answer 1

这样的功能可以在我的StreamEx中找到。图书馆并称为 groupRuns :您可以根据提供的谓词将相邻元素收集到中间列表中。示例:

IntStreamEx.iterate(0, i -> i+1).boxed().limit(100)
    .peek((i) -> {try {Thread.sleep(50);} catch (InterruptedException e) {}})
    .groupRuns((a, b) -> a/10 == b/10)
    .forEach(System.out::println);