Added ability to start a job immediately

Closes jessetane#71
bugs181 · May 31, 2020 · dfdd6b0 · dfdd6b0
1 parent 9ca37f0
commit dfdd6b0
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/index.js b/index.js
@@ -46,6 +46,12 @@ Queue.prototype.reverse = function () {
   return this
 }
 
+Queue.prototype.pushImmediate = function () {
+  Array.prototype.unshift.apply(this.jobs, arguments)
+  this.start(null, true)
+  return this
+}
+
 var arrayAddMethods = [
   'push',
   'unshift',
@@ -75,8 +81,10 @@ Queue.prototype.start = function (cb) {
 
   this.running = true
 
-  if (this.pending >= this.concurrency) {
-    return
+  if (!startImmediate) {
+    if (this.pending >= this.concurrency) {
+      return
+    }
   }
 
   if (this.jobs.length === 0) {