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 Details

    • 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(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 also XdsTransportFactory.EventHandler.onReady(). Application is free to ignore it.