forEachFlushedMessage() — netty Function Reference

Architecture documentation for the forEachFlushedMessage() function in ChannelOutboundBuffer.java from the netty codebase.

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ forEachFlushedMessage() — netty Function Reference

Dependency Diagram

graph TD
  4ed4c369_5392_8325_fb5c_4e527830391f["forEachFlushedMessage()"]
  509b1bc5_7cdc_9ee4_03d9_31eb2203d807["ChannelOutboundBuffer"]
  4ed4c369_5392_8325_fb5c_4e527830391f -->|defined in| 509b1bc5_7cdc_9ee4_03d9_31eb2203d807
  0d29d23e_e9c6_db6e_3ea6_b65a4cb94734["isFlushedEntry()"]
  4ed4c369_5392_8325_fb5c_4e527830391f -->|calls| 0d29d23e_e9c6_db6e_3ea6_b65a4cb94734
  style 4ed4c369_5392_8325_fb5c_4e527830391f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java lines 796–812

    public void forEachFlushedMessage(MessageProcessor processor) throws Exception {
        ObjectUtil.checkNotNull(processor, "processor");

        Entry entry = flushedEntry;
        if (entry == null) {
            return;
        }

        do {
            if (!entry.cancelled) {
                if (!processor.processMessage(entry.msg)) {
                    return;
                }
            }
            entry = entry.next;
        } while (isFlushedEntry(entry));
    }