size method

  1. @override
Future<int> size(
  1. String queue
)
override

Get the number of pending jobs in a queue

Implementation

@override
Future<int> size(String queue) async {
  return _queues[queue]?.length ?? 0;
}