testFlushInbound() — netty Function Reference

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

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ testFlushInbound() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/embedded/EmbeddedChannelTest.java lines 429–444

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

        channel.flushInbound();

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