process method

Future<void> process()

Process next highest priority job

Implementation

Future<void> process() async {
  final prioritizedJob = _queue.removeFirst();
  if (prioritizedJob == null) return;

  _jobsById.remove(prioritizedJob.id);

  try {
    await prioritizedJob.job.handle();
  } catch (e) {
    // Error handling would go here
    rethrow;
  }
}