channelRead() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 1

Entity Profile

Buffer→ Telemetry→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  d58eaa9b_d09e_69a1_69f3_838a1edbf736["channelRead()"]
  8bbb19af_791e_72d1_23a1_1f931abaf525["EchoServerHandler"]
  d58eaa9b_d09e_69a1_69f3_838a1edbf736 -->|defined in| 8bbb19af_791e_72d1_23a1_1f931abaf525
  39163b4d_6655_a05c_9205_fe0c42419b89["channelRead()"]
  39163b4d_6655_a05c_9205_fe0c42419b89 -->|calls| d58eaa9b_d09e_69a1_69f3_838a1edbf736
  39163b4d_6655_a05c_9205_fe0c42419b89["channelRead()"]
  d58eaa9b_d09e_69a1_69f3_838a1edbf736 -->|calls| 39163b4d_6655_a05c_9205_fe0c42419b89
  style d58eaa9b_d09e_69a1_69f3_838a1edbf736 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/socket/SocketConnectTest.java lines 268–279

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            if (msg instanceof ByteBuf) {
                ByteBuf buffer = ctx.alloc().buffer();
                ByteBuf buf = (ByteBuf) msg;
                buffer.writeBytes(buf);
                buf.release();
                ctx.channel().writeAndFlush(buffer);
            } else {
                throw new IllegalArgumentException("Unexpected message type: " + msg);
            }
        }