fix: removed unnecessary interface

Signed-off-by: Matt Peterson <[email protected]>
hashgraph · Aug 11, 2024 · b2e4cde · b2e4cde
1 parent dd1c67b
commit b2e4cde
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 54 deletions.
diff --git a/server/src/main/java/com/hedera/block/server/mediator/LiveStreamMediatorBuilder.java b/server/src/main/java/com/hedera/block/server/mediator/LiveStreamMediatorBuilder.java
@@ -30,8 +30,7 @@
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
-public class LiveStreamMediatorBuilder
-        implements StreamMediatorBuilder<BlockItem, SubscribeStreamResponse> {
+public class LiveStreamMediatorBuilder {
 
     private final BlockWriter<BlockItem> blockWriter;
     private ServiceStatus serviceStatus;
@@ -53,23 +52,20 @@ private LiveStreamMediatorBuilder(
     }
 
     @NonNull
-    public static StreamMediatorBuilder<BlockItem, SubscribeStreamResponse> newBuilder(
+    public static LiveStreamMediatorBuilder newBuilder(
             @NonNull final BlockWriter<BlockItem> blockWriter,
             @NonNull final BlockNodeContext blockNodeContext) {
         return new LiveStreamMediatorBuilder(blockWriter, blockNodeContext);
     }
 
     @NonNull
-    @Override
-    public StreamMediatorBuilder<BlockItem, SubscribeStreamResponse> serviceStatus(
-            @NonNull final ServiceStatus serviceStatus) {
+    public LiveStreamMediatorBuilder serviceStatus(@NonNull final ServiceStatus serviceStatus) {
         this.serviceStatus = serviceStatus;
         return this;
     }
 
     @NonNull
-    @Override
-    public StreamMediatorBuilder<BlockItem, SubscribeStreamResponse> subscribers(
+    public LiveStreamMediatorBuilder subscribers(
             @NonNull
                     final Map<
                                     EventHandler<ObjectEvent<SubscribeStreamResponse>>,
@@ -80,7 +76,6 @@ public StreamMediatorBuilder<BlockItem, SubscribeStreamResponse> subscribers(
     }
 
     @NonNull
-    @Override
     public StreamMediator<BlockItem, ObjectEvent<SubscribeStreamResponse>> build() {
         return new LiveStreamMediatorImpl(
                 subscribers, blockWriter, serviceStatus, blockNodeContext);

diff --git a/server/src/main/java/com/hedera/block/server/mediator/StreamMediatorBuilder.java b/server/src/main/java/com/hedera/block/server/mediator/StreamMediatorBuilder.java
diff --git a/server/src/test/java/com/hedera/block/server/BlockStreamServiceIT.java b/server/src/test/java/com/hedera/block/server/BlockStreamServiceIT.java
@@ -571,7 +571,6 @@ private BlockStreamService buildBlockStreamService() throws IOException {
         final var streamMediator =
                 buildStreamMediator(new ConcurrentHashMap<>(32), Util.defaultPerms);
 
-        // Build the BlockStreamService
         return buildBlockStreamService(streamMediator, blockReader, serviceStatus);
     }