| Modifier and Type | Method and Description |
|---|---|
Connection |
IotHttp2Client.newConnection()
create new connection to server
|
| Modifier and Type | Method and Description |
|---|---|
List<Connection> |
IotHttp2Client.allConnections() |
Optional<Connection> |
IotHttp2Client.randomConnection(Predicate<Connection> predicate) |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Http2Response> |
IotHttp2Client.sendRequest(Connection connection,
io.netty.handler.codec.http2.Http2Headers headers,
byte[] data) |
void |
IotHttp2Client.sendRequest(Connection connection,
io.netty.handler.codec.http2.Http2Headers headers,
byte[] data,
Http2StreamListener listener) |
| Modifier and Type | Method and Description |
|---|---|
Optional<Connection> |
IotHttp2Client.randomConnection(Predicate<Connection> predicate) |
| Modifier and Type | Method and Description |
|---|---|
protected StreamData |
AbstractHttp2StreamDataReceiver.getStreamData(Connection connection,
io.netty.handler.codec.http2.Http2Stream stream) |
void |
Http2StreamListener.onDataRead(Connection connection,
io.netty.handler.codec.http2.Http2Stream stream,
byte[] data,
boolean endOfStream)
callback for data receiving
|
void |
AbstractHttp2StreamDataReceiver.onDataRead(Connection connection,
io.netty.handler.codec.http2.Http2Stream stream,
byte[] data,
boolean endOfStream) |
void |
Http2StreamListener.onHeadersRead(Connection connection,
io.netty.handler.codec.http2.Http2Stream stream,
io.netty.handler.codec.http2.Http2Headers headers,
boolean endOfStream)
callback for headers receiving
|
void |
AbstractHttp2StreamDataReceiver.onHeadersRead(Connection connection,
io.netty.handler.codec.http2.Http2Stream stream,
io.netty.handler.codec.http2.Http2Headers headers,
boolean endOfStream) |
abstract void |
AbstractHttp2StreamDataReceiver.onStreamDataReceived(Connection connection,
io.netty.handler.codec.http2.Http2Stream stream,
StreamData streamData)
callback when receive the whole stream(stream is end).
|
void |
Http2StreamListener.onStreamError(Connection connection,
io.netty.handler.codec.http2.Http2Stream stream,
IOException e)
callback for error.
|
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Connection> |
ConnectionManager.connect(SocketAddress address)
connect
|
List<Connection> |
ConnectionManager.getConnectionList()
get a connection
|
CompletableFuture<Connection> |
ConnectionWriter.writeGoAway(int lastStreamId,
int errorCode,
byte[] debugData)
write GoAway frame
|
CompletableFuture<Connection> |
ConnectionWriter.writeRst(int streamId,
int errorCode)
write RST_STEAM frame
|
| Modifier and Type | Method and Description |
|---|---|
void |
ConnectionListener.onSettingReceive(Connection connection,
io.netty.handler.codec.http2.Http2Settings settings)
callback for setting received
|
void |
ConnectionListener.onStatusChange(ConnectionStatus status,
Connection connection)
callback for status changed
|
| Constructor and Description |
|---|
StreamWriteContext(io.netty.handler.codec.http2.Http2Stream stream,
Connection connection) |
| Modifier and Type | Class and Description |
|---|---|
class |
ConnectionImpl
wrapper for NettyHttp2Handler
|
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Connection> |
ConnectionManagerImpl.connect(SocketAddress address) |
List<Connection> |
ConnectionManagerImpl.getConnectionList() |
CompletableFuture<Connection> |
ConnectionImpl.writeGoAway(int lastStreamId,
int errorCode,
byte[] debugData) |
CompletableFuture<Connection> |
ConnectionImpl.writeRst(int streamId,
int errorCode) |
| Modifier and Type | Method and Description |
|---|---|
Connection |
NettyHttp2Handler.getConnection() |
| Constructor and Description |
|---|
StreamServiceContext(Connection connection,
BaseHttpEntity request,
String serviceName) |
StreamServiceContext(Connection connection,
String serviceName) |
| Modifier and Type | Method and Description |
|---|---|
static Map<String,StreamServiceContext> |
StreamUtil.getDataStreamMaps(Connection connection) |
static void |
StreamUtil.putDataStreamContext(Connection connection,
String dataStreamId,
StreamServiceContext context) |
static void |
StreamUtil.removeDataStreamContext(Connection connection,
String streamId) |
static void |
StreamUtil.setupConnection(Connection connection,
Http2StreamListener http2StreamListener) |
| Modifier and Type | Method and Description |
|---|---|
static Optional<StreamServiceContext> |
StreamUtil.getDataStreamContext(List<Connection> connections,
String dataStreamId) |
Copyright © 2019. All rights reserved.