*/
constructor(workerScript: string, workerOptions?: WorkerOptions) {
super(workerScript, workerOptions);
- this.messageHandler = workerOptions?.messageHandler ?? (() => { /* This is intentional */ });
this.workerSet = new Set<WorkerSetElement>();
+ this.messageHandler = workerOptions?.messageHandler ?? (() => { /* This is intentional */ });
}
get size(): number {
if (this.getLastWorkerSetElement().numberOfWorkerElements >= this.workerOptions.elementsPerWorker) {
await this.startWorker();
}
- this.getLastWorker().postMessage({ id: WorkerMessageEvents.START_WORKER_ELEMENT, data: elementData });
+ this.getLastWorker().postMessage({ id: WorkerMessageEvents.START_WORKER_ELEMENT, workerOptions: this.workerOptions, data: elementData });
this.getLastWorkerSetElement().numberOfWorkerElements++;
- this.workerOptions.elementStartDelay > 0 && await Utils.sleep(this.workerOptions.elementStartDelay);
}
/**