Method Detail

• connect

  void connect(CompletableListener listener)
        throws java.util.concurrent.ExecutionException,
               java.lang.InterruptedException

  建立 H2 连接

  Parameters:

  listener - 结果回调

  Throws:

  java.util.concurrent.ExecutionException

  java.lang.InterruptedException

• openStream

  void openStream(java.lang.String serviceName,
                  Http2Request request,
                  CompletableListener<Http2Response> listener)

  打开新的数据流

  Parameters:

  serviceName - targetService 流服务名称

  request - http2 request 自定义参数和数据，透传到流接收端

  listener - 结果回调，可获取dataStreamId发送数据

• isConnected

  boolean isConnected()

  返回当前是否已建联的状态

  Returns:

  是否已建联

• getState

  ConnectionStatus getState()

  Returns:

  连接状态

• sendStream

  void sendStream(java.lang.String dataStreamId,
                  Http2Request request,
                  IDownStreamListener downStreamListener,
                  CompletableListener<StreamWriteContext> completableListener)

  在打开的流上发送数据

  Parameters:

  dataStreamId - dataStreamId，通过openStream获取

  request - http2 request 自定义参数和数据，透传到流接收端

  downStreamListener - 下行数据回调

  completableListener - 结果回调

• closeStream

  void closeStream(java.lang.String dataStreamId,
                   Http2Request request,
                   CompletableListener<Http2Response> listener)

  关闭打开的流

  Parameters:

  dataStreamId - dataStreamId，通过openStream获取

  request - http2 request 自定义参数和数据，透传到流接收端

  listener - 结果回调

• disconnect

  void disconnect(CompletableListener listener)

  断开 H2 连接

  Parameters:

  listener - 结果回调