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 {
  final result = await _redis.client.send_object(['LLEN', _getQueueKey(queue)]);
  return result as int;
}