commit
cb1fa32e64
|
@ -76,12 +76,12 @@ function createPool(options) {
|
||||||
return callback(err);
|
return callback(err);
|
||||||
|
|
||||||
res.on('error', function (e) {
|
res.on('error', function (e) {
|
||||||
removeAllListeners('end');
|
client.removeAllListeners('end');
|
||||||
callback(e);
|
callback(e);
|
||||||
});
|
});
|
||||||
|
|
||||||
res.on('end', function () {
|
res.on('end', function () {
|
||||||
removeAllListeners('error');
|
client.removeAllListeners('error');
|
||||||
callback(null);
|
callback(null);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
Loading…
Reference in New Issue