From d18000b71d9c2a7d61b9ff9621513f2b0b6c3122 Mon Sep 17 00:00:00 2001
From: Suguru Motegi <suguru.motegi@gmail.com>
Date: Tue, 26 Apr 2016 20:27:11 -0700
Subject: fix `priorityQueue`

---
 lib/priorityQueue.js        | 6 ------
 mocha_test/priorityQueue.js | 3 ---
 2 files changed, 9 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);
         });
     }
diff --git a/mocha_test/priorityQueue.js b/mocha_test/priorityQueue.js
index fa5cfce..6ac3d15 100644
--- a/mocha_test/priorityQueue.js
+++ b/mocha_test/priorityQueue.js
@@ -148,9 +148,6 @@ describe('priorityQueue', function() {
                 expect(calls.indexOf('unsaturated')).to.be.above(-1);
                 setTimeout(function() {
                     expect(calls).eql([
-                        'unsaturated',
-                        'unsaturated',
-                        'unsaturated',
                         'process foo4',
                         'process foo3',
                         'process foo2',
-- 
cgit v1.2.1