StreamHandler Class — netty Architecture

Source Code

codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicStreamFrameTest.java lines 99–143

    private static final class StreamHandler extends ChannelInboundHandlerAdapter {
        private final BlockingQueue<Integer> queue = new LinkedBlockingQueue<>();

        @Override
        public void channelRegistered(ChannelHandlerContext ctx) {
            ctx.channel().config().setOption(QuicChannelOption.READ_FRAMES, true);
            queue.add(0);
        }

        @Override
        public void channelInactive(ChannelHandlerContext ctx) {
            queue.add(3);
            // Close the QUIC channel as well.
            ctx.channel().parent().close();
        }

        @Override
        public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
            if (evt == ChannelInputShutdownReadComplete.INSTANCE) {
                queue.add(2);
                if (((QuicStreamChannel) ctx.channel()).type() == QuicStreamType.BIDIRECTIONAL) {
                    // Let's write back a fin which will also close the channel and so call channelInactive(...)
                    ctx.writeAndFlush(new DefaultQuicStreamFrame(Unpooled.EMPTY_BUFFER, true));
                }
                ctx.channel().parent().close();
            }
        }

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) {
            QuicStreamFrame frame = (QuicStreamFrame) msg;
            if (frame.hasFin()) {
                queue.add(1);
            }
            frame.release();
        }

        void assertSequence() throws Exception {
            assertEquals(0, (int) queue.take());
            assertEquals(1, (int) queue.take());
            assertEquals(2, (int) queue.take());
            assertEquals(3, (int) queue.take());
            assertTrue(queue.isEmpty());
        }
    }