- protected unregisterWorkerMessageListener (
- port: Worker,
- listener: (message: MessageValue<Response>) => void
- ): void {
- port.removeListener('message', listener)
+ /** {@inheritDoc} */
+ protected createWorker (): Worker {
+ return cluster.fork(this.opts.env)
+ }
+
+ /** {@inheritDoc} */
+ protected afterWorkerSetup (worker: Worker): void {
+ // Listen to worker messages.
+ this.registerWorkerMessageListener(worker, super.workerListener())