testReadFlowManagement() — netty Function Reference

Architecture documentation for the testReadFlowManagement() function in MessageAggregatorTest.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ testReadFlowManagement() — netty Function Reference

Dependency Diagram

graph TD
  ae1fef7f_bd3e_d252_c9ee_681ba697560b["testReadFlowManagement()"]
  bc4d585e_177f_3839_a8b4_bd1e1daabdff["MessageAggregatorTest"]
  ae1fef7f_bd3e_d252_c9ee_681ba697560b -->|defined in| bc4d585e_177f_3839_a8b4_bd1e1daabdff
  style ae1fef7f_bd3e_d252_c9ee_681ba697560b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-base/src/test/java/io/netty/handler/codec/MessageAggregatorTest.java lines 66–96

    @Test
    public void testReadFlowManagement() throws Exception {
        ReadCounter counter = new ReadCounter();
        ByteBufHolder first = message("first");
        ByteBufHolder chunk = message("chunk");
        ByteBufHolder last = message("last");

        MockMessageAggregator agg = spy(MockMessageAggregator.class);
        when(agg.isStartMessage(first)).thenReturn(true);
        when(agg.isContentMessage(chunk)).thenReturn(true);
        when(agg.isContentMessage(last)).thenReturn(true);
        when(agg.isLastContentMessage(last)).thenReturn(true);

        EmbeddedChannel embedded = new EmbeddedChannel(counter, agg);
        embedded.config().setAutoRead(false);

        assertFalse(embedded.writeInbound(first));
        assertFalse(embedded.writeInbound(chunk));
        assertTrue(embedded.writeInbound(last));

        assertEquals(3, counter.value); // 2 reads issued from MockMessageAggregator
                                        // 1 read issued from EmbeddedChannel constructor

        ByteBufHolder all = new DefaultByteBufHolder(Unpooled.wrappedBuffer(
            first.content().retain(), chunk.content().retain(), last.content().retain()));
        ByteBufHolder out = embedded.readInbound();

        assertEquals(all, out);
        assertTrue(all.release() && out.release());
        assertFalse(embedded.finish());
    }