Package io.grpc.xds.client
Interface XdsTransportFactory.StreamingCall<ReqT,RespT>
- All Known Implementing Classes:
GrpcXdsTransportFactory.GrpcXdsTransport.XdsStreamingCall
- Enclosing interface:
XdsTransportFactory
public static interface XdsTransportFactory.StreamingCall<ReqT,RespT>
Represents a bidi streaming RPC call.
-
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.
-
Method Details
-
start
-
sendMessage
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. -
startRecvMessage
void startRecvMessage()Requests a message to be received. -
sendError
An error is encountered. Sends the error. -
isReady
boolean isReady()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.
-