| commit | 4de242b18a1b5ea599ae6962cd213dd573f90370 | [log] [tgz] |
|---|---|---|
| author | Marco Miller <marco.miller@ericsson.com> | Thu Jan 17 12:28:59 2019 -0500 |
| committer | Marco Miller <marco.miller@ericsson.com> | Thu Jan 17 12:29:39 2019 -0500 |
| tree | fe08af1eebce4ae9dc8e1901539cd05dc1044c56 | |
| parent | 3be543b0d4163cd42ba82b3de5787a6c0cafe399 [diff] |
RestForwarder: Replace lambda with method reference Change-Id: I6488c8558fcca3b144feb886a41f7759efb42ebe
diff --git a/src/main/java/com/ericsson/gerrit/plugins/highavailability/forwarder/rest/RestForwarder.java b/src/main/java/com/ericsson/gerrit/plugins/highavailability/forwarder/rest/RestForwarder.java index 32c56bf..15c3f63 100644 --- a/src/main/java/com/ericsson/gerrit/plugins/highavailability/forwarder/rest/RestForwarder.java +++ b/src/main/java/com/ericsson/gerrit/plugins/highavailability/forwarder/rest/RestForwarder.java
@@ -133,7 +133,7 @@ .get() .stream() .map(peer -> createRequest(method, peer, action, endpoint, id, payload)) - .map(request -> CompletableFuture.supplyAsync(() -> request.execute())) + .map(request -> CompletableFuture.supplyAsync(request::execute)) .collect(Collectors.toList()); CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join(); return futures.stream().allMatch(CompletableFuture::join);