- class ChargingStationWorker extends AsyncResource {
- constructor() {
- super('ChargingStationWorker');
- }
-
- public run(data: ChargingStationWorkerData): void {
- this.runInAsyncScope(
- startChargingStation.bind(this) as (data: ChargingStationWorkerData) => void,
- this,
- data
- );
- }
- }
- // Add message listener to start charging station from main thread
- parentPort?.on('message', (message: WorkerMessage<ChargingStationWorkerData>) => {
- if (message.id === WorkerMessageEvents.startWorkerElement) {
- startChargingStation(message.data);
- }
- });
- if (workerData !== undefined) {
- new ChargingStationWorker().run(workerData as ChargingStationWorkerData);
- }