java - 什么是java CompletableFuture 相当于scala Future rescue and handle

Question

我看到 CompletableFuture 有一个方法 handle 与 scala Future 的 handle 相同> 基本上将成功和异常全部转换为成功，成为 map 和 flatMap 上游(或 thenApply 和 thenCompose 在 java 中世界)。

在 Java 中，twitter future rescue(或 scala future recoverWith)的等价物是什么？

scala 中的

rescue 基本上就像旧的 java try....catch，然后重新抛出更多信息，这样使用起来会很好。例如，在 twitterFuture.handle 或 scalaFuture.recover 中，返回单位是 U，因此您返回响应。在 twitterFuture.rescue 或 scalaFuture.recoverWith 中，它返回 Future[U] 因此可以采取某些异常(exception)，添加更多信息并返回 future .exception(xxxxx)

Answer 1

对于 recover ，如果你不需要返回一个父类(super class)并且想要吞下所有异常，你可以只使用 exceptionally :

CompletableFuture<T> future = ...;
CompletableFuture<T> newFuture = future.exceptionally(_exc -> defaultValue);

否则，你需要使用 handle 得到 CompletableFuture<CompletableFuture<U>> , 然后使用 thenCompose 折叠它:

CompletableFuture<T> future = ...;
CompletableFuture<T> newFuture = future.handle((v, e) -> {
        if (e == null) {
            return CompletableFuture.completedFuture(v);
        } else {
            // the real recoverWith part
            return applyFutureOnTheException(e);
        }
    }).thenCompose(Function.identity());