File tree Expand file tree Collapse file tree 1 file changed +6
-5
lines changed
server/src/main/java/com/hedera/block/server/consumer Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Original file line number Diff line number Diff line change 19
19
import io .grpc .stub .StreamObserver ;
20
20
21
21
/**
22
- * The LiveStreamObserver interface augments the StreamObserver interface with the notify() method thereby
23
- * allowing a caller to pass a block to the observer of a different type than the StreamObserver. In this way,
24
- * the implementation of this interface can receive and process inbound messages with different types from
25
- * the producer and response messages from the consumer.
22
+ * The LiveStreamObserver interface augments the StreamObserver interface with the notify() method
23
+ * thereby allowing a caller to pass a block to the observer of a different type than the
24
+ * StreamObserver. In this way, the implementation of this interface can receive and process inbound
25
+ * messages with different types from the producer and response messages from the consumer.
26
26
*
27
27
* @param <U> the type of the block
28
28
* @param <V> the type of the StreamObserver
29
29
*/
30
- public interface LiveStreamObserver <U , V > extends StreamObserver <V > {
30
+ public interface LiveStreamObserver <U , V >
31
+ extends StreamObserver <V > {
31
32
32
33
/**
33
34
* Pass the block to the observer.
You can’t perform that action at this time.
0 commit comments