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 request = Sinks.many().unicast().onBackpressureBuffer(); - FluxProcessor inbound = FluxProcessor.fromSink(Sinks.many().unicast().onBackpressureBuffer()); + FluxProcessor inbound = FluxProcessor + .fromSink(Sinks.many().unicast().onBackpressureBuffer()); Flux exchange = request.asFlux().flatMap(it -> {