Enforcing integer value for maxCurrencncy

Original bug found by @wmertens
jdalrymple · Dec 13, 2023 · c7e8286 · c7e8286
1 parent dd30c77
commit c7e8286
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/Sema.ts b/src/Sema.ts
@@ -45,6 +45,10 @@ export class Sema<T = string> {
       throw new Error('pauseFn and resumeFn must be both set for pausing');
     }
 
+    if (!Number.isInteger(maxConcurrency) || maxConcurrency < 0) {
+      throw new TypeError('maxConcurrency should be an integer and greater than zero');
+    }
+
     this.maxConcurrency = maxConcurrency;
     this.freeQ = new Deque(maxConcurrency);
     this.waitingQ = new Deque(capacity);