diff --git a/index.js b/index.js index aec3a1e..abc09dc 100644 --- a/index.js +++ b/index.js @@ -50,6 +50,10 @@ var Pool = module.exports = function (options, Client) { util.inherits(Pool, EventEmitter) +Pool.prototype.isDestroyed = function () { + return this.pool._draining +} + Pool.prototype._promise = function (cb, executor) { if (!cb) { return new this.Promise(executor)