})
await this.sendKillMessageToWorker(workerNodeKey)
workerNode.closeChannel()
+ workerNode.removeAllListeners()
await worker.terminate()
await waitWorkerExit
}
): void {
(
this.workerNodes[workerNodeKey]?.messageChannel as MessageChannel
- ).port1.postMessage(
+ )?.port1?.postMessage(
{ ...message, workerId: this.getWorkerInfo(workerNodeKey).id },
transferList
)