public interface IStreamSender extends IH2FileManager
Modifier and Type | Method and Description |
---|---|
void |
closeStream(java.lang.String dataStreamId,
Http2Request request,
CompletableListener<Http2Response> listener)
关闭打开的流
|
void |
connect(CompletableListener listener)
建立 H2 连接
|
void |
disconnect(CompletableListener listener)
断开 H2 连接
|
ConnectionStatus |
getState() |
boolean |
isConnected()
返回当前是否已建联的状态
|
void |
openStream(java.lang.String serviceName,
Http2Request request,
CompletableListener<Http2Response> listener)
打开新的数据流
|
void |
sendStream(java.lang.String dataStreamId,
Http2Request request,
IDownStreamListener downStreamListener,
CompletableListener<StreamWriteContext> completableListener)
在打开的流上发送数据
|
setDataFragmentSendTimeout, upload, uploadFile
void connect(CompletableListener listener) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
listener
- 结果回调java.util.concurrent.ExecutionException
java.lang.InterruptedException
void openStream(java.lang.String serviceName, Http2Request request, CompletableListener<Http2Response> listener)
serviceName
- targetService 流服务名称request
- http2 request 自定义参数和数据,透传到流接收端listener
- 结果回调,可获取dataStreamId发送数据boolean isConnected()
ConnectionStatus getState()
void sendStream(java.lang.String dataStreamId, Http2Request request, IDownStreamListener downStreamListener, CompletableListener<StreamWriteContext> completableListener)
dataStreamId
- dataStreamId,通过openStream获取request
- http2 request 自定义参数和数据,透传到流接收端downStreamListener
- 下行数据回调completableListener
- 结果回调void closeStream(java.lang.String dataStreamId, Http2Request request, CompletableListener<Http2Response> listener)
dataStreamId
- dataStreamId,通过openStream获取request
- http2 request 自定义参数和数据,透传到流接收端listener
- 结果回调void disconnect(CompletableListener listener)
listener
- 结果回调