diff --git a/server/src/main/java/com/hedera/block/server/consumer/LiveStreamObserver.java b/server/src/main/java/com/hedera/block/server/consumer/LiveStreamObserver.java index 135ecb674..71e141eab 100644 --- a/server/src/main/java/com/hedera/block/server/consumer/LiveStreamObserver.java +++ b/server/src/main/java/com/hedera/block/server/consumer/LiveStreamObserver.java @@ -19,15 +19,16 @@ import io.grpc.stub.StreamObserver; /** - * The LiveStreamObserver interface augments the StreamObserver interface with the notify() method thereby - * allowing a caller to pass a block to the observer of a different type than the StreamObserver. In this way, - * the implementation of this interface can receive and process inbound messages with different types from - * the producer and response messages from the consumer. + * The LiveStreamObserver interface augments the StreamObserver interface with the notify() method + * thereby allowing a caller to pass a block to the observer of a different type than the + * StreamObserver. In this way, the implementation of this interface can receive and process inbound + * messages with different types from the producer and response messages from the consumer. * * @param the type of the block * @param the type of the StreamObserver */ -public interface LiveStreamObserver extends StreamObserver { +public interface LiveStreamObserver + extends StreamObserver { /** * Pass the block to the observer.