Class DeflateDecoder
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.handler.codec.MessageToMessageDecoder<WebSocketFrame>
io.netty.handler.codec.http.websocketx.extensions.WebSocketExtensionDecoder
io.netty.handler.codec.http.websocketx.extensions.compression.DeflateDecoder
- All Implemented Interfaces:
ChannelHandler
,ChannelInboundHandler
- Direct Known Subclasses:
PerFrameDeflateDecoder
,PerMessageDeflateDecoder
Deflate implementation of a payload decompressor for
io.netty.handler.codec.http.websocketx.WebSocketFrame.
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
ChannelHandler.Sharable
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate EmbeddedChannel
(package private) static final ByteBuf
private final WebSocketExtensionFilter
(package private) static final ByteBuf
private final int
private final boolean
-
Constructor Summary
ConstructorsConstructorDescriptionDeflateDecoder
(boolean noContext, WebSocketExtensionFilter extensionDecoderFilter, int maxAllocation) Constructor -
Method Summary
Modifier and TypeMethodDescriptionprotected abstract boolean
void
CallsChannelHandlerContext.fireChannelInactive()
to forward to the nextChannelInboundHandler
in theChannelPipeline
.private void
cleanup()
protected void
decode
(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) Decode from one message to an other.private ByteBuf
protected WebSocketExtensionFilter
Returns the extension decoder filter.void
Do nothing by default, sub-classes may override this method.protected abstract int
newRsv
(WebSocketFrame msg) Methods inherited from class io.netty.handler.codec.MessageToMessageDecoder
acceptInboundMessage, channelRead, channelReadComplete
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded
-
Field Details
-
FRAME_TAIL
-
EMPTY_DEFLATE_BLOCK
-
noContext
private final boolean noContext -
extensionDecoderFilter
-
maxAllocation
private final int maxAllocation -
decoder
-
-
Constructor Details
-
DeflateDecoder
DeflateDecoder(boolean noContext, WebSocketExtensionFilter extensionDecoderFilter, int maxAllocation) Constructor- Parameters:
noContext
- true to disable context takeover.extensionDecoderFilter
- extension decoder filter.
-
-
Method Details
-
extensionDecoderFilter
Returns the extension decoder filter. -
appendFrameTail
-
newRsv
-
decode
protected void decode(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) throws Exception Description copied from class:MessageToMessageDecoder
Decode from one message to an other. This method will be called for each written message that can be handled by this decoder.- Specified by:
decode
in classMessageToMessageDecoder<WebSocketFrame>
- Parameters:
ctx
- theChannelHandlerContext
which thisMessageToMessageDecoder
belongs tomsg
- the message to decode to an other oneout
- theList
to which decoded messages should be added- Throws:
Exception
- is thrown if an error occurs
-
handlerRemoved
Description copied from class:ChannelHandlerAdapter
Do nothing by default, sub-classes may override this method.- Specified by:
handlerRemoved
in interfaceChannelHandler
- Overrides:
handlerRemoved
in classChannelHandlerAdapter
- Throws:
Exception
-
channelInactive
Description copied from class:ChannelInboundHandlerAdapter
CallsChannelHandlerContext.fireChannelInactive()
to forward to the nextChannelInboundHandler
in theChannelPipeline
. Sub-classes may override this method to change behavior.- Specified by:
channelInactive
in interfaceChannelInboundHandler
- Overrides:
channelInactive
in classChannelInboundHandlerAdapter
- Throws:
Exception
-
decompressContent
-
cleanup
private void cleanup()
-