ForwardWriteToReadOnOtherHandler Class — netty Architecture

Source Code

codec-http3/src/test/java/io/netty/handler/codec/http3/QpackEncoderDecoderTest.java lines 512–542

    private static final class ForwardWriteToReadOnOtherHandler extends ChannelOutboundHandlerAdapter {

        private final ChannelInboundHandler other;
        private final BlockingQueue<Callable<Void>> suspendQueue;

        ForwardWriteToReadOnOtherHandler(ChannelInboundHandler other) {
            this(other, null);
        }

        ForwardWriteToReadOnOtherHandler(ChannelInboundHandler other,
                                         @Nullable BlockingQueue<Callable<Void>> suspendQueue) {
            this.other = other;
            this.suspendQueue = suspendQueue;
        }

        @Override
        public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
            if (msg instanceof ByteBuf) {
                if (suspendQueue != null) {
                    suspendQueue.offer(() -> {
                        other.channelRead(ctx, msg);
                        return null;
                    });
                } else {
                    other.channelRead(ctx, msg);
                }
            } else {
                super.write(ctx, msg, promise);
            }
        }
    }