releaseBatchReservations method

Future<void> releaseBatchReservations(
  1. List<int> ids
)

Release in-flight reservations after a flush attempt fails.

Implementation

Future<void> releaseBatchReservations(List<int> ids) async {
  await _lock.synchronized(() async {
    final memorySeqs = <int>{};

    for (final id in ids) {
      if (id < 0) {
        memorySeqs.add(-(id) - 1);
      }
    }

    if (memorySeqs.isNotEmpty) {
      _memoryQueue.releaseInFlight(memorySeqs);
    }
  });
}