如何用嵌套映射函数修复“流已被操作或关闭”错误

Question

当我试图在两个流上执行函数并产生一个出来时，我遇到了“流已经被操作或关闭”。

我已经尝试过使用StreamSupplier了，但是它似乎并不能解决这个问题，如果我将两个流都转换为字符串列表并执行嵌套循环，它就会得到解决。但我想看看这将是什么流解决方案。

String[] str1 = new String[]{"A","B","C"};
String[] str2 = new String[]{"a","b","c"};
private Stream<String> method(final Stream<String> str1,
            final Stream<String> str2) {
       return str1
               .flatMap(s1 -> str2
                       .map(s2 -> simpleStringConcatFunction_1(s1) + simpleStringConcatFunction_2(s2));

我用双循环来实现这些代码是

private Stream<String> generateFilePatterns(final Stream<String> str1,
            final Stream<String> str2) {
        List<String> list1 = str1.collect(Collectors.toList());
        List<String> list2 = str2.collect(Collectors.toList());
        List<String> list = new ArrayList<>();
        for( String s1 : list1){
            for(String s2 : list2){
                list.add(simpleStringConcatFunction_1(s1) + simpleStringConcatFunction_2(s2);
            }
        }
        return list.stream();
    }

Answer 1

执行在非流代码中所做的一半，即获取str2的快照，以便可以将其多次流化：

List<String> list2 = str2.collect(Collectors.toList());
return str1.flatMap(s1 -> list2.stream()
                               .map(s2 -> simpleStringConcatFunction_1(s1) +
                                          simpleStringConcatFunction_2(s2)));