channelRead() — netty Function Reference

Architecture documentation for the channelRead() function in SocketAutoReadTest.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  5354ae69_2a7d_32f3_2ac2_b96eb6a502a3["channelRead()"]
  54eba447_08e7_08fe_25cd_f47eb3c99e5a["AutoReadHandler"]
  5354ae69_2a7d_32f3_2ac2_b96eb6a502a3 -->|defined in| 54eba447_08e7_08fe_25cd_f47eb3c99e5a
  style 5354ae69_2a7d_32f3_2ac2_b96eb6a502a3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/socket/SocketAutoReadTest.java lines 137–147

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            ReferenceCountUtil.release(msg);
            if (count.incrementAndGet() == 1) {
                ctx.channel().config().setAutoRead(false);
            }
            if (callRead) {
                // Test calling read in the EventLoop thread to ensure a read is eventually done.
                ctx.read();
            }
        }