Remove infinite decrement

porsager · porsager · commit e8a51a584390 · 2019-12-27T12:39:38.000+01:00
diff --git a/lib/index.js b/lib/index.js
@@ -39,13 +39,8 @@ module.exports = Postgres
 function Postgres(url, options) {
   options = parseOptions(url, options)
 
-  let ready = false
-    , ended = null
-    , arrayTypesPromise
-    , max = Math.max(1, options.max)
-    , listener
-
-  const connections = Queue()
+  const max = Math.max(1, options.max)
+      , connections = Queue()
       , all = []
       , queries = Queue()
       , listeners = {}
@@ -54,6 +49,12 @@ function Postgres(url, options) {
       , isInsert = /(^|[^)(])\s*insert\s+into\s+[^\s]+\s*$/i
       , isSelect = /(^|[^)(])\s*select\s*$/i
 
+  let ready = false
+    , ended = null
+    , arrayTypesPromise
+    , slots = max
+    , listener
+
   function postgres(xs) {
     return query({}, getConnection(), xs, Array.from(arguments).slice(1))
   }
@@ -186,12 +187,13 @@ function Postgres(url, options) {
   }
 
   function getConnection(reserve) {
-    const connection = --max >= 0 ? createConnection(options) : connections.shift()
+    const connection = slots ? createConnection(options) : connections.shift()
     !reserve && connection && connections.push(connection)
     return connection
   }
 
   function createConnection(options) {
+    slots--
     const connection = Connection(options)
     all.push(connection)
     return connection
