+ /** @inheritDoc */
+ protected registerOnceWorkerMessageListener<Message extends Data | Response>(
+ workerNodeKey: number,
+ listener: (message: MessageValue<Message>) => void
+ ): void {
+ (
+ this.workerNodes[workerNodeKey].messageChannel as MessageChannel
+ ).port1.once('message', listener)
+ }
+
+ /** @inheritDoc */
+ protected deregisterWorkerMessageListener<Message extends Data | Response>(
+ workerNodeKey: number,
+ listener: (message: MessageValue<Message>) => void
+ ): void {
+ (
+ this.workerNodes[workerNodeKey].messageChannel as MessageChannel
+ ).port1.off('message', listener)
+ }
+