- // we will attach a listener for every task,
- // when task is completed the listener will be removed but to avoid warnings we are increasing the max listeners size
- worker.port2.setMaxListeners(this.opts.maxTasks ?? 1000)
+ // Listen to worker messages.
+ this.registerWorkerMessageListener(worker, super.workerListener())
+ }
+
+ /** @inheritDoc */
+ public get type (): PoolType {
+ return PoolType.FIXED
+ }
+
+ /** @inheritDoc */
+ public get busy (): boolean {
+ return this.internalGetBusyStatus()