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 -
Constructor Summary
ConstructorsConstructorDescriptionXdsStreamingCall
(String methodName, io.grpc.MethodDescriptor.Marshaller<ReqT> reqMarshaller, io.grpc.MethodDescriptor.Marshaller<RespT> respMarshaller) -
Method Summary
Modifier and TypeMethodDescriptionboolean
isReady()
Indicates whether call is capable of sending additional messages without requiring excessive buffering internally.void
An error is encountered.void
sendMessage
(ReqT message) Sends a message on the stream.void
start
(XdsTransportFactory.EventHandler<RespT> eventHandler) void
Requests a message to be received.
-
Field Details
-
call
-
-
Constructor Details
-
XdsStreamingCall
-
-
Method Details
-
start
- Specified by:
start
in interfaceXdsTransportFactory.StreamingCall<ReqT,
RespT>
-
sendMessage
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
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>
-