Package io.grpc.xds

Class GrpcXdsTransportFactory.GrpcXdsTransport.XdsStreamingCall<ReqT,RespT>

java.lang.Object

io.grpc.xds.GrpcXdsTransportFactory.GrpcXdsTransport.XdsStreamingCall<ReqT,RespT>

All Implemented Interfaces:

XdsTransportFactory.StreamingCall<ReqT,RespT>

Enclosing class:

GrpcXdsTransportFactory.GrpcXdsTransport

private class GrpcXdsTransportFactory.GrpcXdsTransport.XdsStreamingCall<ReqT,RespT>
extends Object
implements XdsTransportFactory.StreamingCall<ReqT,RespT>

Field Summary

Fields

Modifier and Type	Field	Description
private final io.grpc.ClientCall<ReqT,RespT>	call

Constructor Summary

Constructors

Constructor	Description
XdsStreamingCall(String methodName, io.grpc.MethodDescriptor.Marshaller<ReqT> reqMarshaller, io.grpc.MethodDescriptor.Marshaller<RespT> respMarshaller)

Method Summary

Modifier and Type	Method	Description
boolean	isReady()	Indicates whether call is capable of sending additional messages without requiring excessive buffering internally.
void	sendError(Exception e)	An error is encountered.
void	sendMessage(ReqT message)	Sends a message on the stream.
void	start(XdsTransportFactory.EventHandler<RespT> eventHandler)
void	startRecvMessage()	Requests a message to be received.

Methods inherited from class java.lang.Object

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

Field Details

call

private final io.grpc.ClientCall<ReqT,RespT> call

Constructor Details

XdsStreamingCall

public XdsStreamingCall(String methodName,
 io.grpc.MethodDescriptor.Marshaller<ReqT> reqMarshaller,
 io.grpc.MethodDescriptor.Marshaller<RespT> respMarshaller)

Method Details

start

public void start(XdsTransportFactory.EventHandler<RespT> eventHandler)

Specified by:

start in interface XdsTransportFactory.StreamingCall<ReqT,RespT>

sendMessage

public void sendMessage(ReqT message)

Description copied from interface: XdsTransportFactory.StreamingCall

Sends a message on the stream. Only one message will be in flight at a time; subsequent messages will not be sent until this one is done.

Specified by:

sendMessage in interface XdsTransportFactory.StreamingCall<ReqT,RespT>

startRecvMessage

public void startRecvMessage()

Description copied from interface: XdsTransportFactory.StreamingCall

Requests a message to be received.

Specified by:

startRecvMessage in interface XdsTransportFactory.StreamingCall<ReqT,RespT>

sendError

public void sendError(Exception e)

Description copied from interface: XdsTransportFactory.StreamingCall

An error is encountered. Sends the error.

Specified by:

sendError in interface XdsTransportFactory.StreamingCall<ReqT,RespT>

isReady

public boolean isReady()

Description copied from interface: XdsTransportFactory.StreamingCall

Indicates whether call is capable of sending additional messages without requiring excessive buffering internally. Used for resource initial fetch timeout notification. See also XdsTransportFactory.EventHandler.onReady(). Application is free to ignore it.

Specified by:

isReady in interface XdsTransportFactory.StreamingCall<ReqT,RespT>