ConcurrentQueue constructor

ConcurrentQueue({
  1. bool autoStart = true,
  2. int concurrency = 1 << 32,
  3. Duration interval = Duration.zero,
  4. int intervalCap = 1 << 32,
  5. bool carryoverConcurrencyCount = false,
  6. Duration timeout = Duration.zero,
  7. bool throwOnTimeout = false,
})

Implementation

ConcurrentQueue({
  bool autoStart = true,
  int concurrency = 1<<32,
  Duration interval = Duration.zero,
  int intervalCap = 1<<32,
  bool carryoverConcurrencyCount = false,
  Duration timeout = Duration.zero,
  bool throwOnTimeout = false,
}) :
  _carryoverConcurrencyCount = carryoverConcurrencyCount,
  _isIntervalIgnored = intervalCap == double.infinity || interval == Duration.zero,
  _timeout = timeout,
  _throwOnTimeout = throwOnTimeout,
  _intervalCap = intervalCap,
  _interval = interval,
  _queue = PriorityQueue(),
  _concurrency = concurrency,
  _isPaused = autoStart == false,
  _eventStream = PublishSubject<QueueEvent>( sync: true );