fix: removing this prefixes when they are not needed

Signed-off-by: Matt Peterson <[email protected]>

Author: mattp-swirldslabs

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

@@ -46,8 +46,8 @@ public class LiveStreamObserverImpl implements LiveStreamObserver<BlockStreamSer
      *
      */
     public LiveStreamObserverImpl(final long timeoutThresholdMillis,
-            StreamMediator<BlockStreamServiceGrpcProto.Block, BlockStreamServiceGrpcProto.BlockResponse> mediator,
-            StreamObserver<BlockStreamServiceGrpcProto.Block> responseStreamObserver) {
+            final StreamMediator<BlockStreamServiceGrpcProto.Block, BlockStreamServiceGrpcProto.BlockResponse> mediator,
+            final StreamObserver<BlockStreamServiceGrpcProto.Block> responseStreamObserver) {
 
         this.mediator = mediator;
         this.responseStreamObserver = responseStreamObserver;
@@ -65,14 +65,14 @@ public LiveStreamObserverImpl(final long timeoutThresholdMillis,
     @Override
     public void notify(final BlockStreamServiceGrpcProto.Block block) {
 
-        if (System.currentTimeMillis() - this.consumerLivenessMillis > timeoutThresholdMillis) {
+        if (System.currentTimeMillis() - consumerLivenessMillis > timeoutThresholdMillis) {
             if (mediator.isSubscribed(this)) {
                 LOGGER.log(System.Logger.Level.DEBUG, "Consumer timeout threshold exceeded.  Unsubscribing observer.");
                 mediator.unsubscribe(this);
             }
         } else {
-            this.producerLivenessMillis = System.currentTimeMillis();
-            this.responseStreamObserver.onNext(block);
+            producerLivenessMillis = System.currentTimeMillis();
+            responseStreamObserver.onNext(block);
         }
     }
 
@@ -84,14 +84,14 @@ public void notify(final BlockStreamServiceGrpcProto.Block block) {
     @Override
     public void onNext(final BlockStreamServiceGrpcProto.BlockResponse blockResponse) {
 
-        if (System.currentTimeMillis() - this.producerLivenessMillis > timeoutThresholdMillis) {
+        if (System.currentTimeMillis() - producerLivenessMillis > timeoutThresholdMillis) {
             if (mediator.isSubscribed(this)) {
                 LOGGER.log(System.Logger.Level.DEBUG, "Producer timeout threshold exceeded.  Unsubscribing observer.");
                 mediator.unsubscribe(this);
             }
         } else {
             LOGGER.log(System.Logger.Level.DEBUG, "Received response block " + blockResponse);
-            this.consumerLivenessMillis = System.currentTimeMillis();
+            consumerLivenessMillis = System.currentTimeMillis();
         }
     }
 

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

@@ -30,7 +30,6 @@
  * LiveStreamMediatorImpl is the implementation of the StreamMediator interface.  It is responsible for managing
  * the subscription and unsubscription operations of downstream consumers.  It also proxies new blocks
  * to the subscribers as they arrive and persists the blocks to the block persistence store.
- *
  */
 public class LiveStreamMediatorImpl implements StreamMediator<BlockStreamServiceGrpcProto.Block, BlockStreamServiceGrpcProto.BlockResponse> {
 
@@ -56,7 +55,7 @@ public LiveStreamMediatorImpl(final BlockPersistenceHandler<BlockStreamServiceGr
      */
     @Override
     public void subscribe(final LiveStreamObserver<BlockStreamServiceGrpcProto.Block, BlockStreamServiceGrpcProto.BlockResponse> liveStreamObserver) {
-        this.subscribers.add(liveStreamObserver);
+        subscribers.add(liveStreamObserver);
     }
 
     /**
@@ -66,7 +65,7 @@ public void subscribe(final LiveStreamObserver<BlockStreamServiceGrpcProto.Block
      */
     @Override
     public void unsubscribe(final LiveStreamObserver<BlockStreamServiceGrpcProto.Block, BlockStreamServiceGrpcProto.BlockResponse> liveStreamObserver) {
-        if (this.subscribers.remove(liveStreamObserver)) {
+        if (subscribers.remove(liveStreamObserver)) {
             LOGGER.log(System.Logger.Level.DEBUG, "Successfully removed observer from subscription list");
         } else {
             LOGGER.log(System.Logger.Level.ERROR, "Failed to remove observer from subscription list");
@@ -81,15 +80,15 @@ public void unsubscribe(final LiveStreamObserver<BlockStreamServiceGrpcProto.Blo
      */
     @Override
     public boolean isSubscribed(final LiveStreamObserver<BlockStreamServiceGrpcProto.Block, BlockStreamServiceGrpcProto.BlockResponse> observer) {
-        return this.subscribers.contains(observer);
+        return subscribers.contains(observer);
     }
 
     /**
      * Unsubscribe all observers from the mediator
      */
     @Override
     public void unsubscribeAll() {
-        this.subscribers.clear();
+        subscribers.clear();
     }
 
     /**

server/src/main/java/com/hedera/block/server/producer/ProducerBlockStreamObserver.java

@@ -61,7 +61,7 @@ public void onNext(final BlockStreamServiceGrpcProto.Block block) {
         streamMediator.notifyAll(block);
 
         final BlockStreamServiceGrpcProto.BlockResponse blockResponse = BlockStreamServiceGrpcProto.BlockResponse.newBuilder().setId(block.getId()).build();
-        this.responseStreamObserver.onNext(blockResponse);
+        responseStreamObserver.onNext(blockResponse);
     }
 
     /**
@@ -82,7 +82,7 @@ public void onError(final Throwable t) {
     @Override
     public void onCompleted() {
         LOGGER.log(System.Logger.Level.DEBUG, "ProducerBlockStreamObserver completed");
-        this.streamMediator.unsubscribeAll();
+        streamMediator.unsubscribeAll();
         LOGGER.log(System.Logger.Level.DEBUG, "Unsubscribed all downstream consumers");
     }
 }