检测流中的重复组

我想确保列表中的所有数字都分组在一起。让我用例子来解释这一点：

{1, 1, 1, 2, 2}    // OK, two distinct groups
{1, 1, 2, 2, 1, 1} // Bad, two groups with "1"
{1, 2, 3, 4}       // OK, 4 distinct groups of size 1
{1, 1, 1, 1}       // OK, 1 group
{3, 4, 3}          // Bad, two groups with "3"
{99, -99, 99}      // Bad, two groups with "99"
{}                 // OK, no groups

这是我获取流的方法：

IntStream.of(numbers)
    ...

现在我需要为“OK”示例传递或返回 true 并抛出AssertionError或在“Bad”示例上返回 false。我如何使用 Stream API 来做到这一点？

这是我当前的解决方案以及附加的Set创建：

Set<Integer> previousNumbers = new HashSet<>();
IntStream.of(numbers)
        .reduce(null, (previousNumber, currentNumber) -> {
                    if (currentNumber == previousNumber) {
                        assertThat(previousNumbers).doesNotContain(currentNumber);
                        previousNumbers.add(currentNumber);
                    }
                    return currentNumber;
                }
        );

使用我的免费StreamEx https://github.com/amaembo/streamex图书馆：

IntStreamEx.of(numbers).boxed().runLengths().toMap();

这段代码会抛出IllegalStateException如果有重复组。

Here runLengths() http://amaembo.github.io/streamex/javadoc/one/util/streamex/StreamEx.html#runLengths--使用方法。它会折叠相等的相邻元素，并将它们替换为Map.Entry其中 key 是输入元素，value 是重复次数。最后toMap()使用这是一个快捷方式.collect(Collectors.toMap(Entry::getKey, Entry::getValue))。我们正在利用这样一个事实.toMap() throws IllegalStateException当按键重复时（除非提供了自定义 mergeFunction）。

作为成功执行的免费奖励，您将拥有一个映射，其中键是输入元素，值是系列长度。