pop method

  1. @override
Future<Job?> pop(
  1. String queue
)
override

Pop a job from the queue

Implementation

@override
Future<Job?> pop(String queue) async {
  final jobs = _queues[queue];
  if (jobs == null || jobs.isEmpty) return null;

  return jobs.removeAt(0);
}