Package | Description |
---|---|
io.netty.channel.embedded |
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context. |
io.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
io.netty.handler.codec.http.websocketx.extensions.compression |
Encoder, decoder, handshakers to handle most common WebSocket Compression Extensions.
|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
Modifier and Type | Method and Description |
---|---|
EmbeddedChannel |
EmbeddedChannel.flushInbound()
Flushes the inbound of this
Channel . |
EmbeddedChannel |
EmbeddedChannel.flushOutbound()
Flushes the outbound of this
Channel . |
Constructor and Description |
---|
EmbeddedChannelPipeline(EmbeddedChannel channel) |
Modifier and Type | Field and Description |
---|---|
private EmbeddedChannel |
HttpContentEncoder.Result.contentEncoder |
private EmbeddedChannel |
HttpContentDecoder.decoder |
private EmbeddedChannel |
HttpContentEncoder.encoder |
Modifier and Type | Method and Description |
---|---|
EmbeddedChannel |
HttpContentEncoder.Result.contentEncoder() |
protected abstract EmbeddedChannel |
HttpContentDecoder.newContentDecoder(java.lang.String contentEncoding)
Returns a new
EmbeddedChannel that decodes the HTTP message
content encoded in the specified contentEncoding. |
protected EmbeddedChannel |
HttpContentDecompressor.newContentDecoder(java.lang.String contentEncoding) |
Constructor and Description |
---|
Result(java.lang.String targetContentEncoding,
EmbeddedChannel contentEncoder) |
Modifier and Type | Field and Description |
---|---|
private EmbeddedChannel |
DeflateDecoder.decoder |
private EmbeddedChannel |
DeflateEncoder.encoder |
Modifier and Type | Field and Description |
---|---|
private EmbeddedChannel |
DelegatingDecompressorFrameListener.Http2Decompressor.decompressor |
Modifier and Type | Method and Description |
---|---|
(package private) EmbeddedChannel |
DelegatingDecompressorFrameListener.Http2Decompressor.decompressor()
Responsible for taking compressed bytes in and producing decompressed bytes.
|
private EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newCompressionChannel(ChannelHandlerContext ctx,
ZlibWrapper wrapper)
Generate a new instance of an
EmbeddedChannel capable of compressing data |
private EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newCompressor(ChannelHandlerContext ctx,
Http2Headers headers,
boolean endOfStream)
Checks if a new compressor object is needed for the stream identified by
streamId . |
protected EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newContentCompressor(ChannelHandlerContext ctx,
java.lang.CharSequence contentEncoding)
Returns a new
EmbeddedChannel that encodes the HTTP2 message content encoded in the specified
contentEncoding . |
protected EmbeddedChannel |
DelegatingDecompressorFrameListener.newContentDecompressor(ChannelHandlerContext ctx,
java.lang.CharSequence contentEncoding)
Returns a new
EmbeddedChannel that decodes the HTTP2 message content encoded in the specified
contentEncoding . |
Modifier and Type | Method and Description |
---|---|
private void |
CompressorHttp2ConnectionEncoder.bindCompressorToStream(EmbeddedChannel compressor,
int streamId)
Called after the super class has written the headers and created any associated stream objects.
|
(package private) void |
CompressorHttp2ConnectionEncoder.cleanup(Http2Stream stream,
EmbeddedChannel compressor)
Release remaining content from
EmbeddedChannel and remove the compressor from the Http2Stream . |
private static ByteBuf |
DelegatingDecompressorFrameListener.nextReadableBuf(EmbeddedChannel decompressor)
|
private static ByteBuf |
CompressorHttp2ConnectionEncoder.nextReadableBuf(EmbeddedChannel compressor)
|
Constructor and Description |
---|
Http2Decompressor(EmbeddedChannel decompressor) |