clearMutationQueue method

  1. @override
Future<void> clearMutationQueue()
override

Implementation

@override
Future<void> clearMutationQueue() async {
  await _tracked(() async {
    await _locks.mutations.synchronized(() async {
      if (await _mutationsFile!.exists()) {
        await _mutationsFile!.delete();
      }
    });
  });
}