testFireChannelRegistered() — netty Function Reference

Architecture documentation for the testFireChannelRegistered() function in DefaultChannelPipelineTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testFireChannelRegistered() — netty Function Reference

Dependency Diagram

graph TD
  22dad6f8_b9a5_94d2_0da8_eb5618a07e6d["testFireChannelRegistered()"]
  666d912b_4166_a807_ed10_ba12f328a7b2["DefaultChannelPipelineTest"]
  22dad6f8_b9a5_94d2_0da8_eb5618a07e6d -->|defined in| 666d912b_4166_a807_ed10_ba12f328a7b2
  ebcc6e3b_d3a0_03bf_fca5_6465216a4f0e["channelRegistered()"]
  22dad6f8_b9a5_94d2_0da8_eb5618a07e6d -->|calls| ebcc6e3b_d3a0_03bf_fca5_6465216a4f0e
  style 22dad6f8_b9a5_94d2_0da8_eb5618a07e6d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java lines 438–455

    @Test
    public void testFireChannelRegistered() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);
        ChannelPipeline pipeline = new LocalChannel().pipeline();
        pipeline.addLast(new ChannelInitializer<Channel>() {
            @Override
            protected void initChannel(Channel ch) {
                ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelRegistered(ChannelHandlerContext ctx) {
                        latch.countDown();
                    }
                });
            }
        });
        group.register(pipeline.channel());
        assertTrue(latch.await(2, TimeUnit.SECONDS));
    }