testCompress() — netty Function Reference

Architecture documentation for the testCompress() function in CodecCompressionTest.java from the netty codebase.

Function java Buffer Telemetry called by 2

Entity Profile

Buffer→ Telemetry→ testCompress() — netty Function Reference

Dependency Diagram

graph TD
  1752b0b1_7b50_0c26_ad71_af62cf815017["testCompress()"]
  3ccb7162_6782_66b0_7c76_efe45f5a039b["CodecCompressionTest"]
  1752b0b1_7b50_0c26_ad71_af62cf815017 -->|defined in| 3ccb7162_6782_66b0_7c76_efe45f5a039b
  bf2ac2cc_a5fb_e637_40f5_b7524edacf2c["testBrotli4j()"]
  bf2ac2cc_a5fb_e637_40f5_b7524edacf2c -->|calls| 1752b0b1_7b50_0c26_ad71_af62cf815017
  853d4477_7420_e4e5_e340_0f01e7301f8a["testZstd()"]
  853d4477_7420_e4e5_e340_0f01e7301f8a -->|calls| 1752b0b1_7b50_0c26_ad71_af62cf815017
  style 1752b0b1_7b50_0c26_ad71_af62cf815017 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite-jpms/src/test/java/io/netty/testsuite_jpms/test/CodecCompressionTest.java lines 43–58

    public void testCompress(MessageToByteEncoder<ByteBuf> encoder) {
        EmbeddedChannel channel = new EmbeddedChannel(encoder);
        ByteBuf data = Unpooled.copiedBuffer("some-string", StandardCharsets.UTF_8);
        assertTrue(channel.writeOutbound(data));
        assertTrue(channel.finish());
        assertEquals(0, data.readableBytes());
        int size = 0;
        for (ByteBuf chunk = channel.readOutbound(); chunk != null; chunk = channel.readOutbound()) {
            // Zstd can emit an empty buffer (flush)
            if (chunk != Unpooled.EMPTY_BUFFER) {
                size += chunk.readableBytes();
                assertTrue(chunk.release());
            }
        }
        assertTrue(size > 0);
    }