start method

  1. @override
Future<void> start()

to start the execution of jobs in queue

Implementation

@override
Future<void> start() async {
  if (size == 0 || _isRunning) return;

  _isRunning = true;
  _emitEvent(QueueEventType.queueStart);

  while (size > 0) {
    if (_isForcedStop) break;
    await _dequeue();
  }

  _isRunning = false;
  _emitEvent(QueueEventType.queueEnd);
}