[CI] Auto commit changes from spotless

Author: elasticsearchmachine

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/results/StreamingUnifiedChatCompletionResults.java

@@ -35,9 +35,7 @@
 /**
  * Chat Completion results that only contain a Flow.Publisher.
  */
-public record StreamingUnifiedChatCompletionResults(Flow.Publisher<Results> publisher)
-    implements
-        InferenceServiceResults {
+public record StreamingUnifiedChatCompletionResults(Flow.Publisher<Results> publisher) implements InferenceServiceResults {
 
     public static final String NAME = "chat_completion_chunk";
     public static final String MODEL_FIELD = "model";

x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/inference/results/StreamingUnifiedChatCompletionResultsTests.java

@@ -213,10 +213,10 @@ public void testBufferedPublishing() {
             downstream.onSubscribe(new Flow.Subscription() {
                 @Override
                 public void request(long n) {
-                    if(completed.compareAndSet(false, true)) {
+                    if (completed.compareAndSet(false, true)) {
                         downstream.onNext(new StreamingUnifiedChatCompletionResults.Results(results));
                     } else {
-                    downstream.onComplete();
+                        downstream.onComplete();
                     }
                 }
 
@@ -232,7 +232,7 @@ public void cancel() {
         streamingResults.publisher().subscribe(new Flow.Subscriber<>() {
             @Override
             public void onSubscribe(Flow.Subscription subscription) {
-                if(upstream.compareAndSet(null, subscription) == false) {
+                if (upstream.compareAndSet(null, subscription) == false) {
                     fail("Upstream already set?!");
                 }
                 subscription.request(1);
@@ -243,7 +243,7 @@ public void onNext(StreamingUnifiedChatCompletionResults.Results item) {
                 assertNotNull(item);
                 counter.incrementAndGet();
                 var sub = upstream.get();
-                if(sub != null) {
+                if (sub != null) {
                     sub.request(1);
                 } else {
                     fail("Upstream not yet set?!");
@@ -256,8 +256,7 @@ public void onError(Throwable throwable) {
             }
 
             @Override
-            public void onComplete() {
-            }
+            public void onComplete() {}
         });
         assertThat(counter.get(), equalTo(2));
     }