Streams peek（）的未来等价物是什么？

Question

这里的答案引用了一个包含所有完全未来方法的表，但这并不是我要找的，或者我可能搞错了。

我正在寻找Streams'peek（）的完全未来等价物，因此基本上是一个返回输入参数的thenApply，或者一个不返回Void的thenRun。我认为有两种方法都不能在语义上准确地表达我的意图，但可以做到这一点：

(..)
.thenApply((a) -> {
   doSomething();
   return a;
}
(..)

和

java prettyprint-override">(..)
.whenComplete((result, exception) -> {
   if (exception == null) {
      doSomething();
   }
}
(..)

两者都从上一个阶段获取输入，允许我执行一个操作并以相同的类型返回到下一个阶段。在这两种方法中，后一种方法将我的时间限制在其他事情完成时，而不是在前一个必要阶段完成后立即异步。

我也一直在寻找一个以消费者函数为参数的身份函数，但似乎我必须自己写：

public static <T> Function<T, T> identityConsumer(Consumer<T> c) {
    return a -> { c.accept(a); return a; };
}

java prettyprint-override">(..)
.thenApply(identityConsumer(a -> doSomething()));
(..)

在编写自己的util函数之前，有没有一种优雅的方法可以在中间阶段执行操作，在中间阶段我不必返回某些内容，同时保持阶段的当前类型？

Answer 1

与Stream不同，您可以从一个未来生成多个函数链，因此不必在一个调用链中完成所有操作。我会这样处理你的问题：

var f1 = CompletableFuture.supplyAsync(...);
f1.thenRun(() -> doSomething()); // this is your "peek"
var f2 = f1.thenApply(...); // continue your chain of operations here