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 java.lang.Object implements XdsTransportFactory.StreamingCall<ReqT,RespT>
-
-
Constructor Summary
Constructors Constructor Description XdsStreamingCall(java.lang.String methodName, io.grpc.MethodDescriptor.Marshaller<ReqT> reqMarshaller, io.grpc.MethodDescriptor.Marshaller<RespT> respMarshaller)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isReady()
Indicates whether call is capable of sending additional messages without requiring excessive buffering internally.void
sendError(java.lang.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.
-
-
-
Method Detail
-
start
public void start(XdsTransportFactory.EventHandler<RespT> eventHandler)
- Specified by:
start
in interfaceXdsTransportFactory.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 interfaceXdsTransportFactory.StreamingCall<ReqT,RespT>
-
startRecvMessage
public void startRecvMessage()
Description copied from interface:XdsTransportFactory.StreamingCall
Requests a message to be received.- Specified by:
startRecvMessage
in interfaceXdsTransportFactory.StreamingCall<ReqT,RespT>
-
sendError
public void sendError(java.lang.Exception e)
Description copied from interface:XdsTransportFactory.StreamingCall
An error is encountered. Sends the error.- Specified by:
sendError
in interfaceXdsTransportFactory.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 alsoXdsTransportFactory.EventHandler.onReady()
. Application is free to ignore it.- Specified by:
isReady
in interfaceXdsTransportFactory.StreamingCall<ReqT,RespT>
-
-