java - 流列表上的 IllegalStateException

Question

这个问题已经有答案了:

Copy a stream to avoid "stream has already been operated upon or closed" (10 个回答)

已关闭 5 年前。

List<String> list2 = Arrays.asList("hello", "hi", "你好");  
List<String> list3 = Arrays.asList("zhangsan", "lisi", "wangwu", "zhaoliu");  

List<Stream<String>> list2Result = list2.stream().map(item -> list3.stream().map(item2 -> item + " " + item2)).collect(Collectors.toList());

list2Result.forEach(item -> item.collect(Collectors.toList()));
list2Result.forEach(item -> item.forEach(System.out::println));

我必须将 list2Result 转换为 List<List<String>> ，但我不能使用 foreach 来打印它。

Exception in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closed at java.util.stream.AbstractPipeline.evaluate(Unknown Source) at java.util.stream.ReferencePipeline.forEach(Unknown Source) at com.singhand.proxyServer.Main.lambda$15(Main.java:61) at java.util.ArrayList.forEach(Unknown Source) at com.singhand.proxyServer.Main.main(Main.java:61)

Answer 1

您不能操作同一个Stream两次。

尝试收集第一个 map 中的列表。

List<List<String>> list2Result = list2.stream()
        .map(item -> list3.stream()
            .map(item2 -> item + " " + item2)
            .collect(Collectors.toList()))
        .collect(Collectors.toList());

并以同样的方式打印列表列表

list2Result.forEach(item -> item.forEach(System.out::println));

<小时/>

如果您想要一个扁平列表，请尝试在将多个流扁平化为一个的 flatMap 之前使用来收集列表。

List<String> list2Result = list2.stream()
        .map(item -> list3.stream()
            .flatMap(item2 -> item + " " + item2))
        .collect(Collectors.toList());

然后您将获得可以打印的字符串列表。

list2Result.forEach(System.out::println);