fix(utils): fixes in createParalellRunner

kedrzu · Apr 9, 2024 · 8e09d1f · 8e09d1f
1 parent da77580
commit 8e09d1f
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/packages/utils/src/createParalellRunner.ts b/packages/utils/src/createParalellRunner.ts
@@ -12,13 +12,10 @@ export function createParalellRunner(options: ParalelllRunnerOptions) {
     let active = 0;
     let done = true;
 
-    for (let i = 0; i < concurrency; i++) {
-        void startThread();
-    }
-
     return {
         start,
         stop,
+        wait,
     };
 
     async function start() {
@@ -40,19 +37,25 @@ export function createParalellRunner(options: ParalelllRunnerOptions) {
         await promise?.promise;
     }
 
+    async function wait() {
+        await promise?.promise;
+    }
+
     async function startThread() {
         active++;
 
         // eslint-disable-next-line no-constant-condition
         while (true) {
             if (done) {
                 stopThread();
+                return;
             }
 
             try {
                 const result = await handler();
                 if (result === false) {
                     stopThread();
+                    return;
                 }
             } catch (e) {
                 active--;