X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fhttp-client-pool%2Fsrc%2Fmain.ts;h=722de1e6dc200bbc535f1dfce8db4516d6c95d58;hb=48eab5902faccd2b14649e0fe4477778ec70ba96;hp=1f4532c9a0147d7a30e443724c6851bbb52bd412;hpb=5ba0cd3c9bdb6479399aa77f45321ac72183f135;p=poolifier.git diff --git a/examples/typescript/http-client-pool/src/main.ts b/examples/typescript/http-client-pool/src/main.ts index 1f4532c9..722de1e6 100644 --- 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>() - 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) {