Home / Function/ testAggregateTransferEncodingChunked() — netty Function Reference

testAggregateTransferEncodingChunked() — netty Function Reference

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

Entity Profile

Dependency Diagram

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

Relationship Graph

Source Code

codec-http/src/test/java/io/netty/handler/codec/http/HttpObjectAggregatorTest.java lines 336–362

    @Test
    public void testAggregateTransferEncodingChunked() {
        HttpObjectAggregator aggr = new HttpObjectAggregator(1024 * 1024);
        EmbeddedChannel embedder = new EmbeddedChannel(aggr);

        HttpRequest message = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.PUT, "http://localhost");
        message.headers().set(of("X-Test"), true);
        message.headers().set(of("Transfer-Encoding"), of("Chunked"));
        HttpContent chunk1 = new DefaultHttpContent(Unpooled.copiedBuffer("test", CharsetUtil.US_ASCII));
        HttpContent chunk2 = new DefaultHttpContent(Unpooled.copiedBuffer("test2", CharsetUtil.US_ASCII));
        HttpContent chunk3 = LastHttpContent.EMPTY_LAST_CONTENT;
        assertFalse(embedder.writeInbound(message));
        assertFalse(embedder.writeInbound(chunk1));
        assertFalse(embedder.writeInbound(chunk2));

        // this should trigger a channelRead event so return true
        assertTrue(embedder.writeInbound(chunk3));
        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")));
        checkContentBuffer(aggregatedMessage);
        assertNull(embedder.readInbound());
    }

Domain

Subdomains

Frequently Asked Questions

What does testAggregateTransferEncodingChunked() do?
testAggregateTransferEncodingChunked() is a function in the netty codebase, defined in codec-http/src/test/java/io/netty/handler/codec/http/HttpObjectAggregatorTest.java.
Where is testAggregateTransferEncodingChunked() defined?
testAggregateTransferEncodingChunked() is defined in codec-http/src/test/java/io/netty/handler/codec/http/HttpObjectAggregatorTest.java at line 336.
What does testAggregateTransferEncodingChunked() call?
testAggregateTransferEncodingChunked() 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