ConcurrentQueue constructor
ConcurrentQueue({})
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 );