1 import { availableParallelism
} from
'poolifier'
2 import { fetchPool
} from
'./pool.js'
3 import { type WorkerResponse
} from
'./types.js'
5 const parallelism
= availableParallelism()
6 const requestUrl
= 'http://localhost:8080/'
8 const fetchPoolPromises
= new Set
<Promise
<WorkerResponse
>>()
9 for (let i
= 0; i
< availableParallelism(); i
++) {
10 fetchPoolPromises
.add(fetchPool
.execute({ url
: requestUrl
}))
14 const now
= performance
.now()
15 const responses
= await Promise
.all(fetchPoolPromises
)
16 const elapsedTime
= performance
.now() - now
18 `Received in ${elapsedTime.toFixed(2)}ms an array with ${
20 } responses from ${parallelism} parallel requests made with node-fetch on ${requestUrl}:\n`,