Skip to content

Commit

Permalink
properly align code
Browse files Browse the repository at this point in the history
Signed-off-by: Ludovic Orban <[email protected]>
  • Loading branch information
lorban committed Dec 11, 2023
1 parent ec74550 commit 126ae5c
Showing 1 changed file with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -205,16 +205,16 @@ public CompletableFuture<Void> begin() {
.thenCompose(v -> CompletableFuture.allOf(responses));
})
.thenRun(this::fireCompleteEvent)
// HttpClient cannot be stopped from one of its own threads.
.whenCompleteAsync((r, x) ->
{
if (LOGGER.isDebugEnabled())
// HttpClient cannot be stopped from one of its own threads.
.whenCompleteAsync((r, x) ->
{
LOGGER.debug("stopping http clients");
}
Collection<HttpClient> clients = getBeans(HttpClient.class);
clients.forEach(this::stopHttpClient);
}, executorService)
if (LOGGER.isDebugEnabled())
{
LOGGER.debug("stopping http clients");
}
Collection<HttpClient> clients = getBeans(HttpClient.class);
clients.forEach(this::stopHttpClient);
}, executorService)
// Call halt() even if previous stages failed.
.whenCompleteAsync((r, x) -> halt(), executorService);
}
Expand Down

0 comments on commit 126ae5c

Please sign in to comment.