Fix resume method

Author: tshemsedinov

JavaScript/3-pause.js

@@ -64,7 +64,7 @@ class Queue {
         this.finish(err, task);
         if (waiting.length > 0) {
           setTimeout(() => {
-            if (!this.paused) this.takeNext();
+            if (!this.paused && waiting.length > 0) this.takeNext();
           }, 0);
         }
         return;
@@ -109,11 +109,13 @@ class Queue {
     return this;
   }
   resume() {
-    this.paused = false;
     if (this.waiting.length > 0) {
-      const hasChannel = this.count < this.concurrency;
-      if (hasChannel) this.takeNext();
+      const channels = this.concurrency - this.count;
+      for (let i = 0; i < channels; i++) {
+        this.takeNext();
+      }
     }
+    this.paused = false;
     return this;
   }
 }

JavaScript/4-priority.js

@@ -68,7 +68,7 @@ class Queue {
         this.finish(err, task);
         if (waiting.length > 0) {
           setTimeout(() => {
-            if (this.paused && waiting.length > 0) this.takeNext();
+            if (!this.paused && waiting.length > 0) this.takeNext();
           }, 0);
         }
         return;
@@ -113,11 +113,13 @@ class Queue {
     return this;
   }
   resume() {
-    this.paused = false;
     if (this.waiting.length > 0) {
-      const hasChannel = this.count < this.concurrency;
-      if (hasChannel) this.takeNext();
+      const channels = this.concurrency - this.count;
+      for (let i = 0; i < channels; i++) {
+        this.takeNext();
+      }
     }
+    this.paused = false;
     return this;
   }
   priority(flag = true) {

JavaScript/5-pipe.js

@@ -69,7 +69,7 @@ class Queue {
         this.finish(err, task);
         if (waiting.length > 0) {
           setTimeout(() => {
-            if (this.paused && waiting.length > 0) this.takeNext();
+            if (!this.paused && waiting.length > 0) this.takeNext();
           }, 0);
         }
         return;
@@ -115,11 +115,13 @@ class Queue {
     return this;
   }
   resume() {
-    this.paused = false;
     if (this.waiting.length > 0) {
-      const hasChannel = this.count < this.concurrency;
-      if (hasChannel) this.takeNext();
+      const channels = this.concurrency - this.count;
+      for (let i = 0; i < channels; i++) {
+        this.takeNext();
+      }
     }
+    this.paused = false;
     return this;
   }
   priority(flag = true) {