completable-future

    1热度

    1回答

    我在玩CompletableFuture连锁店,偶然发现了意外行为的情况(至少对我来说):如果在.thenCompose()调用中传递了一个例外的CompletableFuture,则生成的CompletableFuture将完成原始异常包装在CompletionException。这可能是很难理解没有一个例子: public static <T> CompletableFuture<T> exc

    2热度

    1回答

    在Java中使用CompletableFuture时遇到问题。 我有2个选择请求,这些请求在从服务器接收响应时填充。 在连接线程(线程1)(使用反应器)中,我使用: if(hasException) { selectFuture.completeExceptionally(new ClientException(errorCode)); } else { System.out

    1热度

    1回答

    我试图处理Kotlin中的CompletableFuture异常,但我无法弄清楚如何提供适当的参数。因此,举例来说,我有: CompletableFuture.runAsync { "sr" } .exceptionally{e -> {}} 但随后的编译器抱怨Cannot infer type parameter T。 我该如何解决这个问题?

    0热度

    2回答

    重新抛出exceptionally内部异常似乎不允许使用CompletionStage方法。 我需要检查某一种异常的,如果没有我需要把它重新抛出回: Future<JsonNode> futureSite = someClient.getSite(siteId, queryParams); CompletionStage<JsonNode> outcome = FutureConverters

    1热度

    2回答

    我有一个关于Java中的CompletableFuture的问题。我正在等待CompletableFuture完成,并根据收到的结果,我想要么调用一个新任务,并等待CompletableFuture完成或做一些不同的事情。我对我的解决方案不满意,因为有太多的回调,而且它不同于阅读。你能帮我改进我的代码吗? final CompletableFuture<String> future = new C

    2热度

    2回答

    我有一系列的thenCompose通话,类似于 myObject.updateDB(payload) .thenCompose(__ -> getUserID(payload.ID())) .thenCompose(id -> getProfile(id)) .thenCompose(userProfile -> updateSomething(userProf

    1热度

    1回答

    我写了一个简单的例子来理解CompletableFuture。但是,当我在控制台上打印它。有时它只是显示“ASYN演示” 这是我的代码 public class DemoAsyn extends Thread { public static void main(String[] args) { List<String> mailer = Arrays.asList("[ema

    1热度

    1回答

    我有点困惑,现在我,所以我也应该返回CompletableFuture<List<A>> 方法里面的方法值是: CompletableFuture<List<String>> toReturn = asyncCall().thenApply(....) .thenCompose(listOfStuff -> convertToList(listOfStuff.stream().map(

    2热度

    1回答

    我试图返回一个CompletableFuture,它将返回来自Amazon的响应。我的代码首先检查是否响应缓存在本地。如果是这样,它会返回响应,否则会调用亚马逊。 [注意:真正的版本也会缓存从亚马逊收到的响应,但我没有包括,因为代码已经非常复杂。] 有没有办法改变我的callAmazon方法的实现方法重新组织代码),以便我不必“手动”将响应状态从amazonApi复制到finalResponse?

    1热度

    1回答

    我看到CompletableFuture有一个方法handle是相同阶Future的handle基本上转换成功和例外所有成功是map和flatMap上游的(或在java世界中的thenApply和thenCompose)。在Java中,什么是twitter未来rescue(或者scala未来recoverWith)的等价物? rescue在斯卡拉基本上就像老的java try....catch,然