ChannelPromise() — netty Function Reference

Architecture documentation for the ChannelPromise() function in PendingWriteQueue.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ ChannelPromise() — netty Function Reference

Dependency Diagram

graph TD
  a74a1023_8945_1782_ee15_7f4896283503["ChannelPromise()"]
  83722386_341f_50b9_cd3a_d141138801ae["PendingWriteQueue"]
  a74a1023_8945_1782_ee15_7f4896283503 -->|defined in| 83722386_341f_50b9_cd3a_d141138801ae
  d80642d8_7dc6_939b_e48a_94fa31dc8c25["recycle()"]
  a74a1023_8945_1782_ee15_7f4896283503 -->|calls| d80642d8_7dc6_939b_e48a_94fa31dc8c25
  style a74a1023_8945_1782_ee15_7f4896283503 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/PendingWriteQueue.java lines 250–260

    public ChannelPromise remove() {
        assert executor.inEventLoop();
        PendingWrite write = head;
        if (write == null) {
            return null;
        }
        ChannelPromise promise = write.promise;
        ReferenceCountUtil.safeRelease(write.msg);
        recycle(write, true);
        return promise;
    }