testCloseInFlush() — netty Function Reference

Architecture documentation for the testCloseInFlush() function in ReentrantChannelTest.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ testCloseInFlush() — netty Function Reference

Dependency Diagram

graph TD
  f88fc585_cf0a_1ba8_606e_8f4d4be7b258["testCloseInFlush()"]
  13a11eea_27b7_44b5_a4d5_69eb21dd0e09["ReentrantChannelTest"]
  f88fc585_cf0a_1ba8_606e_8f4d4be7b258 -->|defined in| 13a11eea_27b7_44b5_a4d5_69eb21dd0e09
  style f88fc585_cf0a_1ba8_606e_8f4d4be7b258 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ReentrantChannelTest.java lines 222–250

    @Test
    public void testCloseInFlush() throws Exception {

        LocalAddress addr = new LocalAddress("testCloseInFlush");

        ServerBootstrap sb = getLocalServerBootstrap();
        sb.bind(addr).sync().channel();

        Bootstrap cb = getLocalClientBootstrap();

        setInterest(Event.WRITE, Event.FLUSH, Event.CLOSE, Event.EXCEPTION);

        Channel clientChannel = cb.connect(addr).sync().channel();

        clientChannel.pipeline().addLast(new ChannelOutboundHandlerAdapter() {

            @Override
            public void write(final ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
                promise.addListener(future -> ctx.channel().close());
                ctx.write(msg, promise);
                ctx.channel().flush();
            }
        });

        clientChannel.write(createTestBuf(2000)).sync();
        clientChannel.closeFuture().sync();

        assertLog("WRITE\nFLUSH\nCLOSE\n");
    }