Skip to content

Commit 55f5a9f

Browse files
committed
fix: from now _acquire return always a promise to avoid uncatchable exception
1 parent 48c9c1f commit 55f5a9f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/base/connection-pool.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -363,7 +363,7 @@ class ConnectionPool extends EventEmitter {
363363
*/
364364

365365
acquire (requester, callback) {
366-
const acquirePromise = shared.Promise.resolve(this._acquire().promise).catch(err => {
366+
const acquirePromise = shared.Promise.resolve(this._acquire()).catch(err => {
367367
this.emit('error', err)
368368
throw err
369369
})
@@ -382,7 +382,7 @@ class ConnectionPool extends EventEmitter {
382382
return shared.Promise.reject(new ConnectionError('Connection is closing', 'ENOTOPEN'))
383383
}
384384

385-
return this.pool.acquire()
385+
return this.pool.acquire().promise
386386
}
387387

388388
/**

0 commit comments

Comments
 (0)