dequeueMutation method

  1. @override
Future<void> dequeueMutation(
  1. String requestId
)
override

Implementation

@override
Future<void> dequeueMutation(String requestId) async {
  await _tracked(() async {
    await _ensureInitialized();
    await _locks.mutations.synchronized(() async {
      await _ensureQueueLoadedUnsafe();
      _queue.removeWhere((m) => m.requestId == requestId);
      await _appendJournalUnsafe({'op': 'dequeue', 'requestId': requestId});
      await _maybeCompactUnsafe();
    });
  });
}