handlerAddedStateUpdatedBeforeHandlerAddedDone() — netty Function Reference

Source Code

transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java lines 2197–2242

    private static void handlerAddedStateUpdatedBeforeHandlerAddedDone(boolean executeInEventLoop)
            throws InterruptedException {
        final ChannelPipeline pipeline = new LocalChannel().pipeline();
        final Object userEvent = new Object();
        final Object writeObject = new Object();
        final CountDownLatch doneLatch = new CountDownLatch(1);

        group.register(pipeline.channel());

        Runnable r = new Runnable() {
            @Override
            public void run() {
                pipeline.addLast(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
                        if (evt == userEvent) {
                            ctx.write(writeObject);
                        }
                        ctx.fireUserEventTriggered(evt);
                    }
                });
                pipeline.addFirst(new ChannelDuplexHandler() {
                    @Override
                    public void handlerAdded(ChannelHandlerContext ctx) {
                        ctx.fireUserEventTriggered(userEvent);
                    }

                    @Override
                    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
                        if (msg == writeObject) {
                            doneLatch.countDown();
                        }
                        ctx.write(msg, promise);
                    }
                });
            }
        };

        if (executeInEventLoop) {
            pipeline.channel().eventLoop().execute(r);
        } else {
            r.run();
        }

        doneLatch.await();
    }