From fbcf5e158672b78b5c495f30df86699a1b2360d4 Mon Sep 17 00:00:00 2001
From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= <jerome.benoit@piment-noir.org>
Date: Wed, 27 Mar 2024 18:12:19 +0100
Subject: [PATCH] docs: refactor TS example
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
---
 examples/typescript/pool.ts   | 8 ++++++--
 examples/typescript/worker.ts | 2 +-
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/examples/typescript/pool.ts b/examples/typescript/pool.ts
index c55c4e96..fb48f7b0 100644
--- a/examples/typescript/pool.ts
+++ b/examples/typescript/pool.ts
@@ -14,7 +14,7 @@ const workerFile = join(
   `worker${extname(fileURLToPath(import.meta.url))}`
 )
 
-export const fixedPool = new FixedThreadPool<MyData, MyResponse>(
+const fixedPool = new FixedThreadPool<MyData, MyResponse>(
   availableParallelism(),
   workerFile,
   {
@@ -27,7 +27,9 @@ export const fixedPool = new FixedThreadPool<MyData, MyResponse>(
   }
 )
 
-export const dynamicPool = new DynamicThreadPool<MyData, MyResponse>(
+await fixedPool.execute()
+
+const dynamicPool = new DynamicThreadPool<MyData, MyResponse>(
   Math.floor(availableParallelism() / 2),
   availableParallelism(),
   workerFile,
@@ -41,6 +43,8 @@ export const dynamicPool = new DynamicThreadPool<MyData, MyResponse>(
   }
 )
 
+await dynamicPool.execute()
+
 // eslint-disable-next-line @typescript-eslint/no-misused-promises
 setTimeout(async () => {
   await fixedPool.destroy()
diff --git a/examples/typescript/worker.ts b/examples/typescript/worker.ts
index 79819d98..1d8af8d9 100644
--- a/examples/typescript/worker.ts
+++ b/examples/typescript/worker.ts
@@ -20,7 +20,7 @@ class MyThreadWorker extends ThreadWorker<MyData, MyResponse> {
     return await new Promise(resolve => {
       setTimeout(() => {
         resolve({ message: 'Hello from Worker :)', data })
-      }, 10000)
+      }, 1000)
     })
   }
 }
-- 
2.34.1