testForEachByteAbort() — netty Function Reference

Architecture documentation for the testForEachByteAbort() function in AbstractByteBufTest.java from the netty codebase.

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ testForEachByteAbort() — netty Function Reference

Dependency Diagram

graph TD
  62921fcc_ee6e_936e_159a_6df4b6819bcd["testForEachByteAbort()"]
  6540f2d1_cdad_6705_dd1d_9a24e2e53242["AbstractByteBufTest"]
  62921fcc_ee6e_936e_159a_6df4b6819bcd -->|defined in| 6540f2d1_cdad_6705_dd1d_9a24e2e53242
  8a937a41_8149_af3c_cc53_a4bb2a5522fa["process()"]
  62921fcc_ee6e_936e_159a_6df4b6819bcd -->|calls| 8a937a41_8149_af3c_cc53_a4bb2a5522fa
  style 62921fcc_ee6e_936e_159a_6df4b6819bcd fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

buffer/src/test/java/io/netty/buffer/AbstractByteBufTest.java lines 2641–2663

    @Test
    public void testForEachByteAbort() {
        buffer.clear();
        for (int i = 0; i < CAPACITY; i ++) {
            buffer.writeByte(i + 1);
        }

        final int stop = CAPACITY / 2;
        assertEquals(stop, buffer.forEachByte(CAPACITY / 3, CAPACITY / 3, new ByteProcessor() {
            int i = CAPACITY / 3;

            @Override
            public boolean process(byte value) throws Exception {
                assertEquals((byte) (i + 1), value);
                if (i == stop) {
                    return false;
                }

                i++;
                return true;
            }
        }));
    }