1
1
/*
2
- * Hedera Block Node
3
- *
4
2
* Copyright (C) 2024 Hedera Hashgraph, LLC
5
3
*
6
4
* Licensed under the Apache License, Version 2.0 (the "License");
@@ -68,7 +66,8 @@ public Descriptors.FileDescriptor proto() {
68
66
}
69
67
70
68
/**
71
- * Returns the service name for the BlockStreamService. This service name corresponds to the service name in the proto file.
69
+ * Returns the service name for the BlockStreamService. This service name corresponds to the service name in
70
+ * the proto file.
72
71
*
73
72
* @return the service name
74
73
*/
@@ -91,10 +90,10 @@ public void update(final Routing routing) {
91
90
/**
92
91
* The streamSink method is called by Helidon each time a producer initiates a bidirectional stream.
93
92
*
94
- * @param responseStreamObserver - Helidon provides a StreamObserver to handle responses back to the producer.
93
+ * @param responseStreamObserver Helidon provides a StreamObserver to handle responses back to the producer.
95
94
*
96
- * @return a custom StreamObserver to handle streaming blocks from the producer to all subscribed consumers
97
- * via the streamMediator as well as sending responses back to the producer.
95
+ * @return a custom StreamObserver to handle streaming blocks from the producer to all subscribed consumer
96
+ * via the streamMediator as well as sending responses back to the producer.
98
97
*/
99
98
private StreamObserver <BlockStreamServiceGrpcProto .Block > streamSink (
100
99
final StreamObserver <BlockStreamServiceGrpcProto .BlockResponse > responseStreamObserver ) {
@@ -106,11 +105,11 @@ private StreamObserver<BlockStreamServiceGrpcProto.Block> streamSink(
106
105
/**
107
106
* The streamSource method is called by Helidon each time a consumer initiates a bidirectional stream.
108
107
*
109
- * @param responseStreamObserver - Helidon provides a StreamObserver to handle responses from the consumer
110
- * back to the server.
108
+ * @param responseStreamObserver Helidon provides a StreamObserver to handle responses from the consumer
109
+ * back to the server.
111
110
*
112
- * @return a custom StreamObserver to handle streaming blocks from the producer to the consumer as well as
113
- * handling responses from the consumer.
111
+ * @return a custom StreamObserver to handle streaming blocks from the producer to the consumer as well
112
+ * as handling responses from the consumer.
114
113
*/
115
114
private StreamObserver <BlockStreamServiceGrpcProto .BlockResponse > streamSource (final StreamObserver <BlockStreamServiceGrpcProto .Block > responseStreamObserver ) {
116
115
LOGGER .log (System .Logger .Level .DEBUG , "Executing bidirectional streamSource method" );
0 commit comments