wait for completion using allOf().joins()

C-Otto · Jun 7, 2024 · 08d06ac · 08d06ac
1 parent 4fdfa4e
commit 08d06ac
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/backend/src/main/java/de/cotto/lndmanagej/service/ChannelDetailsService.java b/backend/src/main/java/de/cotto/lndmanagej/service/ChannelDetailsService.java
@@ -66,6 +66,18 @@ public ChannelDetails getDetails(LocalChannel localChannel) {
         CompletableFuture<ChannelWarnings> channelWarnings = getChannelWarnings(localChannel);
         CompletableFuture<Optional<ChannelRating>> rating = getRating(channelId);
         try {
+            CompletableFuture.allOf(
+                    remoteAlias,
+                    balanceInformation,
+                    onChainCosts,
+                    policies,
+                    feeReport,
+                    flowReport,
+                    rebalanceReport,
+                    channelWarnings,
+                    rating
+            ).join();
+
             return new ChannelDetails(
                     localChannel,
                     remoteAlias.get(),

diff --git a/backend/src/main/java/de/cotto/lndmanagej/service/NodeDetailsService.java b/backend/src/main/java/de/cotto/lndmanagej/service/NodeDetailsService.java
@@ -78,6 +78,17 @@ public NodeDetails getDetails(Pubkey pubkey) {
         List<ChannelId> forceClosingChannelIds =
                 getSortedChannelIds(channelService.getForceClosingChannelsWith(pubkey));
         try {
+            CompletableFuture.allOf(
+                    node,
+                    onlineReport,
+                    onChainCosts,
+                    balanceInformation,
+                    feeReport,
+                    flowReport,
+                    rebalanceReport,
+                    nodeWarnings,
+                    rating
+            ).join();
             return new NodeDetails(
                     pubkey,
                     node.get().alias(),