Polish

Signed-off-by: Violeta Georgieva <696661+violetagg@users.noreply.github.com>

Author: violetagg

reactor-netty-http/src/test/java/reactor/netty/http/server/HttpServerOutboundCompleteTest.java

@@ -267,30 +267,30 @@ void httpPipeliningGetRespondsSendMono(boolean enableMetricsAndAccessLog) throws
 
 			Connection client =
 					TcpClient.create()
-							.port(disposableServer.port())
-							.wiretap(true)
-							.connectNow();
+					         .port(disposableServer.port())
+					         .wiretap(true)
+					         .connectNow();
 
 			int port = disposableServer.port();
 			String address = HttpUtil.formatHostnameForHttp((InetSocketAddress) disposableServer.address()) + ":" + port;
 			String request = repeatString("GET /%s HTTP/1.1\r\nHost: " + address + "\r\n\r\n");
 			client.outbound()
-					.sendObject(Unpooled.wrappedBuffer(request.getBytes(Charset.defaultCharset())))
-					.then()
-					.subscribe();
+			      .sendObject(Unpooled.wrappedBuffer(request.getBytes(Charset.defaultCharset())))
+			      .then()
+			      .subscribe();
 
 			CountDownLatch responses = new CountDownLatch(16);
 			client.inbound()
-					.receive()
-					.asString()
-					.doOnNext(s -> {
-						int ind = 0;
-						while ((ind = s.indexOf("200", ind)) != -1) {
-							responses.countDown();
-							ind += 3;
-						}
-					})
-					.subscribe();
+			      .receive()
+			      .asString()
+			      .doOnNext(s -> {
+			          int ind = 0;
+			          while ((ind = s.indexOf("200", ind)) != -1) {
+			              responses.countDown();
+			              ind += 3;
+			          }
+			      })
+			      .subscribe();
 
 			assertThat(responses.await(5, TimeUnit.SECONDS)).isTrue();
 
@@ -340,30 +340,30 @@ void httpPipeliningGetRespondsSendObject(boolean enableMetricsAndAccessLog) thro
 
 			Connection client =
 					TcpClient.create()
-							.port(disposableServer.port())
-							.wiretap(true)
-							.connectNow();
+					         .port(disposableServer.port())
+					         .wiretap(true)
+					         .connectNow();
 
 			int port = disposableServer.port();
 			String address = HttpUtil.formatHostnameForHttp((InetSocketAddress) disposableServer.address()) + ":" + port;
 			String request = repeatString("GET /%s HTTP/1.1\r\nHost: " + address + "\r\n\r\n");
 			client.outbound()
-					.sendObject(Unpooled.wrappedBuffer(request.getBytes(Charset.defaultCharset())))
-					.then()
-					.subscribe();
+			      .sendObject(Unpooled.wrappedBuffer(request.getBytes(Charset.defaultCharset())))
+			      .then()
+			      .subscribe();
 
 			CountDownLatch responses = new CountDownLatch(16);
 			client.inbound()
-					.receive()
-					.asString()
-					.doOnNext(s -> {
-						int ind = 0;
-						while ((ind = s.indexOf("200", ind)) != -1) {
-							responses.countDown();
-							ind += 3;
-						}
-					})
-					.subscribe();
+			      .receive()
+			      .asString()
+			      .doOnNext(s -> {
+			          int ind = 0;
+			          while ((ind = s.indexOf("200", ind)) != -1) {
+			              responses.countDown();
+			              ind += 3;
+			          }
+			      })
+			      .subscribe();
 
 			assertThat(responses.await(5, TimeUnit.SECONDS)).isTrue();