enqueueMutation method

  1. @override
Future<void> enqueueMutation(
  1. PendingMutation mutation
)
override

Implementation

@override
Future<void> enqueueMutation(PendingMutation mutation) async {
  await _tracked(() async {
    await _ensureInitialized();
    await _locks.mutations.synchronized(() async {
      await _ensureQueueLoadedUnsafe();
      _queue.add(mutation);
      await _appendJournalUnsafe({
        'op': 'enqueue',
        'mutation': mutation.toJson(),
      });
    });
  });
}