chore: v3.1.30

[poolifier.git] / examples / typescript / http-client-pool / src / main.ts

diff --git a/examples/typescript/http-client-pool/src/main.ts b/examples/typescript/http-client-pool/src/main.ts
index 1f4532c9a0147d7a30e443724c6851bbb52bd412..722de1e6dc200bbc535f1dfce8db4516d6c95d58 100644 (file)
--- a/examples/typescript/http-client-pool/src/main.ts
+++ b/examples/typescript/http-client-pool/src/main.ts
@@ -1,13 +1,14 @@
 import { availableParallelism } from 'poolifier'
+
 import { httpClientPool } from './pool.js'
-import { type WorkerResponse } from './types.js'
+import type { WorkerResponse } from './types.js'
 
-const parallelism = availableParallelism()
+const parallelism = availableParallelism() * 2
 const requestUrl = 'http://localhost:8080/'
 
 for (const workerFunction of ['node_fetch', 'fetch', 'axios']) {
   const httpClientPoolPromises = new Set<Promise<WorkerResponse>>()
-  for (let i = 0; i < availableParallelism(); i++) {
+  for (let i = 0; i < parallelism; i++) {
     httpClientPoolPromises.add(
       httpClientPool.execute({ input: requestUrl }, workerFunction)
     )
@@ -19,7 +20,7 @@ for (const workerFunction of ['node_fetch', 'fetch', 'axios']) {
     console.info(
       `Received in ${elapsedTime.toFixed(2)}ms an array with ${
         responses.length
-      } responses from ${parallelism} parallel requests made with ${workerFunction} on ${requestUrl}:\n`,
+      } responses from ${parallelism} parallel requests made with HTTP client pool task function ${workerFunction} on ${requestUrl}:\n`,
       responses
     )
   } catch (error) {