availableParallelism(),
'./multiFunctionWorker.js',
{
- errorHandler: (e) => console.error(e),
+ errorHandler: e => console.error(e),
onlineHandler: () => console.info('worker is online')
}
)
pool
.execute({ text: 'hello' }, 'fn0')
- .then((res) => console.info(res))
- .catch((err) => console.error(err))
+ .then(res => console.info(res))
+ .catch(err => console.error(err))
pool
.execute({ text: 'multiple functions' }, 'fn1')
- .then((res) => console.info(res))
- .catch((err) => console.error(err))
+ .then(res => console.info(res))
+ .catch(err => console.error(err))
-setTimeout(pool.destroy(), 3000)
+setTimeout(async () => await pool.destroy(), 3000)