netty Architecture Docs
Home / Function/ testAggregateWithTrailer() — netty Function Reference

testAggregateWithTrailer() — netty Function Reference

Architecture documentation for the testAggregateWithTrailer() function in HttpObjectAggregatorTest.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Dependency Diagram

graph TD
  87e256f9_170c_799e_8d36_6963bfef5eb1["testAggregateWithTrailer()"]
  32ca569a_2b67_1114_bbc8_cbf703c91b95["HttpObjectAggregatorTest"]
  87e256f9_170c_799e_8d36_6963bfef5eb1 -->|defined in| 32ca569a_2b67_1114_bbc8_cbf703c91b95
  289e67e4_9cfc_4a06_6bad_12c03f6651f2["checkContentBuffer()"]
  87e256f9_170c_799e_8d36_6963bfef5eb1 -->|calls| 289e67e4_9cfc_4a06_6bad_12c03f6651f2
  style 87e256f9_170c_799e_8d36_6963bfef5eb1 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http/src/test/java/io/netty/handler/codec/http/HttpObjectAggregatorTest.java lines 88–116

    @Test
    public void testAggregateWithTrailer() {
        HttpObjectAggregator aggr = new HttpObjectAggregator(1024 * 1024);
        EmbeddedChannel embedder = new EmbeddedChannel(aggr);
        HttpRequest message = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "http://localhost");
        message.headers().set(of("X-Test"), true);
        HttpUtil.setTransferEncodingChunked(message, true);
        HttpContent chunk1 = new DefaultHttpContent(Unpooled.copiedBuffer("test", CharsetUtil.US_ASCII));
        HttpContent chunk2 = new DefaultHttpContent(Unpooled.copiedBuffer("test2", CharsetUtil.US_ASCII));
        LastHttpContent trailer = new DefaultLastHttpContent();
        trailer.trailingHeaders().set(of("X-Trailer"), true);

        assertFalse(embedder.writeInbound(message));
        assertFalse(embedder.writeInbound(chunk1));
        assertFalse(embedder.writeInbound(chunk2));

        // this should trigger a channelRead event so return true
        assertTrue(embedder.writeInbound(trailer));
        assertTrue(embedder.finish());
        FullHttpRequest aggregatedMessage = embedder.readInbound();
        assertNotNull(aggregatedMessage);

        assertEquals(chunk1.content().readableBytes() + chunk2.content().readableBytes(),
                HttpUtil.getContentLength(aggregatedMessage));
        assertEquals(Boolean.TRUE.toString(), aggregatedMessage.headers().get(of("X-Test")));
        assertEquals(Boolean.TRUE.toString(), aggregatedMessage.trailingHeaders().get(of("X-Trailer")));
        checkContentBuffer(aggregatedMessage);
        assertNull(embedder.readInbound());
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does testAggregateWithTrailer() do?
testAggregateWithTrailer() is a function in the netty codebase, defined in codec-http/src/test/java/io/netty/handler/codec/http/HttpObjectAggregatorTest.java.
Where is testAggregateWithTrailer() defined?
testAggregateWithTrailer() is defined in codec-http/src/test/java/io/netty/handler/codec/http/HttpObjectAggregatorTest.java at line 88.
What does testAggregateWithTrailer() call?
testAggregateWithTrailer() calls 1 function(s): checkContentBuffer.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free