testFlushOutbound() — netty Function Reference

Architecture documentation for the testFlushOutbound() function in EmbeddedChannelTest.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ testFlushOutbound() — netty Function Reference

Dependency Diagram

graph TD
  7828aff6_b98d_ebd4_35b8_21e28865d8b2["testFlushOutbound()"]
  300cabef_b042_697f_5623_37ce249f504d["EmbeddedChannelTest"]
  7828aff6_b98d_ebd4_35b8_21e28865d8b2 -->|defined in| 300cabef_b042_697f_5623_37ce249f504d
  style 7828aff6_b98d_ebd4_35b8_21e28865d8b2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/embedded/EmbeddedChannelTest.java lines 477–492

    @Test
    public void testFlushOutbound() throws InterruptedException {
        final CountDownLatch latch = new CountDownLatch(1);
        EmbeddedChannel channel = new EmbeddedChannel(new ChannelOutboundHandlerAdapter() {
            @Override
            public void flush(ChannelHandlerContext ctx) throws Exception {
                latch.countDown();
            }
        });

        channel.flushOutbound();

        if (!latch.await(1L, TimeUnit.SECONDS)) {
            fail("Nobody called #flush() in time.");
        }
    }