Lines Matching refs:q
71 q.started = true;
82 … var item = q._createTaskItem(data, rejectOnError ? promiseCallback : callback || promiseCallback);
85 q._tasks.unshift(item);
87 q._tasks.push(item);
94 q.process();
127 if (numRunning <= q.concurrency - q.buffer) {
131 if (q.idle()) {
134 q.process();
139 if (data.length === 0 && q.idle()) {
161 var q = { variable
170 yield* q._tasks[Symbol.iterator]();
193 q._tasks.empty();
210 q._tasks.remove(testFn);
219 while (!q.paused && numRunning < q.concurrency && q._tasks.length) {
222 var l = q._tasks.length;
223 if (q.payload) l = Math.min(l, q.payload);
225 var node = q._tasks.shift();
233 if (q._tasks.length === 0) {
237 if (numRunning === q.concurrency) {
247 return q._tasks.length;
256 return q._tasks.length + numRunning === 0;
259 q.paused = true;
262 if (q.paused === false) {
265 q.paused = false;
266 (0, _setImmediate2.default)(q.process);
270 Object.defineProperties(q, {
292 return q;