diff --git a/lib/index.js b/lib/index.js index 4433c38..2c8209c 100644 --- a/lib/index.js +++ b/lib/index.js @@ -141,6 +141,22 @@ module.exports = function (Pouch) { }); }, callback); }); + + Pouch.allDbsEnsureClosed = utils.toPromise(function (callback) { + queue.add(function (callback) { + if (!pouch) return callback(); + + pouch.close().then(function () { + pouch = null; + cache = null; + callback(); + }).catch(/* istanbul ignore next */ function (err) { + pouch = null; + cache = null; + callback(); + }); + }, callback); + }); }; /* istanbul ignore next */