channelReadComplete() — netty Function Reference

Source Code

codec-classes-quic/src/main/java/io/netty/handler/codec/quic/QuicCodecDispatcher.java lines 136–155

    @Override
    public final void channelReadComplete(ChannelHandlerContext ctx) {
        // Loop over all ChannelHandlerContextDispatchers and ensure fireChannelReadComplete() is called if required.
        // We use and old style for loop as CopyOnWriteArrayList implements RandomAccess and so we can
        // reduce the object creations.
        boolean dispatchForOwnContextAlready = false;
        for (int i = 0; i < contextList.size(); i++) {
            ChannelHandlerContextDispatcher ctxDispatcher = contextList.get(i);
            if (ctxDispatcher != null) {
                boolean fired = ctxDispatcher.fireChannelReadCompleteIfNeeded();
                if (fired && !dispatchForOwnContextAlready) {
                    // Check if we dispatched to ctx so if we didnt at the end we can do it manually.
                    dispatchForOwnContextAlready = ctx.equals(ctxDispatcher.ctx);
                }
            }
        }
        if (!dispatchForOwnContextAlready) {
            ctx.fireChannelReadComplete();
        }
    }