连接它们时意外关闭流

Question

使用 Java 8（如果这很重要），我有一个难以理解的行为。

假设我有一个Entry 类：

static class Entry {
    String key;
    List<String> values;
    public Entry(String key, String... values) {
        this.key = key;
        this.values = Arrays.asList(values);
    }
}

还有一个实例列表：

List<Entry> entries = Arrays.asList(
    new Entry("a", "a1"),
    new Entry("b", "b1"),
    new Entry("a", "a2"));
);

现在我想收集所有具有相同键的条目（并保持不同的值），我偶然发现了“IllegalStateException：流已被操作或关闭”。

生成它的最少代码是：

entries.stream().collect(
  Collectors.groupingBy(
    e -> e.key,
    Collectors.mapping(
        e -> e.values.stream(), 
        Collectors.reducing(Stream.<String>empty(), Stream::concat))
  )
);

（我会添加一个collectingAndThen 来满足我的要求，但这不是我的问题的重点）

我看不到代码的哪一部分消耗/作用于流。此外，如果我将代码更改为以下内容，它可以工作：

entries.stream().collect(
  Collectors.groupingBy(
    e -> e.key,
    Collectors.mapping(
        e -> e.values.stream(), 
        Collectors.reducing(Stream::concat))
  )
);

我宁愿使用以前的代码，因为后者给我一个Map<K, Optional<V>>，而前者给我一个Map<K, V>。

但问题是：中性元素的使用在减少方面有什么不同，最终导致（至少）其中一个流被消耗？

Answer 1

主要问题可以归结为这个类似的例子：

Stream<String> identity = Stream.empty();
Stream<String> stream1 = Stream.of("1");
Stream<String> stream2 = Stream.of("2");
Stream.concat(identity, stream1); //works
Stream.concat(identity, stream2); //java.lang.IllegalStateException

换句话说，

Collectors.reducing(Stream.<String>empty(), Stream::concat)

使用Stream.<String>empty() 创建一个 流对象，并将其作为多级归约中的标识值重用。幸运的是，您已经有了解决方法。

---

正如文档中所警告的那样，并且在 cmets 中也指出，不鼓励重复的流连接：

从重复连接构造流时要小心。访问深度串联流的元素可能会导致深度调用链，甚至是 StackOverflowException。

我能想到的另一种方法是在分组之前展平流：

//This yields a Map<String, List<String>>
entries.stream()
    .flatMap(v -> v.values.stream().map(val -> new SimpleEntry<>(v.key, val)))
    .collect(Collectors.groupingBy(
        Map.Entry::getKey, 
        Collectors.mapping(Map.Entry::getValue, 
                           Collectors.toList())));

Answer 2

主要问题是你不能将流作为标识元素，因为流不能被重用，所以当它试图重用它时，抛出说它被操作或关闭。

这是一种替代方法（返回 List 而不是 Optional）：

Map<String, List<String>> collect = entries.stream().collect(
    Collectors.groupingBy(
        e -> e.key,
        Collectors.flatMapping(e -> e.values.stream(), Collectors.toList())))