class PerMessageDeflateDecoder extends DeflateDecoder
ChannelHandler.Sharable
Modifier and Type | Field and Description |
---|---|
private boolean |
compressing |
FRAME_TAIL
Constructor and Description |
---|
PerMessageDeflateDecoder(boolean noContext)
Constructor
|
Modifier and Type | Method and Description |
---|---|
boolean |
acceptInboundMessage(java.lang.Object msg)
Returns
true if the given message should be handled. |
protected boolean |
appendFrameTail(WebSocketFrame msg) |
protected void |
decode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out)
Decode from one message to an other.
|
protected int |
newRsv(WebSocketFrame msg) |
channelInactive, handlerRemoved
channelRead
channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
ensureNotSharable, handlerAdded, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded
public PerMessageDeflateDecoder(boolean noContext)
noContext
- true to disable context takeover.public boolean acceptInboundMessage(java.lang.Object msg) throws java.lang.Exception
MessageToMessageDecoder
true
if the given message should be handled. If false
it will be passed to the next
ChannelInboundHandler
in the ChannelPipeline
.acceptInboundMessage
in class MessageToMessageDecoder<WebSocketFrame>
java.lang.Exception
protected int newRsv(WebSocketFrame msg)
newRsv
in class DeflateDecoder
protected boolean appendFrameTail(WebSocketFrame msg)
appendFrameTail
in class DeflateDecoder
protected void decode(ChannelHandlerContext ctx, WebSocketFrame msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageDecoder
decode
in class DeflateDecoder
ctx
- the ChannelHandlerContext
which this MessageToMessageDecoder
belongs tomsg
- the message to decode to an other oneout
- the List
to which decoded messages should be addedjava.lang.Exception
- is thrown if an error occurs