undo format fixes

Author: xylos19

src/main/java/org/springframework/data/elasticsearch/core/AbstractReactiveElasticsearchTemplate.java

@@ -60,8 +60,7 @@
 import org.springframework.util.Assert;
 
 /**
- * Base class keeping common code for implementations of the
- * {@link ReactiveElasticsearchOperations} interface
+ * Base class keeping common code for implementations of the {@link ReactiveElasticsearchOperations} interface
  * independent of the used client.
  *
  * @author Peter-Josef Meisch
@@ -149,10 +148,8 @@ public RefreshPolicy getRefreshPolicy() {
 	}
 
 	/**
-	 * Set the {@link ReactiveEntityCallbacks} instance to use when invoking
-	 * {@link ReactiveEntityCallbacks callbacks}
-	 * like the {@link ReactiveBeforeConvertCallback}. Overrides potentially
-	 * existing {@link ReactiveEntityCallbacks}.
+	 * Set the {@link ReactiveEntityCallbacks} instance to use when invoking {@link ReactiveEntityCallbacks callbacks}
+	 * like the {@link ReactiveBeforeConvertCallback}. Overrides potentially existing {@link ReactiveEntityCallbacks}.
 	 *
 	 * @param entityCallbacks must not be {@literal null}.
 	 * @throws IllegalArgumentException if the given instance is {@literal null}.
@@ -177,8 +174,7 @@ public Mono<Void> logVersions() {
 		return getVendor()
 				.zipWith(getRuntimeLibraryVersion())
 				.zipWith(getClusterVersion())
-				.doOnNext(objects -> VersionInfo.logVersions(objects.getT1().getT1(), objects.getT1().getT2(),
-						objects.getT2()))
+				.doOnNext(objects -> VersionInfo.logVersions(objects.getT1().getT1(), objects.getT1().getT2(), objects.getT2()))
 				.then();
 	}
 
@@ -235,8 +231,7 @@ public <T> Flux<T> save(Flux<T> entities, IndexCoordinates index, int bulkSize)
 			entities
 					.bufferTimeout(bulkSize, Duration.ofMillis(200), true)
 					.subscribe(new Subscriber<>() {
-						@Nullable
-						private Subscription subscription = null;
+						@Nullable private Subscription subscription = null;
 						private final AtomicBoolean upstreamComplete = new AtomicBoolean(false);
 						private final AtomicBoolean onNextHasBeenCalled = new AtomicBoolean(false);
 
@@ -437,8 +432,7 @@ public Mono<ByQueryResponse> delete(DeleteQuery query, Class<?> entityType) {
 
 	// region SearchDocument
 	@Override
-	public <T> Flux<SearchHit<T>> search(Query query, Class<?> entityType, Class<T> resultType,
-			IndexCoordinates index) {
+	public <T> Flux<SearchHit<T>> search(Query query, Class<?> entityType, Class<T> resultType, IndexCoordinates index) {
 		SearchDocumentCallback<T> callback = new ReadSearchDocumentCallback<>(resultType, index);
 		return doFind(query, entityType, index).concatMap(callback::toSearchHit);
 	}
@@ -682,8 +676,7 @@ public Mono<T> toEntity(SearchDocument response) {
 
 		@Override
 		public Mono<SearchHit<T>> toSearchHit(SearchDocument response) {
-			return toEntity(response)
-					.map(entity -> SearchHitMapping.mappingFor(type, converter).mapHit(response, entity));
+			return toEntity(response).map(entity -> SearchHitMapping.mappingFor(type, converter).mapHit(response, entity));
 		}
 	}
 
@@ -747,8 +740,7 @@ public String getEntityRouting(Object entity) {
 	}
 
 	/**
-	 * Value class to capture client independent information from a response to an
-	 * index request.
+	 * Value class to capture client independent information from a response to an index request.
 	 */
 	public record IndexResponseMetaData(String id, String index, long seqNo, long primaryTerm, long version) {
 	}
@@ -774,8 +766,7 @@ public List<IndexQuery> indexQueries() {
 		}
 
 		public T entityAt(long index) {
-			// it's safe to cast to int because the original indexed collection was fitting
-			// in memory
+			// it's safe to cast to int because the original indexed collection was fitting in memory
 			int intIndex = (int) index;
 			return entities.get(intIndex);
 		}