流已被供应商操作或关闭

Question

private Stream<User> getUserStream(Stream<User> testStream) { 
    Supplier<Stream<User>> supplierUserStream=()->userStream;
    supplierUserStream.get().sorted();
    supplierUserStream.get().sorted();// throw exception Stream has already been operated upon or closed
    return userStream;
}

Supplier<Stream<User>> streamSupplier
        = () -> Stream.of(userStream.toArray(size -> new User[size]));

Answer 1

仔细看这条信息（重点是我的）：

IllegalStateException：流已经被操作或关闭

因为在第一条语句中没有终端操作，所以流并没有被关闭，而是被操作了，这就是为什么在第二次尝试对它进行操作时会出现错误的原因。

supplierUserStream.get().sorted().sorted();

但是，这将是一种潜在问题的隐藏。例如，如果将main中的测试调用替换为以下语句，您将再次得到相同的问题：

getStringStream(Stream.of("Hello", "World")).forEach(System.out::println);

处理它的一个好方法可以是Ernest_k所建议的：

它也可以通过跟踪派生流对象来解决。Stream Stream=s.get().sorted()；stream=stream.sorted()；返回stream.sorted（）；以重用那些冗余的sort（）调用。

import java.util.function.Supplier;
import java.util.stream.Stream;

public class Main {
    public static void main(String[] args) {
        getStringStream(Stream.of("World", "Hello", "Good morning!")).forEach(System.out::println);
    }

    private static Stream<String> getStringStream(Stream<String> testStream) {
        Supplier<Stream<String>> supplierStringStream = () -> testStream;
        Stream<String> stream = supplierStringStream.get().sorted();
        return stream.sorted();
    }
}

Good morning!
Hello
World