Java 复制流以避免“流已被操作或关闭”

你可以将局部变量与一起使用，

Supplier

从http://winterbe.com/posts/2014/07/31/java8-stream-tutorial-examples/：

重用流

Java 8流无法重用。调用任何终端操作后，流就立即关闭：

Stream<String> stream = Stream.of("d2", "a2", "b1", "b3", "c")    .filter(s -> s.startsWith("a"));stream.anyMatch(s -> true);    // okstream.noneMatch(s -> true);   // exceptionCalling `noneMatch` after `anyMatch` on the same stream results in the following exception:java.lang.IllegalStateException: stream has already been operated upon or closedat java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:229)at java.util.stream.ReferencePipeline.noneMatch(ReferencePipeline.java:459)at com.winterbe.java8.Streams5.test7(Streams5.java:38)at com.winterbe.java8.Streams5.main(Streams5.java:28)

为了克服此限制，我们必须为要执行的每个终端操作创建一个新的流链，例如，我们可以创建一个流提供程序以构造一个已经设置了所有中间操作的新流：

Supplier<Stream<String>> streamSupplier =    () -> Stream.of("d2", "a2", "b1", "b3", "c") .filter(s -> s.startsWith("a"));streamSupplier.get().anyMatch(s -> true);   // okstreamSupplier.get().noneMatch(s -> true);  // ok

每次调用都会get()构造一个新的流，我们可以保存该流以调用所需的终端操作。