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,然