Class StreamingServiceGrpc.StreamingServiceStub (0.1.0)

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.StreamingServiceStub

Methods

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
Overrides
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>