XdsTransportFactory.StreamingCall

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 Type

Method

Description

boolean

isReady()

Indicates whether call is capable of sending additional messages without requiring excessive buffering internally.

void

sendError(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 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.