Comparing version 1.7.1 to 1.8.0
@@ -93,3 +93,3 @@ var genericPool = require('generic-pool') | ||
e.client = client | ||
this.emit('error', e) | ||
this.emit('error', e, client) | ||
}.bind(this)) | ||
@@ -100,3 +100,3 @@ | ||
this.log('client connection error:', err) | ||
cb(err) | ||
cb(err, null) | ||
} else { | ||
@@ -103,0 +103,0 @@ this.log('client connected') |
{ | ||
"name": "pg-pool", | ||
"version": "1.7.1", | ||
"version": "1.8.0", | ||
"description": "Connection pool for node-postgres", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -63,2 +63,18 @@ var expect = require('expect.js') | ||
}) | ||
it('emits error and client if an idle client in the pool hits an error', function (done) { | ||
var pool = new Pool() | ||
pool.connect(function (err, client) { | ||
expect(err).to.equal(null) | ||
client.release() | ||
setImmediate(function () { | ||
client.emit('error', new Error('problem')) | ||
}) | ||
pool.once('error', function (err, errClient) { | ||
expect(err.message).to.equal('problem') | ||
expect(errClient).to.equal(client) | ||
done() | ||
}) | ||
}) | ||
}) | ||
}) | ||
@@ -65,0 +81,0 @@ |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
29341
12
488