Блог

Я вижу, что CompletableFuture у этого есть метод handle , который такой же, как у scala Future handle , в основном преобразующий успех и исключения в успех, чтобы быть map и flatMap вверх по течению (или thenApply и thenCompose в мире Java).

Что такое эквивалент twitter future rescue (или scala future recoverWith ) в java?

rescue в scala это в основном похоже на старую java try....catch , затем повторно добавляйте дополнительную информацию, чтобы ее было удобно использовать. Например, в twitterFuture.handle или scalaFuture.recover возвращаемая единица — это U то, что вы возвращаете ответ. В twitterFuture.rescue or scalaFuture.recoverWith он возвращает Future[U] , чтобы можно было принимать определенные исключения, добавлять дополнительную информацию и возвращать Future.exception(xxxxx)

Например recover , если вам не нужно возвращать суперкласс и вы хотите проглотить все исключения, вы можете просто использовать 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());