acquire method

Future<void> acquire()

Implementation

Future<void> acquire() {
  if (_currentCount < _maxConcurrent) {
    _currentCount++;
    return Future.value();
  } else {
    final completer = Completer<void>();
    _queue.add(completer);
    return completer.future;
  }
}