Class StreamingServiceGrpc.StreamingServiceStub (0.51.0)

0.51.0 (latest) 0.50.0 0.48.0 0.45.0 0.44.0 0.42.0 0.40.0 0.39.0 0.37.0 0.35.0 0.33.0 0.32.0 0.31.0 0.30.0 0.29.0 0.27.0 0.25.0 0.24.0 0.21.0 0.20.0 0.19.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 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

Inherited Members

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withOnReadyThreshold(int)

io.grpc.stub.AbstractStub.withWaitForReady()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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>