From: Jérôme Benoit <jerome.benoit@piment-noir.org>
Date: Sun, 8 Oct 2023 17:27:16 +0000 (+0200)
Subject: refactor: close message channel last on error
X-Git-Tag: v3.0.1~23
X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;ds=sidebyside;h=cce7d65715a3c63234581b6f0f674b26057ddc5e;p=poolifier.git

refactor: close message channel last on error

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
---

diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts
index 628ad32f..08a955a9 100644
--- a/src/pools/abstract-pool.ts
+++ b/src/pools/abstract-pool.ts
@@ -1213,8 +1213,8 @@ export abstract class AbstractPool<
       const workerNodeKey = this.getWorkerNodeKeyByWorker(worker)
       const workerInfo = this.getWorkerInfo(workerNodeKey)
       workerInfo.ready = false
-      this.workerNodes[workerNodeKey].closeChannel()
       this.emitter?.emit(PoolEvents.error, error)
+      this.workerNodes[workerNodeKey].closeChannel()
       if (
         this.started &&
         !this.starting &&