destroyAllNow also has a callback

Ricky Ng-Adam · Ricky Ng-Adam · commit 85c28e9088f4 · 2014-04-17T16:25:59.000+08:00
diff --git a/lib/index.js b/lib/index.js
@@ -25,11 +25,12 @@ PG.prototype.end = function() {
     var pool = self.pools.all[key];
     delete self.pools.all[key];
     pool.drain(function() {
-      pool.destroyAllNow();
-      count--;
-      if(count === 0) {
-        self.emit('ended');
-      }
+      pool.destroyAllNow(function() {
+        count--;
+        if(count === 0) {
+          self.emit('ended');
+        }        
+      });
     });
   });
 };
