pending method

Future<Map<String, int>> pending([
  1. List<String> queues = const ['default']
])

Returns the number of pending jobs across specified queues.

Implementation

Future<Map<String, int>> pending([List<String> queues = const ['default']]) async {
  final result = <String, int>{};
  for (final q in queues) {
    result[q] = await driver.size(q);
  }
  return result;
}