clear method

  1. @override
Future<void> clear(
  1. String queue
)
override

Clear all jobs from a queue

Implementation

@override
Future<void> clear(String queue) async {
  await _redis.client.send_object(['DEL', _getQueueKey(queue)]);
}