flush method

@override Future<int> flush(String queue)

Implementation

@override
Future<int> flush(String queue) async {
  await initialize();
  return database.execute(
    'DELETE FROM $tableName WHERE queue = ?',
    <Object?>[queue],
  );
}