Skip to content

Commit 0cfb1b5

Browse files
committed
DATAES-894 - Polishing.
Reformat code. Add author tag. Original pull request: spring-projects#498.
1 parent 103bf9f commit 0cfb1b5

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,6 +142,7 @@
142142
* @author Roman Puchkovskiy
143143
* @author Russell Parry
144144
* @author Thomas Geese
145+
* @author Brian Clozel
145146
* @since 3.2
146147
* @see ClientConfiguration
147148
* @see ReactiveRestClients
@@ -468,7 +469,8 @@ public Flux<SearchHit> scroll(HttpHeaders headers, SearchRequest searchRequest)
468469

469470
Sinks.Many<ActionRequest> request = Sinks.many().unicast().onBackpressureBuffer();
470471

471-
FluxProcessor<SearchResponse, SearchResponse> inbound = FluxProcessor.fromSink(Sinks.many().unicast().onBackpressureBuffer());
472+
FluxProcessor<SearchResponse, SearchResponse> inbound = FluxProcessor
473+
.fromSink(Sinks.many().unicast().onBackpressureBuffer());
472474

473475
Flux<SearchResponse> exchange = request.asFlux().flatMap(it -> {
474476

0 commit comments

Comments
 (0)