channelRead() — netty Function Reference

Architecture documentation for the channelRead() function in LocalTransportThreadModelTest.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
  6348c4c7_af5b_1906_cb20_8d15cf666108["channelRead()"]
  4416ca34_8b23_0a00_46de_59cd1da38ed7["MessageDiscarder"]
  6348c4c7_af5b_1906_cb20_8d15cf666108 -->|defined in| 4416ca34_8b23_0a00_46de_59cd1da38ed7
  1bd859c5_a859_6819_c97f_7afc68bc6800["init()"]
  1bd859c5_a859_6819_c97f_7afc68bc6800 -->|calls| 6348c4c7_af5b_1906_cb20_8d15cf666108
  85f17597_0918_a0c8_297d_c8f56617c6be["channelRead()"]
  6348c4c7_af5b_1906_cb20_8d15cf666108 -->|calls| 85f17597_0918_a0c8_297d_c8f56617c6be
  style 6348c4c7_af5b_1906_cb20_8d15cf666108 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java lines 579–591

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            Thread t = this.t;
            if (t == null) {
                this.t = Thread.currentThread();
            } else {
                assertSame(t, Thread.currentThread());
            }

            int actual = (Integer) msg;
            int expected = inCnt ++;
            assertEquals(expected, actual);
        }