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

Question

我想复制一个Java 8流，这样我可以处理它两次。我可以收集作为列表并从中获取新流；

// doSomething() returns a stream
List<A> thing = doSomething().collect(toList());
thing.stream()... // do stuff
thing.stream()... // do other stuff

但我觉得应该有一个更高效/更优雅的方法。

有没有一种方法可以复制流而不将其变成集合？

我实际上正在处理一个或者流，所以在移动到右侧投影并以另一种方式处理之前，希望先以一种方式处理左侧投影。类似于这样（到目前为止，我不得不使用tolist技巧）。

List<Either<Pair<A, Throwable>, A>> results = doSomething().collect(toList());

Stream<Pair<A, Throwable>> failures = results.stream().flatMap(either -> either.left());
failures.forEach(failure -> ... );

Stream<A> successes = results.stream().flatMap(either -> either.right());
successes.forEach(success -> ... );

Answer 1

我认为你对效率的假设有点倒退。如果只使用一次数据，就会获得巨大的效率回报，因为您不必存储数据，并且流提供了强大的“循环融合”优化，可以使整个数据高效地通过管道流动。

如果您想重用相同的数据，那么根据定义，您要么必须生成它两次（确定性地），要么存储它。如果它已经碰巧在一个集合中，那很好；那么迭代两次是很便宜的。

我们用“分叉溪流”做了设计实验。我们发现，支持这一计划是有实际成本的；它以牺牲不常见的情况为代价，加重了普通情况（使用一次）的负担。最大的问题是处理“当两个管道不以相同的速率消耗数据时会发生什么”。现在你又回到缓冲了。这是一个明显不起作用的特点。

如果您希望重复操作相同的数据，可以存储它，或者将您的操作结构化为使用者，并执行以下操作：

stream()...stuff....forEach(e -> { consumerA(e); consumerB(e); });

您还可以研究一下RxJava库，因为它的处理模型更适合这种“流分叉”。