wip: spotless

Signed-off-by: Matt Peterson <matt.peterson@swirldslabs.com>

Author: mattp-swirldslabs

server/src/main/java/com/hedera/block/server/consumer/ConsumerBlockItemObserver.java

@@ -16,22 +16,21 @@
 
 package com.hedera.block.server.consumer;
 
+import static com.hedera.block.protos.BlockStreamService.BlockItem;
+import static com.hedera.block.protos.BlockStreamService.SubscribeStreamResponse;
+
 import com.hedera.block.server.data.ObjectEvent;
 import com.hedera.block.server.mediator.StreamMediator;
 import io.grpc.stub.ServerCallStreamObserver;
 import io.grpc.stub.StreamObserver;
-
 import java.time.InstantSource;
 import java.util.concurrent.atomic.AtomicBoolean;
 
-import static com.hedera.block.protos.BlockStreamService.BlockItem;
-import static com.hedera.block.protos.BlockStreamService.SubscribeStreamResponse;
-
 /**
- * The ConsumerBlockItemObserver class is the primary integration point between the LMAX Disruptor and
- * an instance of a downstream consumer (represented by subscribeStreamResponseObserver provided by Helidon).
- * The ConsumerBlockItemObserver implements the EventHandler interface so the Disruptor can invoke
- * the onEvent() method when a new SubscribeStreamResponse is available.
+ * The ConsumerBlockItemObserver class is the primary integration point between the LMAX Disruptor
+ * and an instance of a downstream consumer (represented by subscribeStreamResponseObserver provided
+ * by Helidon). The ConsumerBlockItemObserver implements the EventHandler interface so the Disruptor
+ * can invoke the onEvent() method when a new SubscribeStreamResponse is available.
  */
 public class ConsumerBlockItemObserver
         implements BlockItemEventHandler<ObjectEvent<SubscribeStreamResponse>> {
@@ -114,7 +113,9 @@ public void onEvent(
         final long currentMillis = producerLivenessClock.millis();
         if (currentMillis - producerLivenessMillis > timeoutThresholdMillis) {
             streamMediator.unsubscribe(this);
-            LOGGER.log(System.Logger.Level.DEBUG, "Unsubscribed ConsumerBlockItemObserver due to producer timeout");
+            LOGGER.log(
+                    System.Logger.Level.DEBUG,
+                    "Unsubscribed ConsumerBlockItemObserver due to producer timeout");
         } else {
 
             // Only send the response if the consumer has not cancelled
@@ -133,7 +134,10 @@ public void onEvent(
                 }
 
                 if (streamStarted) {
-                    LOGGER.log(System.Logger.Level.DEBUG, "Send BlockItem downstream: {0} ", blockItem);
+                    LOGGER.log(
+                            System.Logger.Level.DEBUG,
+                            "Send BlockItem downstream: {0} ",
+                            blockItem);
                     subscribeStreamResponseObserver.onNext(subscribeStreamResponse);
                 }
             }

server/src/main/java/com/hedera/block/server/mediator/StreamMediator.java

@@ -20,10 +20,10 @@
 import java.io.IOException;
 
 /**
- * The StreamMediator interface represents a bridge between a bidirectional stream of
- * items from a producer (e.g. a Consensus Node) and N consumers each requesting a gRPC
- * server stream of items. The StreamMediator manages adding and removing consumers
- * dynamically to receive items as they arrive from upstream.
+ * The StreamMediator interface represents a bridge between a bidirectional stream of items from a
+ * producer (e.g. a Consensus Node) and N consumers each requesting a gRPC server stream of items.
+ * The StreamMediator manages adding and removing consumers dynamically to receive items as they
+ * arrive from upstream.
  *
  * @param <U> The type of items sent by the upstream producer.
  * @param <V> The type of the response published to the downstream consumers.