summaryrefslogtreecommitdiff
path: root/lib/priorityQueue.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/priorityQueue.js')
-rw-r--r--lib/priorityQueue.js6
1 files changed, 0 insertions, 6 deletions
diff --git a/lib/priorityQueue.js b/lib/priorityQueue.js
index a33f2f5..4c29596 100644
--- a/lib/priorityQueue.js
+++ b/lib/priorityQueue.js
@@ -73,12 +73,6 @@ export default function(worker, concurrency) {
q.tasks.splice(_binarySearch(q.tasks, item, _compareTasks) + 1, 0, item);
- if (q.tasks.length === q.concurrency) {
- q.saturated();
- }
- if (q.tasks.length <= (q.concurrency - q.buffer) ) {
- q.unsaturated();
- }
setImmediate(q.process);
});
}