clearMutationQueue method

@override Future<void> clearMutationQueue()

Implementation

@override
Future<void> clearMutationQueue() async {
  await _tracked(() async {
    await _ensureInitialized();
    await _locks.mutations.synchronized(() async {
      _queue.clear();
      _queueLoaded = true;
      _journalOpCount = 0;
      if (await _mutationsFile!.exists()) {
        await _mutationsFile!.delete();
      }
      if (await _journalFile!.exists()) {
        await _journalFile!.delete();
      }
    });
  });
}