com.aliyun.openservices.iot.api.http2.connection

Interface ConnectionWriter

All Known Subinterfaces:

Connection

All Known Implementing Classes:

ConnectionImpl

public interface ConnectionWriter

Author:

brhao

Date:

08/04/2018

Method Summary

Modifier and Type	Method and Description
CompletableFuture<StreamWriteContext>	writeData(int streamId, byte[] data, boolean endStream) write DATA frame
CompletableFuture<Connection>	writeGoAway(int lastStreamId, int errorCode, byte[] debugData) write GoAway frame
CompletableFuture<StreamWriteContext>	writeHeaders(io.netty.handler.codec.http2.Http2Headers headers, boolean endStream, Http2StreamListener http2StreamListener) start a new stream and write Header Frame
CompletableFuture<Connection>	writeRst(int streamId, int errorCode) write RST_STEAM frame

Method Detail

writeHeaders

CompletableFuture<StreamWriteContext> writeHeaders(io.netty.handler.codec.http2.Http2Headers headers,
                                                   boolean endStream,
                                                   Http2StreamListener http2StreamListener)

start a new stream and write Header Frame

Parameters:

headers - headers

endStream - end of stream

http2StreamListener - stream listener

Returns:

CompletableFuture for IO

writeData

CompletableFuture<StreamWriteContext> writeData(int streamId,
                                                byte[] data,
                                                boolean endStream)

write DATA frame

Parameters:

streamId - streamId

data - data

endStream - end of stream

Returns:

CompletableFuture for IO

writeGoAway

CompletableFuture<Connection> writeGoAway(int lastStreamId,
                                          int errorCode,
                                          byte[] debugData)

write GoAway frame

Parameters:

lastStreamId - lastStreamId

errorCode - errorCode

debugData - debugData

Returns:

CompletableFuture for IO

writeRst

CompletableFuture<Connection> writeRst(int streamId,
                                       int errorCode)

write RST_STEAM frame

Parameters:

streamId - streamId

errorCode - errorCode

Returns:

CompletableFuture for IO