public void channelRead()

in tchannel-core/src/main/java/com/uber/tchannel/handlers/LoadControlHandler.java [37:45]

• 9 lines of code
• 4 McCabe index (conditional complexity)

    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        if (msg instanceof Request) {
            ChannelConfig config = ctx.channel().config();
            if (++outstanding >= high && config.isAutoRead()) {
                config.setAutoRead(false);
            }
        }
        ctx.fireChannelRead(msg);
    }