ByteBufForwarder Class — netty Architecture

Source Code

codec-http/src/main/java/io/netty/handler/codec/http/HttpContentDecoder.java lines 270–295

    private final class ByteBufForwarder extends ChannelInboundHandlerAdapter {

        private final ChannelHandlerContext targetCtx;

        ByteBufForwarder(ChannelHandlerContext targetCtx) {
            this.targetCtx = targetCtx;
        }

        @Override
        public boolean isSharable() {
            // We need to mark the handler as sharable as we will add it to every EmbeddedChannel that is
            // generated.
            return true;
        }

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) {
            ByteBuf buf = (ByteBuf) msg;
            if (!buf.isReadable()) {
                buf.release();
                return;
            }
            needRead = false;
            targetCtx.fireChannelRead(new DefaultHttpContent(buf));
        }
    }