流已经运行或关闭-供应商没有帮助

Question

Supplier filteredSupplier = () -> Stream.of(filteredStream.toArray(Obj[]::new));
Stream.concat((Stream<Obj>)filteredSupplier.get(), Stream.of(objs)).forEach(some operation);

据我所知，如果您使用供应商，您可以通过在供应商上使用get（）func来随时使用流。我仍然得到“流已经被操作或关闭”。

请帮助我理解，是否有任何限制使用流通过供应商以及？？

Answer 1

在这一行

Supplier filteredSupplier = () -> Stream.of(filteredStream.toArray(Obj[]::new));

有两个流:FilteredStream和Stream.of(...)返回的流。

对供应商的get方法的每次调用都将导致对stream.of(...)的调用，从而创建一个新流。但是，每个调用都将使用相同的FilteredStream。您的供应商在第二次调用时将无法工作，因为FilteredStream流在第一次调用期间“用完了”。

    Obj[] array = filteredStream.toArray(Obj[]::new);
    Supplier<Stream<Obj>> filteredSupplier = () -> Stream.of(array);