使用 Stream StreamSupplier

Question

我正在使用以下代码重用 Stream 但得到java.lang.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()但实际上您想返回一个新的Stream.

同样正如@Eugene 所建议的，使用Arrays.stream()overStream.of()是首选。因为后者是一个可变参数方法，但只是委托给前者。

也可以使用以下Stream.peek()方法简化您当前的方法：

long count = Arrays.stream(array)

    .peek(System.out::println)

    .count();

Answer 2

Stream::count是关闭流的终端操作，因此没有更多的管道可以继续。

你创建Stream<String>你把它放到之前Supplier。如果您希望供应商在每次调用时提供一个新的 Stream，请Stream<String>直接在Supplier.

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

然后streamSupplier.get()将始终使用新的Stream<Stream>.

---

但是，您可能会获得相同的结果，Stream::peek其工作方式相同Stream::forEach，但不关闭Stream但返回相同的未修改结果（@Lino 更快）。

long count = streamSupplier.get().peek(System.out::println).count();

Answer 3

你得到的例外是合适的，它告诉你需要研究什么。从Java 8 Stream 类：

一个流应该只被操作一次（调用一个中间或终端流操作）。例如，这排除了“分叉”流，其中相同的源提供两个或多个管道，或者同一流的多次遍历。如果流实现检测到流正在被重用，它可能会抛出 IllegalStateException。但是，由于某些流操作可能会返回其接收器而不是新的流对象，因此可能无法在所有情况下检测到重用。