Java 为什么我的 `Stream` 在运行时被关闭

首先，让我们仔细分析一下您创建的custom collector个:

Collector.of(
    () -> Stream.of(),                          // Container - this object is meant accumulate the result by consuming stream elements (in this case it can't really change its state, but nominally its still a container)
    (s, bi) -> Stream.concat(s, Stream.of(bi)), // Accumulator - is meant to define how stream elements should be accumulated in the container (again in this case we can't do anything with the container)
    (s1, s2) -> Stream.concat(s1, s2),          // Combiner - difines how containers should be merged while executing stream in parallel (NB: - we can replace it with a method reference Stream::concat)
    s -> s                                      // Finisher function - discribes the final transformation which should be performed with contaner (NB: since it doesn't perform any action we can omit this agument, there's an overloaded version which doesn't expect Finisher)
)

首先，值得指出的是，Stream等于not a container of data(就像一个集合).

因此，提供空流() -> Stream.of()作为collector的container是错误的-container需要是可变的.但是我们can't把元素推入一条空流中.

其次，custom collector中的accumulator(Collector.of()的第二个参数)是not，它在做你可能期望它做的事情.

Accumulator是BiConsumer<R, T>，您已经按如下方式实现了它:

(s, bi) -> Stream.concat(s, Stream.of(bi))

在这里，Stream.concat()使用流s和Stream.of(bi)返回的流中的所有元素，并生成一个新的未命名流，该流很快就成为垃圾收集器的猎物.提醒:BiConsumer不返回值，因此concat()返回的流消失.

流s保留(意味着collector知道它是引用)，但它在执行concat()时已经被消耗，即它是closed.它发生在第一流元素(BigInteger.ZERO)获得处理时.当collectortry 处理第二个元素时，您会得到一个异常，因为concat()try 使用已经关闭的流s.

当Consumer触发时，我预计Stream<Stream<BigInteger>>将被消耗，返回Stream<BigInteger>

首先，BiConsumer和Consumer都有一个abstract方法accept()，即void，它不打算返回任何东西.

我的Supplier返回的流似乎正在关闭

其次，感觉你对Collection 家的工作方式有误解.mutable container的实例将在顺序执行场景中创建only once(每个线程并行创建一个容器，除非您通过提供Collector.Characteristics.CONCURRENT将其指定为concurrent collector，在这种情况下，所有线程将共享相同的容器).

Container应该是一个可变对象(否则它不会像您的例子那样有用)，它的工作是累加流元素.即container更改其状态，而collector使用流中的元素.

由Stream.iterate(seed,f)返回的流将是Stream<BigInteger>类型.

supplier () -> Stream.of()生成的Container将是Stream<Object>类型，因为编译器无法推断空流的类型，除非您使用类似.<BigInteger>of()的Type-Witness显式指定它.

因此，由accumulator侧的concat()返回的流也将是Stream<Object>类型.并提醒您，此流将被忽略.

在任何地方都不会有像Stream<Stream<BigInteger>>这样的野兽，无论是在管道中，还是在收集器内部.

最后，我要重申的是，将一个元素加到Stream中，本质上是impossible.