From 55f5a9fc84534decb2cdd7bdd5268450cab9f482 Mon Sep 17 00:00:00 2001 From: bombjackit <94737161+bombjackit@users.noreply.github.com> Date: Fri, 22 Dec 2023 08:47:36 +0100 Subject: [PATCH] fix: from now _acquire return always a promise to avoid uncatchable exception --- lib/base/connection-pool.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/base/connection-pool.js b/lib/base/connection-pool.js index 83daa82c..6888aa25 100644 --- a/lib/base/connection-pool.js +++ b/lib/base/connection-pool.js @@ -363,7 +363,7 @@ class ConnectionPool extends EventEmitter { */ acquire (requester, callback) { - const acquirePromise = shared.Promise.resolve(this._acquire().promise).catch(err => { + const acquirePromise = shared.Promise.resolve(this._acquire()).catch(err => { this.emit('error', err) throw err }) @@ -382,7 +382,7 @@ class ConnectionPool extends EventEmitter { return shared.Promise.reject(new ConnectionError('Connection is closing', 'ENOTOPEN')) } - return this.pool.acquire() + return this.pool.acquire().promise } /**