fix pool limit check

shevernitskiy · Feb 7, 2024 · eadfb2e · eadfb2e
1 parent 8085ee0
commit eadfb2e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/core/async-queue.ts b/src/core/async-queue.ts
@@ -61,7 +61,7 @@ export class ConcurrentPool<T> implements AsyncQueue<T> {
       return;
     }
 
-    if (this.concurrent <= this.size) {
+    if (this.concurrent < this.size) {
       const promise = this.stack.shift();
       promise?.resolve(promise.fn());