channelReadComplete() — netty Function Reference

Architecture documentation for the channelReadComplete() function in FlowControlHandler.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ channelReadComplete() — netty Function Reference

Dependency Diagram

graph TD
  7521bde4_9626_8e3b_0f5d_4bde6e9ffb9d["channelReadComplete()"]
  a378d3b4_7977_a8fc_c1dd_b695ec779172["FlowControlHandler"]
  7521bde4_9626_8e3b_0f5d_4bde6e9ffb9d -->|defined in| a378d3b4_7977_a8fc_c1dd_b695ec779172
  ece3f16c_f517_592d_83b3_6b0a7b34835b["isQueueEmpty()"]
  7521bde4_9626_8e3b_0f5d_4bde6e9ffb9d -->|calls| ece3f16c_f517_592d_83b3_6b0a7b34835b
  231cc677_f63d_f911_377d_62f5edbedf36["dequeue()"]
  7521bde4_9626_8e3b_0f5d_4bde6e9ffb9d -->|calls| 231cc677_f63d_f911_377d_62f5edbedf36
  style 7521bde4_9626_8e3b_0f5d_4bde6e9ffb9d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/flow/FlowControlHandler.java lines 166–175

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        if (isQueueEmpty()) {
            ctx.fireChannelReadComplete();
        } else {
            // Don't relay completion events from upstream as they
            // make no sense in this context. See dequeue() where
            // a new set of completion events is being produced.
        }
    }