refactor: cleanup exports
[poolifier.git] / src / pools / cluster / fixed.ts
index f3fb54bbf4a08bd0ee6d28f623f3ac04f55630f1..46cabdcb75787700bab966bed3ce3312056659ad 100644 (file)
@@ -41,26 +41,6 @@ export class FixedClusterPool<
     return cluster.isPrimary
   }
 
-  /** @inheritDoc */
-  protected async destroyWorkerNode (workerNodeKey: number): Promise<void> {
-    this.flagWorkerNodeAsNotReady(workerNodeKey)
-    this.flushTasksQueue(workerNodeKey)
-    // FIXME: wait for tasks to be finished
-    const workerNode = this.workerNodes[workerNodeKey]
-    const waitWorkerExit = new Promise<void>(resolve => {
-      workerNode.registerOnceWorkerEventHandler('exit', () => {
-        resolve()
-      })
-    })
-    workerNode.registerOnceWorkerEventHandler('disconnect', () => {
-      workerNode.worker.kill()
-    })
-    await this.sendKillMessageToWorker(workerNodeKey)
-    workerNode.removeAllListeners()
-    workerNode.worker.disconnect()
-    await waitWorkerExit
-  }
-
   /** @inheritDoc */
   protected sendToWorker (
     workerNodeKey: number,