testRemoveAndWrite() — netty Function Reference

Architecture documentation for the testRemoveAndWrite() function in PendingWriteQueueTest.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ testRemoveAndWrite() — netty Function Reference

Dependency Diagram

graph TD
  670dbce5_6028_a7d3_d6ca_f69e7325a1c6["testRemoveAndWrite()"]
  b4bff24e_be13_7693_4ece_a0ed5ee1a982["PendingWriteQueueTest"]
  670dbce5_6028_a7d3_d6ca_f69e7325a1c6 -->|defined in| b4bff24e_be13_7693_4ece_a0ed5ee1a982
  03c20eb8_620c_93ca_7117_43063817f243["assertWrite()"]
  670dbce5_6028_a7d3_d6ca_f69e7325a1c6 -->|calls| 03c20eb8_620c_93ca_7117_43063817f243
  ae83f057_ec09_c91a_1fe2_4c222d04aff0["assertQueueEmpty()"]
  670dbce5_6028_a7d3_d6ca_f69e7325a1c6 -->|calls| ae83f057_ec09_c91a_1fe2_4c222d04aff0
  style 670dbce5_6028_a7d3_d6ca_f69e7325a1c6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java lines 41–53

    @Test
    public void testRemoveAndWrite() {
        assertWrite(new TestHandler() {
            @Override
            public void flush(ChannelHandlerContext ctx) throws Exception {
                assertFalse(ctx.channel().isWritable(), "Should not be writable anymore");

                ChannelFuture future = queue.removeAndWrite();
                future.addListener(f -> assertQueueEmpty(queue));
                super.flush(ctx);
            }
        }, 1);
    }