write() — netty Function Reference

Architecture documentation for the write() function in LocalTransportThreadModelTest.java from the netty codebase.

Function java Buffer Telemetry calls 1 called by 1

Entity Profile

Buffer→ Telemetry→ write() — netty Function Reference

Dependency Diagram

graph TD
  bcebdee4_e5fa_bd89_67bf_34873fa50e5b["write()"]
  5d9bf869_26ee_1468_df42_d7b387c194da["MessageForwarder3"]
  bcebdee4_e5fa_bd89_67bf_34873fa50e5b -->|defined in| 5d9bf869_26ee_1468_df42_d7b387c194da
  8aab9b97_817c_1676_25bc_fb10a37c9473["write()"]
  8aab9b97_817c_1676_25bc_fb10a37c9473 -->|calls| bcebdee4_e5fa_bd89_67bf_34873fa50e5b
  b71fa464_aa34_c554_4b9a_ed67afd8bdcf["write()"]
  bcebdee4_e5fa_bd89_67bf_34873fa50e5b -->|calls| b71fa464_aa34_c554_4b9a_ed67afd8bdcf
  style bcebdee4_e5fa_bd89_67bf_34873fa50e5b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java lines 549–558

        @Override
        public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
            assertSame(t, Thread.currentThread());

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

            ctx.write(msg, promise);
        }