convert priorityQueue tests to mocha

1 files changed, 9 insertions, 6 deletions

diff --git a/lib/internal/queue.js b/lib/internal/queue.js
index 3e7eb1e..9521091 100644
--- a/lib/internal/queue.js
+++ b/lib/internal/queue.js
@@ -42,12 +42,6 @@ export default function queue(worker, concurrency, payload) {
                 q.tasks.push(item);
             }
 
-            if (q.tasks.length === q.concurrency) {
-                q.saturated();
-            }
-            if (q.tasks.length <= (q.concurrency - q.buffer) ) {
-                q.unsaturated();
-            }
         });
         setImmediate(q.process);
     }
@@ -111,8 +105,17 @@ export default function queue(worker, concurrency, payload) {
                 }
                 workers += 1;
                 workersList.push(tasks[0]);
+
+                if (workers === q.concurrency) {
+                    q.saturated();
+                }
+                if (workers <= (q.concurrency - q.buffer) ) {
+                    q.unsaturated();
+                }
+
                 var cb = onlyOnce(_next(q, tasks));
                 worker(data, cb);
+
             }
         },
         length: function () {