close method

Future<void> close()

Closes the queue. The queue cannot be used after closing.

Implementation

Future<void> close() async {
  await _mutex.lock(() async {
    if (_closed) return;

    await _stopSyncingInternal();
    _closed = true;
    _logger.info('AttachmentQueue closed.');
  });
}