pg-pool
Advanced tools
Comparing version 3.6.0 to 3.6.1
@@ -42,2 +42,7 @@ 'use strict' | ||
rej = reject | ||
}).catch(err => { | ||
// replace the stack trace that leads to `TCP.onStreamRead` with one that leads back to the | ||
// application that created the query | ||
Error.captureStackTrace(err); | ||
throw err; | ||
}) | ||
@@ -44,0 +49,0 @@ return { callback: cb, result: result } |
{ | ||
"name": "pg-pool", | ||
"version": "3.6.0", | ||
"version": "3.6.1", | ||
"description": "Connection pool for node-postgres", | ||
@@ -40,3 +40,3 @@ "main": "index.js", | ||
}, | ||
"gitHead": "ee302cbcf10437e34fd05d70fc003c357b14c654" | ||
"gitHead": "eaafac36dc8f4a13f1fecc9e3420d35559fd8e2b" | ||
} |
@@ -71,2 +71,3 @@ 'use strict' | ||
}) | ||
const promises = [] | ||
for (let i = 0; i < 10; i++) { | ||
@@ -77,8 +78,10 @@ pool.connect(function (err, client, release) { | ||
}) | ||
pool.query('SELECT now()') | ||
promises.push(pool.query('SELECT now()')) | ||
} | ||
setTimeout(function () { | ||
expect(releaseCount).to.be(20) | ||
pool.end(done) | ||
}, 100) | ||
Promise.all(promises).then(() => { | ||
pool.end(() => { | ||
expect(releaseCount).to.be(20) | ||
done() | ||
}) | ||
}) | ||
}) | ||
@@ -92,3 +95,2 @@ | ||
pool.once('release', function (err, errClient) { | ||
console.log(err, errClient) | ||
expect(err).to.equal(releaseError) | ||
@@ -95,0 +97,0 @@ expect(errClient).to.equal(client) |
69739
1663