BAEL-3285 - code reformatted

spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/Client.java

@@ -1,4 +1,4 @@
-package com.baeldung.reactive.simultaneouswebclient;
+package com.baeldung.reactive.webclient.simultaneous;
 
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Mono;
@@ -16,24 +16,21 @@ public class Client {
     }
 
     public Mono<User> getUser(int id) {
-        return webClient
+        return webClient.get()
-            .get()
             .uri("/user/{id}", id)
             .retrieve()
             .bodyToMono(User.class);
     }
 
     public Mono<Item> getItem(int id) {
-        return webClient
+        return webClient.get()
-            .get()
             .uri("/item/{id}", id)
             .retrieve()
             .bodyToMono(Item.class);
     }
 
     public Mono<User> getOtherUser(int id) {
-        return webClient
+        return webClient.get()
-            .get()
             .uri("/otheruser/{id}", id)
             .retrieve()
             .bodyToMono(User.class);
@@ -45,7 +42,7 @@ public class Client {
             .runOn(Schedulers.elastic())
             .flatMap(this::getUser)
             .collectSortedList((u1, u2) -> u2.id() - u1.id())
-          .block();
+            .block();
     }
 
     public List<User> fetchUserAndOtherUser(int id) {
@@ -61,6 +58,6 @@ public class Client {
         Mono<Item> item = getItem(itemId).subscribeOn(Schedulers.elastic());
 
         return Mono.zip(user, item, UserWithItem::new)
-          .block();
+            .block();
     }
 }

spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/Item.java

@@ -1,4 +1,4 @@
-package com.baeldung.reactive.simultaneouswebclient;
+package com.baeldung.reactive.webclient.simultaneous;
 
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;

spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/User.java

@@ -1,4 +1,4 @@
-package com.baeldung.reactive.simultaneouswebclient;
+package com.baeldung.reactive.webclient.simultaneous;
 
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;

spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/UserWithItem.java

@@ -1,4 +1,4 @@
-package com.baeldung.reactive.simultaneouswebclient;
+package com.baeldung.reactive.webclient.simultaneous;
 
 public class UserWithItem {
     private User user;

spring-5-reactive-client/src/test/java/com/baeldung/reactive/webclient/simultaneous/ClientIntegrationTest.java

@@ -1,4 +1,4 @@
-package com.baeldung.reactive.simultaneouswebclient;
+package com.baeldung.reactive.webclient.simultaneous;
 
 import org.junit.Test;
 import org.junit.Before;
@@ -8,7 +8,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 import com.github.tomakehurst.wiremock.WireMockServer;
 
-import java.util.Arrays;
 import java.util.List;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
@@ -43,17 +42,15 @@ public class ClientIntegrationTest {
         int singleRequestTime = 1000;
 
         for (int i = 1; i <= requestsNumber; i++) {
-            stubFor(
+            stubFor(get(urlEqualTo("/user/" + i)).willReturn(aResponse().withFixedDelay(singleRequestTime)
-              get(urlEqualTo("/user/" + i)).willReturn(aResponse()
-                .withFixedDelay(singleRequestTime)
                 .withStatus(200)
                 .withHeader("Content-Type", "application/json")
                 .withBody(String.format("{ \"id\": %d }", i))));
         }
 
         List<Integer> userIds = IntStream.rangeClosed(1, requestsNumber)
-          .boxed()
+            .boxed()
-          .collect(Collectors.toList());
+            .collect(Collectors.toList());
 
         Client client = new Client("http://localhost:8089");