public static final class StreamingServiceGrpc.StreamingServiceStub extends AbstractAsyncStub<StreamingServiceGrpc.StreamingServiceStub>A stub to allow clients to do asynchronous rpc calls to service StreamingService.
Streaming service for receiving and sending packets.
Inheritance
java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > StreamingServiceGrpc.StreamingServiceStubMethods
acquireLease(AcquireLeaseRequest request, StreamObserver<Lease> responseObserver)
public void acquireLease(AcquireLeaseRequest request, StreamObserver<Lease> responseObserver)AcquireLease acquires a lease.
| Parameters | |
|---|---|
| Name | Description |
request |
AcquireLeaseRequest |
responseObserver |
io.grpc.stub.StreamObserver<Lease> |
build(Channel channel, CallOptions callOptions)
protected StreamingServiceGrpc.StreamingServiceStub build(Channel channel, CallOptions callOptions)| Parameters | |
|---|---|
| Name | Description |
channel |
io.grpc.Channel |
callOptions |
io.grpc.CallOptions |
| Returns | |
|---|---|
| Type | Description |
StreamingServiceGrpc.StreamingServiceStub |
|
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
receiveEvents(StreamObserver<ReceiveEventsResponse> responseObserver)
public StreamObserver<ReceiveEventsRequest> receiveEvents(StreamObserver<ReceiveEventsResponse> responseObserver)Receive events given the stream name.
| Parameter | |
|---|---|
| Name | Description |
responseObserver |
io.grpc.stub.StreamObserver<ReceiveEventsResponse> |
| Returns | |
|---|---|
| Type | Description |
io.grpc.stub.StreamObserver<ReceiveEventsRequest> |
|
receivePackets(StreamObserver<ReceivePacketsResponse> responseObserver)
public StreamObserver<ReceivePacketsRequest> receivePackets(StreamObserver<ReceivePacketsResponse> responseObserver)Receive packets from the series.
| Parameter | |
|---|---|
| Name | Description |
responseObserver |
io.grpc.stub.StreamObserver<ReceivePacketsResponse> |
| Returns | |
|---|---|
| Type | Description |
io.grpc.stub.StreamObserver<ReceivePacketsRequest> |
|
releaseLease(ReleaseLeaseRequest request, StreamObserver<ReleaseLeaseResponse> responseObserver)
public void releaseLease(ReleaseLeaseRequest request, StreamObserver<ReleaseLeaseResponse> responseObserver)RleaseLease releases a lease.
| Parameters | |
|---|---|
| Name | Description |
request |
ReleaseLeaseRequest |
responseObserver |
io.grpc.stub.StreamObserver<ReleaseLeaseResponse> |
renewLease(RenewLeaseRequest request, StreamObserver<Lease> responseObserver)
public void renewLease(RenewLeaseRequest request, StreamObserver<Lease> responseObserver)RenewLease renews a lease.
| Parameters | |
|---|---|
| Name | Description |
request |
RenewLeaseRequest |
responseObserver |
io.grpc.stub.StreamObserver<Lease> |
sendPackets(StreamObserver<SendPacketsResponse> responseObserver)
public StreamObserver<SendPacketsRequest> sendPackets(StreamObserver<SendPacketsResponse> responseObserver)Send packets to the series.
| Parameter | |
|---|---|
| Name | Description |
responseObserver |
io.grpc.stub.StreamObserver<SendPacketsResponse> |
| Returns | |
|---|---|
| Type | Description |
io.grpc.stub.StreamObserver<SendPacketsRequest> |
|