java - 如何在 Java8 流中管理附带效果

Question

我知道 Java8 中的流只能收集一次(如 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(Consumer action)

Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.

This is an intermediate operation.

它允许您在使用 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>
}