使用Stream StreamSupplier

Question

IllegalStateException：流已经被操作或关闭

代码

public static void main(String[] args) {

    try {
        String[] array = { "a", "b", "c", "d", "e" };
        Stream<String> ss = Stream.of(array);
        Supplier<Stream<String>> streamSupplier = () -> ss;

        long count = streamSupplier.get().count();
        // get new stream
        streamSupplier.get().forEach(x -> System.out.println(x));

        // get another new stream

        System.out.println(count);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

Answer 1

不要将stream.of(array)赋值给中间变量，只需在supplier中直接返回：

Supplier<Stream<String>> streamSupplier = () -> Stream.of(array);

这是因为以前在调用supplier.get()时总是提供相同的引用，但实际上您希望返回一个新的流。

同样，正如@Eugene所建议的，在stream.of()之上使用arrays.stream()是首选。因为后者是varargs方法，但只是委托给前者。

long count = Arrays.stream(array)
    .peek(System.out::println)
    .count();