com.aliyun.openservices.iot.api.stream

Class StreamServiceContext

java.lang.Object

com.aliyun.openservices.iot.api.stream.StreamServiceContext

public class StreamServiceContext
extends Object

Author:

brhao

Date:

16/05/2018

Constructor Summary

Constructors

Constructor and Description
StreamServiceContext(Connection connection, BaseHttpEntity request, String serviceName)
StreamServiceContext(Connection connection, String serviceName)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Http2Response>	closeStream() 回复流数据，response数据一次发送完成，并完成该次流请求
void	updateContext(BaseHttpEntity httpEntity) 更新上下文
CompletableFuture<StreamWriteContext>	writeHeader(io.netty.handler.codec.http2.Http2Headers headers, boolean endOfStream) 回复流数据，回复header并获取写入的context，可以持续写入数据，直到endStream为true
void	writeResponse(Http2Response response) 回复流数据，response数据一次发送完成，并完成该次流请求

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamServiceContext

public StreamServiceContext(Connection connection,
                            String serviceName)

StreamServiceContext

public StreamServiceContext(Connection connection,
                            BaseHttpEntity request,
                            String serviceName)

Method Detail

writeHeader

public CompletableFuture<StreamWriteContext> writeHeader(io.netty.handler.codec.http2.Http2Headers headers,
                                                         boolean endOfStream)

回复流数据，回复header并获取写入的context，可以持续写入数据，直到endStream为true

Parameters:

headers - headers

endOfStream - 是否结束本次请求

Returns:

StreamWriteContext，用于数据写入操作

writeResponse

public void writeResponse(Http2Response response)

回复流数据，response数据一次发送完成，并完成该次流请求

Parameters:

response - 回复请求方的数据

closeStream

public CompletableFuture<Http2Response> closeStream()

回复流数据，response数据一次发送完成，并完成该次流请求

updateContext

public void updateContext(BaseHttpEntity httpEntity)

更新上下文