Module com.hedera.hashgraph.sdk
Class ConsensusServiceGrpc.ConsensusServiceStub
java.lang.Object
io.grpc.stub.AbstractStub<ConsensusServiceGrpc.ConsensusServiceStub>
io.grpc.stub.AbstractAsyncStub<ConsensusServiceGrpc.ConsensusServiceStub>
com.hedera.hashgraph.sdk.proto.mirror.ConsensusServiceGrpc.ConsensusServiceStub
- Enclosing class:
ConsensusServiceGrpc
public static final class ConsensusServiceGrpc.ConsensusServiceStub
extends io.grpc.stub.AbstractAsyncStub<ConsensusServiceGrpc.ConsensusServiceStub>
A stub to allow clients to do asynchronous rpc calls to service ConsensusService.
The Mirror Service provides the ability to query a stream of Hedera Consensus Service (HCS) messages for an HCS Topic via a specific (possibly open-ended) time range.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>> -
Method Summary
Modifier and TypeMethodDescriptionbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) voidsubscribeTopic(ConsensusTopicQuery request, io.grpc.stub.StreamObserver<ConsensusTopicResponse> responseObserver) Methods inherited from class io.grpc.stub.AbstractAsyncStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
protected ConsensusServiceGrpc.ConsensusServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
buildin classio.grpc.stub.AbstractStub<ConsensusServiceGrpc.ConsensusServiceStub>
-
subscribeTopic
public void subscribeTopic(ConsensusTopicQuery request, io.grpc.stub.StreamObserver<ConsensusTopicResponse> responseObserver)
-