Package proto.stream.v1

Class StreamServiceGrpc.StreamServiceBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<StreamServiceGrpc.StreamServiceBlockingV2Stub>

io.grpc.stub.AbstractBlockingStub<StreamServiceGrpc.StreamServiceBlockingV2Stub>

proto.stream.v1.StreamServiceGrpc.StreamServiceBlockingV2Stub

Enclosing class:

StreamServiceGrpc

public static final class StreamServiceGrpc.StreamServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<StreamServiceGrpc.StreamServiceBlockingV2Stub>

A stub to allow clients to do synchronous rpc calls to service StreamService.

 A StreamService is used to coordinate with a WebRTC the listing,
 addition, and removal of registered video streams.
 TODO(https://github.com/viamrobotics/rdk/issues/509): support removal
 

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
Stream.AddStreamResponse	addStream(Stream.AddStreamRequest request)	AddStream requests a particular stream be added.
protected StreamServiceGrpc.StreamServiceBlockingV2Stub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
Stream.GetStreamOptionsResponse	getStreamOptions(Stream.GetStreamOptionsRequest request)	GetStreamOptions returns the options for a particular stream.
Stream.ListStreamsResponse	listStreams(Stream.ListStreamsRequest request)	ListStreams returns all streams registered.
Stream.RemoveStreamResponse	removeStream(Stream.RemoveStreamRequest request)	RemoveStream requests a particular stream be removed.
Stream.SetStreamOptionsResponse	setStreamOptions(Stream.SetStreamOptionsRequest request)	SetStreamOptions sets the options for a particular stream.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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 StreamServiceGrpc.StreamServiceBlockingV2Stub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<StreamServiceGrpc.StreamServiceBlockingV2Stub>

listStreams

public Stream.ListStreamsResponse listStreams(Stream.ListStreamsRequest request)
                                       throws io.grpc.StatusException

 ListStreams returns all streams registered.
 

Throws:

io.grpc.StatusException

addStream

public Stream.AddStreamResponse addStream(Stream.AddStreamRequest request)
                                   throws io.grpc.StatusException

 AddStream requests a particular stream be added.
 

Throws:

io.grpc.StatusException

getStreamOptions

public Stream.GetStreamOptionsResponse getStreamOptions(Stream.GetStreamOptionsRequest request)
                                                 throws io.grpc.StatusException

 GetStreamOptions returns the options for a particular stream.
 

Throws:

io.grpc.StatusException

setStreamOptions

public Stream.SetStreamOptionsResponse setStreamOptions(Stream.SetStreamOptionsRequest request)
                                                 throws io.grpc.StatusException

 SetStreamOptions sets the options for a particular stream.
 

Throws:

io.grpc.StatusException

removeStream

public Stream.RemoveStreamResponse removeStream(Stream.RemoveStreamRequest request)
                                         throws io.grpc.StatusException

 RemoveStream requests a particular stream be removed. If the calling client
 is the last to be receiving the stream, it will attempt to be stopped to
 conserve resources.
 

Throws:

io.grpc.StatusException