import { FixedThreadPool } from 'poolifier';
-import { WorkerData, WorkerOptions } from '../types/Worker';
+import type { WorkerData, WorkerOptions } from '../types/Worker';
import Utils from '../utils/Utils';
import WorkerAbstract from './WorkerAbstract';
import { WorkerUtils } from './WorkerUtils';
*/
constructor(workerScript: string, workerOptions?: WorkerOptions) {
super(workerScript, workerOptions);
+ this.workerOptions.poolOptions.errorHandler =
+ this.workerOptions?.poolOptions?.errorHandler ?? WorkerUtils.defaultErrorHandler;
this.workerOptions.poolOptions.exitHandler =
this.workerOptions?.poolOptions?.exitHandler ?? WorkerUtils.defaultExitHandler;
this.pool = new FixedThreadPool(