testRemoveAndWriteAll() — netty Function Reference

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

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ testRemoveAndWriteAll() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java lines 55–67

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

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