Package com.viam.sdk.core.webrtc

Class ClientStream<RequestT,ResponseT>

java.lang.Object

io.grpc.ClientCall<RequestT,ResponseT>

com.viam.sdk.core.webrtc.ClientStream<RequestT,ResponseT>

public class ClientStream<RequestT,ResponseT>
extends io.grpc.ClientCall<RequestT,ResponseT>

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.ClientCall

io.grpc.ClientCall.Listener<T extends Object>

Constructor Summary

Constructors

Constructor	Description
ClientStream(io.grpc.MethodDescriptor<RequestT,ResponseT> methodDescriptor, ClientChannel channel, Grpc.Stream stream, Function<Long,Void> onDone, io.grpc.CallOptions callOptions, Logger logger)

Method Summary

Modifier and Type	Method	Description
void	cancel(String message, Throwable cause)
void	halfClose()
void	onResponse(Grpc.Response resp)
void	request(int numMessages)
void	sendMessage(RequestT message)
void	start(io.grpc.ClientCall.Listener<ResponseT> responseListener, io.grpc.Metadata headers)

Methods inherited from class io.grpc.ClientCall

getAttributes, isReady, setMessageCompression

Methods inherited from class java.lang.Object

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

Constructor Details

ClientStream

public ClientStream(io.grpc.MethodDescriptor<RequestT,ResponseT> methodDescriptor,
 ClientChannel channel,
 Grpc.Stream stream,
 Function<Long,Void> onDone,
 io.grpc.CallOptions callOptions,
 Logger logger)

Method Details

start

public void start(io.grpc.ClientCall.Listener<ResponseT> responseListener,
 io.grpc.Metadata headers)

Specified by:

start in class io.grpc.ClientCall<RequestT,ResponseT>

request

public void request(int numMessages)

Specified by:

request in class io.grpc.ClientCall<RequestT,ResponseT>

cancel

public void cancel(@Nullable
 String message,
 @Nullable
 Throwable cause)

Specified by:

cancel in class io.grpc.ClientCall<RequestT,ResponseT>

halfClose

public void halfClose()

Specified by:

halfClose in class io.grpc.ClientCall<RequestT,ResponseT>

sendMessage

public void sendMessage(RequestT message)

Specified by:

sendMessage in class io.grpc.ClientCall<RequestT,ResponseT>

onResponse

public void onResponse(Grpc.Response resp)