Top Description Fields Constructors Methods
io.netty.handler.codec.http.websocketx.extensions.compression

pack-priv abstract Class DeflateEncoder

extends WebSocketExtensionEncoder
Class Inheritance
Known Direct Subclasses
io.netty.handler.codec.http.websocketx.extensions.compression.PerFrameDeflateEncoder, io.netty.handler.codec.http.websocketx.extensions.compression.PerMessageDeflateEncoder
Imports
io.netty.buffer.ByteBuf, .CompositeByteBuf, io.netty.channel.ChannelHandlerContext, io.netty.channel.embedded.EmbeddedChannel, io.netty.handler.codec.CodecException, io.netty.handler.codec.compression.ZlibCodecFactory, .ZlibWrapper, io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame, .ContinuationWebSocketFrame, .TextWebSocketFrame, .WebSocketFrame, io.netty.handler.codec.http.websocketx.extensions.WebSocketExtensionEncoder, .WebSocketExtensionFilter, java.util.List
Deflate implementation of a payload compressor for io.netty.handler.codec.http.websocketx.WebSocketFrame.

Field Summary

Modifier and TypeField and Description
private final int
compressionLevel

private EmbeddedChannel
encoder

private final WebSocketExtensionFilter
extensionEncoderFilter

private final boolean
noContext

private final int
windowSize

Constructor Summary

AccessConstructor and Description
pack-priv
DeflateEncoder(int
compression level of the compressor.
compressionLevel, int
maximum size of the window compressor buffer.
windowSize, boolean
true to disable context takeover.
noContext, WebSocketExtensionFilter
extension encoder filter.
extensionEncoderFilter)

Constructor

Method Summary

Modifier and TypeMethod and Description
private void
cleanup()

private ByteBuf
compressContent(ChannelHandlerContext ctx, WebSocketFrame msg)

protected void
encode(ChannelHandlerContext
the ChannelHandlerContext which this MessageToMessageEncoder belongs to
ctx, WebSocketFrame
the message to encode to an other one
msg, List<Object>
the List into which the encoded msg should be added needs to do some kind of aggregation
out)

Implements abstract io.netty.handler.codec.MessageToMessageEncoder.encode.

Encode from one message to an other.
protected WebSocketExtensionFilter
extensionEncoderFilter()

Returns the extension encoder filter.

public void
handlerRemoved(ChannelHandlerContext ctx)

Overrides io.netty.channel.ChannelHandlerAdapter.handlerRemoved.

Implements io.netty.channel.ChannelHandler.handlerRemoved.

Gets called after the ChannelHandler was removed from the actual context and it doesn't handle events anymore.
protected abstract boolean

Returns:

true if compressed payload tail needs to be removed.
removeFrameTail(WebSocketFrame
the current frame.
msg)

protected abstract int

Returns:

the rsv bits to set in the compressed frame.
rsv(WebSocketFrame
the current frame.
msg)

Field Detail

compressionLevelback to summary
private final int compressionLevel
encoderback to summary
private EmbeddedChannel encoder
extensionEncoderFilterback to summary
private final WebSocketExtensionFilter extensionEncoderFilter
noContextback to summary
private final boolean noContext
windowSizeback to summary
private final int windowSize

Constructor Detail

DeflateEncoderback to summary
pack-priv DeflateEncoder(int compressionLevel, int windowSize, boolean noContext, WebSocketExtensionFilter extensionEncoderFilter)

Constructor

Parameters
compressionLevel:int

compression level of the compressor.

windowSize:int

maximum size of the window compressor buffer.

noContext:boolean

true to disable context takeover.

extensionEncoderFilter:WebSocketExtensionFilter

extension encoder filter.

Method Detail

cleanupback to summary
private void cleanup()
compressContentback to summary
private ByteBuf compressContent(ChannelHandlerContext ctx, WebSocketFrame msg)
encodeback to summary
protected void encode(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) throws Exception

Implements abstract io.netty.handler.codec.MessageToMessageEncoder.encode.

Doc from io.netty.handler.codec.MessageToMessageEncoder.encode.

Encode from one message to an other. This method will be called for each written message that can be handled by this encoder.

Parameters
ctx:ChannelHandlerContext

the ChannelHandlerContext which this MessageToMessageEncoder belongs to

msg:WebSocketFrame

the message to encode to an other one

out:List<Object>

the List into which the encoded msg should be added needs to do some kind of aggregation

Annotations
@Override
Exceptions
Exception:
is thrown if an error occurs
extensionEncoderFilterback to summary
protected WebSocketExtensionFilter extensionEncoderFilter()

Returns the extension encoder filter.

handlerRemovedback to summary
public void handlerRemoved(ChannelHandlerContext ctx) throws Exception

Overrides io.netty.channel.ChannelHandlerAdapter.handlerRemoved.

Implements io.netty.channel.ChannelHandler.handlerRemoved.

Doc from io.netty.channel.ChannelHandler.handlerRemoved.

Gets called after the ChannelHandler was removed from the actual context and it doesn't handle events anymore.

Annotations
@Override
removeFrameTailback to summary
protected abstract boolean removeFrameTail(WebSocketFrame msg)
Parameters
msg:WebSocketFrame

the current frame.

Returns:boolean

true if compressed payload tail needs to be removed.

rsvback to summary
protected abstract int rsv(WebSocketFrame msg)
Parameters
msg:WebSocketFrame

the current frame.

Returns:int

the rsv bits to set in the compressed frame.