diff options
Diffstat (limited to 'lib/priorityQueue.js')
-rw-r--r-- | lib/priorityQueue.js | 6 |
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); }); } |