Method waitForMessages

cli/src/utils/MessageQueue2.ts:389–439

* Wait for messages to arrive

(abortSignal?: AbortSignal)

     * Wait for messages to arrive
     */
    private waitForMessages(abortSignal?: AbortSignal): Promise<boolean> {
        return new Promise((resolve) => {
            let settled = false;
            let abortHandler: (() => void) | null = null;
            let waiterFunc: (hasMessages: boolean) => void;

            const finish = (hasMessages: boolean) => {
                if (settled) {
                    return;
                }
                settled = true;
                if (this.waiter === waiterFunc) {
                    this.waiter = null;
                }
                // Clean up abort handler
                if (abortHandler && abortSignal) {
                    abortSignal.removeEventListener('abort', abortHandler);
                }
                resolve(hasMessages);
            };

            waiterFunc = (hasMessages: boolean) => {
                finish(hasMessages);
            };

            // Set up abort handler
            if (abortSignal) {
                abortHandler = () => {
                    logger.debug('[MessageQueue2] Wait aborted');
                    finish(false);
                };
                abortSignal.addEventListener('abort', abortHandler);
            }

            // Set the waiter before checking the queue to avoid missed notifications
            this.waiter = waiterFunc;

            // Check again in case messages arrived or queue closed while setting up
            if (this.queue.length > 0) {
                finish(true);
                return;
            }

            if (this.closed || abortSignal?.aborted) {
                finish(false);
                return;
            }

            logger.debug('[MessageQueue2] Waiting for messages...');
        });
    }
}