initialize method

@override Future<void> initialize()

Initializes the queue, loading any persisted operations.

Implementation

@override
Future<void> initialize() async {
  if (_isInitialized) return;

  // Load persisted operations from database
  final persistedOps = await _database.getPendingOperations();
  _operations.addAll(persistedOps);
  _pendingCountController.add(_operations.length);
  _isInitialized = true;

  final pendingOps = _operations.length;
  ChatLogger.info('OutboundQueue initialized with $pendingOps pending ops');
}