diff --git a/spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/Client.java b/spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/Client.java index 3c6623cb02..9afe50af58 100644 --- a/spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/Client.java +++ b/spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/Client.java @@ -6,9 +6,12 @@ import reactor.core.publisher.Flux; import reactor.core.scheduler.Schedulers; import java.util.List; +import java.util.logging.Logger; public class Client { + private static final Logger LOG = Logger.getLogger(Client.class.getName()); + private WebClient webClient; public Client(String uri) { @@ -16,6 +19,8 @@ public class Client { } public Mono getUser(int id) { + LOG.info(String.format("Calling getUser(%d)", id)); + return webClient.get() .uri("/user/{id}", id) .retrieve() diff --git a/spring-5-reactive-client/src/test/java/com/baeldung/reactive/webclient/simultaneous/ClientIntegrationTest.java b/spring-5-reactive-client/src/test/java/com/baeldung/reactive/webclient/simultaneous/ClientIntegrationTest.java index 99efd34f9f..0acedf15b0 100644 --- a/spring-5-reactive-client/src/test/java/com/baeldung/reactive/webclient/simultaneous/ClientIntegrationTest.java +++ b/spring-5-reactive-client/src/test/java/com/baeldung/reactive/webclient/simultaneous/ClientIntegrationTest.java @@ -36,7 +36,7 @@ public class ClientIntegrationTest { } @Test - public void checkIfCallsAreExecutedSimultaneously() { + public void givenClient_whenFetchingUsers_thenExecutionTimeIsLessThanDouble() { // Arrange int requestsNumber = 5; int singleRequestTime = 1000;