如何在 Java8 流中管理附带影响

Question

我知道 Java8 中的 Streams 只能收集一次（如在 forEach() 终止中），但我想知道我们是否可以设法“挖掘”到位于过滤和映射任务链中间的流产生一些附带效应。

本质上，“点击”就像执行 forEach() 但在管道的那个点返回 Stream。

我会这样使用它：

List<User> createAndPersistRandomUsers(int count) {
  return IntStream.range(0, count)
    .boxed() // returns Stream<Integer>
    .map(UserBuilder::random) // returns Stream<User>
    .tap(userRepo::persist) // Collateral persist of user, returns Stream<User>
    .collect(toList()); // returns List<User>
}

有什么想法吗？

Answer 1

我能想到的最接近你想要的东西是peek：

Stream peek（消费者操作）

返回一个由该流的元素组成的流， 另外对每个元素执行提供的操作 元素从结果流中消耗。

这是一个中间操作。

它允许您在 Stream 被消费时对 Stream 的元素执行操作。

List<User> createAndPersistRandomUsers(int count) {
  return IntStream.range(0, count)
    .boxed() // returns Stream<Integer>
    .map(UserBuilder::random) // returns Stream<User>
    .peek(userRepo::persist) // Collateral persist of user, returns Stream<User>
    .collect(toList()); // returns List<User>
}