@ Override protected void channelRead0 ( final ChannelHandlerContext ctx , final HttpObject msg ) throws Exception { if ( msg instanceof HttpContent ) { HttpContent content = ( HttpContent ) msg ; decodeChunk ( ( InetSocketAddress ) ctx . channel ( ) . remoteAddress ( ) , content . content ( ) ) ; } }
If we get a new content chunk send it towards decoding .