private final class HttpClientCodec.Decoder extends HttpResponseDecoder
ByteToMessageDecoder.Cumulator
ChannelHandler.Sharable
validateHeaders
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
Constructor and Description |
---|
Decoder(int maxInitialLineLength,
int maxHeaderSize,
int maxChunkSize,
boolean validateHeaders) |
Decoder(int maxInitialLineLength,
int maxHeaderSize,
int maxChunkSize,
boolean validateHeaders,
int initialBufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
channelInactive(ChannelHandlerContext ctx)
Calls
ChannelHandlerContext.fireChannelInactive() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
protected void |
decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
private void |
decrement(java.lang.Object msg) |
protected boolean |
isContentAlwaysEmpty(HttpMessage msg) |
createInvalidMessage, createMessage, isDecodingRequest
decodeLast, reset, userEventTriggered
actualReadableBytes, callDecode, channelRead, channelReadComplete, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
handlerAdded, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded
Decoder(int maxInitialLineLength, int maxHeaderSize, int maxChunkSize, boolean validateHeaders)
Decoder(int maxInitialLineLength, int maxHeaderSize, int maxChunkSize, boolean validateHeaders, int initialBufferSize)
protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, java.util.List<java.lang.Object> out) throws java.lang.Exception
ByteToMessageDecoder
ByteBuf
to an other. This method will be called till either the input
ByteBuf
has nothing to read when return from this method or till nothing was read from the input
ByteBuf
.decode
in class HttpObjectDecoder
ctx
- the ChannelHandlerContext
which this ByteToMessageDecoder
belongs tobuffer
- the ByteBuf
from which to read dataout
- the List
to which decoded messages should be addedjava.lang.Exception
- is thrown if an error accourprivate void decrement(java.lang.Object msg)
protected boolean isContentAlwaysEmpty(HttpMessage msg)
isContentAlwaysEmpty
in class HttpObjectDecoder
public void channelInactive(ChannelHandlerContext ctx) throws java.lang.Exception
ChannelInboundHandlerAdapter
ChannelHandlerContext.fireChannelInactive()
to forward
to the next ChannelInboundHandler
in the ChannelPipeline
.
Sub-classes may override this method to change behavior.channelInactive
in interface ChannelInboundHandler
channelInactive
in class ByteToMessageDecoder
java.lang.Exception