Skip to content

Commit f246ff2

Browse files
git:spotless
Signed-off-by: Matt Peterson <[email protected]>
1 parent 6988dde commit f246ff2

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

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

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,16 +16,15 @@
1616

1717
package com.hedera.block.server.consumer;
1818

19+
import static com.hedera.block.protos.BlockStreamService.BlockItem;
20+
import static com.hedera.block.protos.BlockStreamService.SubscribeStreamResponse;
21+
1922
import com.hedera.block.server.data.ObjectEvent;
2023
import com.hedera.block.server.mediator.StreamMediator;
2124
import io.grpc.stub.ServerCallStreamObserver;
2225
import io.grpc.stub.StreamObserver;
23-
2426
import java.time.InstantSource;
2527

26-
import static com.hedera.block.protos.BlockStreamService.BlockItem;
27-
import static com.hedera.block.protos.BlockStreamService.SubscribeStreamResponse;
28-
2928
/**
3029
* The LiveStreamObserverImpl class implements the LiveStreamObserver interface to pass blocks to
3130
* the downstream consumer via the notify method and manage the bidirectional stream to the consumer
@@ -115,6 +114,5 @@ public void onEvent(final ObjectEvent<BlockItem> event, final long l, final bool
115114
}
116115

117116
@Override
118-
public void awaitShutdown() throws InterruptedException {
119-
}
117+
public void awaitShutdown() throws InterruptedException {}
120118
}

0 commit comments

Comments
 (0)