Java8 CompletableFuture recoveryWith等效吗？例如异常但返回CompletableFuture __

Question

__

我没有看到一种处理异步结果异常的明显方法。例如，如果我想重试异步操作。我会期望像这样的事情，但是handleAsync并没有按照您认为的那样做-
异步地在另一个线程上运行回调。在这里返回CompletionStage是不正确的。当天的危害问题：thenApply就是thenCompose因为exceptionally是为了什么？

CompletionStage<String> cf = askPong("cause error").handleAsync((x, t) -> {
    if (t != null) {
        return askPong("Ping");
    } else {
        return x;
    }
});

AskPong在哪里问演员：

public CompletionStage<String> askPong(String message){
    Future sFuture = ask(actorRef, message, 1000);
    final CompletionStage<String> cs = toJava(sFuture);
    return cs;
}

Answer 1

__

在试图找出用Java
8完成Scala的restoreWith的正确方法后，我大失所望，最后我还是自己写了。我仍然不知道这是否是最好的方法，但是我创建了以下内容：

public RecoveryChainAsync<T> recoverWith(Function<Throwable,
                                         CompletableFuture<T>> fn);

通过重复调用recoverWith，我将恢复链中的功能排入队列，并使用“
handle”自己实现恢复流程。然后，RecoveryChainAsync.getCompletableFuture（）返回整个链的代表性CompletableFuture。希望这可以帮助。