code: @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());
      }
    }
docs: If we get a new content chunk, send it towards decoding.