size method

@override Future<int> size([ String queue = 'default' ])

Returns the number of pending jobs in the queue.

Implementation

@override
Future<int> size([String queue = 'default']) async {
  final result = await _db.query('''
    SELECT COUNT(*) as count FROM $_table
    WHERE queue = @queue AND status = 'pending'
  ''', {'queue': queue});

  return result.rows.first['count'] as int? ?? 0;
}