From 0cfb1b563ee0edcb414a71853bbb3ae162fdfeef Mon Sep 17 00:00:00 2001
From: Mark Paluch <mpaluch@pivotal.io>
Date: Wed, 5 Aug 2020 14:48:50 +0200
Subject: [PATCH] DATAES-894 - Polishing.

Reformat code. Add author tag.

Original pull request: #498.
---
 .../client/reactive/DefaultReactiveElasticsearchClient.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java b/src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java
index 8c05bca60..968ffe094 100644
--- a/src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java
+++ b/src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java
@@ -142,6 +142,7 @@ import org.springframework.web.reactive.function.client.WebClient.RequestBodySpe
  * @author Roman Puchkovskiy
  * @author Russell Parry
  * @author Thomas Geese
+ * @author Brian Clozel
  * @since 3.2
  * @see ClientConfiguration
  * @see ReactiveRestClients
@@ -468,7 +469,8 @@ public class DefaultReactiveElasticsearchClient implements ReactiveElasticsearch
 
 		Sinks.Many<ActionRequest> request = Sinks.many().unicast().onBackpressureBuffer();
 
-		FluxProcessor<SearchResponse, SearchResponse> inbound = FluxProcessor.fromSink(Sinks.many().unicast().onBackpressureBuffer());
+		FluxProcessor<SearchResponse, SearchResponse> inbound = FluxProcessor
+				.fromSink(Sinks.many().unicast().onBackpressureBuffer());
 
 		Flux<SearchResponse> exchange = request.asFlux().flatMap(it -> {