channelRead() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 2

Entity Profile

Buffer→ Telemetry→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  fd4cb239_0079_4349_2f0a_6fdb29ae051d["channelRead()"]
  3cd79522_6bee_9112_a872_451fa97e98c4["ReRegisterHandler"]
  fd4cb239_0079_4349_2f0a_6fdb29ae051d -->|defined in| 3cd79522_6bee_9112_a872_451fa97e98c4
  7b09c379_bbd9_a5c3_c129_13140fc43d2c["channelRead()"]
  7b09c379_bbd9_a5c3_c129_13140fc43d2c -->|calls| fd4cb239_0079_4349_2f0a_6fdb29ae051d
  a9154bc0_2e31_08b0_6b9a_230dfe452c5a["testReregisterOnChannelHandlerContext()"]
  a9154bc0_2e31_08b0_6b9a_230dfe452c5a -->|calls| fd4cb239_0079_4349_2f0a_6fdb29ae051d
  7b09c379_bbd9_a5c3_c129_13140fc43d2c["channelRead()"]
  fd4cb239_0079_4349_2f0a_6fdb29ae051d -->|calls| 7b09c379_bbd9_a5c3_c129_13140fc43d2c
  style fd4cb239_0079_4349_2f0a_6fdb29ae051d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/AbstractEventLoopTest.java lines 186–203

        @Override
        public void channelRead(ChannelHandlerContext outCtx, Object msg) throws Exception {
            final EventLoop newLoop = anyNotEqual(outCtx.channel().eventLoop());
            ChannelFutureListener pipelieModifyingListener = register -> {
                outCtx.pipeline().addLast(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelRead(ChannelHandlerContext inCtx, Object inMsg) {
                        outCtx.writeAndFlush(inMsg);
                    }
                });
                outCtx.fireChannelRead(msg);
            };
            ChannelFutureListener reregisteringListener = deregister -> {
                deregister.channel().pipeline().fireUserEventTriggered("Unregistered user event");
                newLoop.register(deregister.channel()).addListener(pipelieModifyingListener);
            };
            method.apply(outCtx).addListener(reregisteringListener);
        }