processQueue method

@override Future<void> processQueue()

Processes the queue.

Implementation

@override
Future<void> processQueue() async {
  if (!_isInitialized) {
    await initialize();
  }

  // Prevent concurrent processing
  if (_isProcessing) {
    ChatLogger.debug('Queue already processing, skipping');
    return;
  }

  _isProcessing = true;

  try {
    await _processQueueInternal();
  } finally {
    _isProcessing = false;
  }
}