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
All Methods Instance Methods Abstract 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
void start(XdsTransportFactory.EventHandler<RespT> eventHandler)
-
sendMessage
void sendMessage(ReqT message)
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
void sendError(java.lang.Exception e)
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.
-
-