如何重用java集合流的调用结果，这样我们就不会重复同样的工作了？

Question

我知道，一旦集合的流操作为forEach-min-collect-code，该流即关闭，不再适用于进一步的函数调用。

我的问题是，如何避免“重复流操作”，以便我们可以在同一个集合上执行不同的流操作，而不需要重复计算？

例如。

    public static void main(String[] args) {
        List<Integer> ls = new ArrayList<>(Arrays.asList( 11, 9, 7, 11, 24, 13, 37, 16 ));
        Stream<Integer> s1 = ls.stream().filter(x -> x > 10).sorted().distinct().limit(4).skip(2);
        s1.forEach(System.out::println);

        // java.lang.IllegalStateException: stream has already been operated upon or closed
        System.out.println(s1.max((x, y) -> x < y ? y : x).get()); // s1 is no longer useable.
    }

好吧，我知道为了得到s1。max我必须再次构建流，如下所示：

Stream<Integer> sAnother = ls.stream().filter(x -> x > 10).sorted().distinct().limit(4).skip(2);

这是可行的，但似乎是第二次做多余的工作。我希望我们可以使用这个调用序列，并使其只执行一次：

filter(x -> x > 10).sorted().distinct().limit(4).skip(2)

然后：（1）进行forEach打印元素。（2） 计算最大元素。

不必两次构造和计算整个流过程。

有办法做到这一点吗？谢谢。

Answer 1

Stream只能使用一次，您对此无能为力。但是，您可以做的是将其收集到List（stream.toList（）），然后使用该列表进行进一步执行-在您的情况下创建两个可以执行不同工作的新流。