Package com.google.cloud.visionai.v1

Class StreamingServiceGrpc.StreamingServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<StreamingServiceGrpc.StreamingServiceStub>

com.google.cloud.visionai.v1.StreamingServiceGrpc.StreamingServiceStub

Enclosing class:

StreamingServiceGrpc

public static final class StreamingServiceGrpc.StreamingServiceStub
extends io.grpc.stub.AbstractAsyncStub<StreamingServiceGrpc.StreamingServiceStub>

A stub to allow clients to do asynchronous rpc calls to service StreamingService.

 Streaming service for receiving and sending packets.
 

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 Type	Method	Description
void	acquireLease(AcquireLeaseRequest request, io.grpc.stub.StreamObserver<Lease> responseObserver)	AcquireLease acquires a lease.
protected StreamingServiceGrpc.StreamingServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
io.grpc.stub.StreamObserver<ReceiveEventsRequest>	receiveEvents(io.grpc.stub.StreamObserver<ReceiveEventsResponse> responseObserver)	Receive events given the stream name.
io.grpc.stub.StreamObserver<ReceivePacketsRequest>	receivePackets(io.grpc.stub.StreamObserver<ReceivePacketsResponse> responseObserver)	Receive packets from the series.
void	releaseLease(ReleaseLeaseRequest request, io.grpc.stub.StreamObserver<ReleaseLeaseResponse> responseObserver)	RleaseLease releases a lease.
void	renewLease(RenewLeaseRequest request, io.grpc.stub.StreamObserver<Lease> responseObserver)	RenewLease renews a lease.
io.grpc.stub.StreamObserver<SendPacketsRequest>	sendPackets(io.grpc.stub.StreamObserver<SendPacketsResponse> responseObserver)	Send packets to the series.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

build

protected StreamingServiceGrpc.StreamingServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<StreamingServiceGrpc.StreamingServiceStub>

sendPackets

public io.grpc.stub.StreamObserver<SendPacketsRequest> sendPackets(io.grpc.stub.StreamObserver<SendPacketsResponse> responseObserver)

 Send packets to the series.
 

receivePackets

public io.grpc.stub.StreamObserver<ReceivePacketsRequest> receivePackets(io.grpc.stub.StreamObserver<ReceivePacketsResponse> responseObserver)

 Receive packets from the series.
 

receiveEvents

public io.grpc.stub.StreamObserver<ReceiveEventsRequest> receiveEvents(io.grpc.stub.StreamObserver<ReceiveEventsResponse> responseObserver)

 Receive events given the stream name.
 

acquireLease

public void acquireLease(AcquireLeaseRequest request,
 io.grpc.stub.StreamObserver<Lease> responseObserver)

 AcquireLease acquires a lease.
 

renewLease

public void renewLease(RenewLeaseRequest request,
 io.grpc.stub.StreamObserver<Lease> responseObserver)

 RenewLease renews a lease.
 

releaseLease

public void releaseLease(ReleaseLeaseRequest request,
 io.grpc.stub.StreamObserver<ReleaseLeaseResponse> responseObserver)

 RleaseLease releases a lease.