const worker = async (options) => {
const { Worker } = require('worker_threads');
const workerResult = await new Promise((resolve, reject) => {
const worker = new Worker(`${__dirname}/worker.js`, {
workerData: options
});
worker.on('message', resolve);
worker.on('error', reject);
worker.on('exit', (code) => {
if (code !== 0) {
reject(new Error(`Worker stopped with exit code ${code}`));
}
worker.terminate()
});
});
return workerResult
};
module.exports.worker = worker
