Don't dequeue queries unless a connection is available

porsager · porsager · commit 03df7c197c58 · 2019-12-09T17:37:35.000+01:00
diff --git a/lib/index.js b/lib/index.js
@@ -141,9 +141,8 @@ export default function Postgres(url, options) {
   }
 
   function next() {
-    let x
-    let c
-    while ((x = queries.shift()) && (c = getConnection(x.fn))) {
+    let c, x
+    while (queries.length && (c = getConnection(queries.peek().fn)) && (x = queries.shift())) {
       x.fn
         ? transaction(x, c)
         : send(c, x.query, x.xs, x.args)
diff --git a/lib/queue.js b/lib/queue.js
@@ -7,6 +7,7 @@ export default function Queue() {
       return xs.length - index
     },
     push: (x) => xs.push(x),
+    peek: (x) => xs[index],
     shift: () => {
       if (index === xs.length) {
         index = -1
