Fix reserved connection query handler (#683)

porsager · Oct 10, 2023 · ded413f · ded413f
1 parent e4b158b
commit ded413f
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 16 deletions.
diff --git a/cf/src/index.js b/cf/src/index.js
@@ -202,7 +202,7 @@ function Postgres(a, b) {
   }
 
   async function reserve() {
-    const q = Queue()
+    const queue = Queue()
     const c = open.length
       ? open.shift()
       : await new Promise(r => {
@@ -211,8 +211,8 @@ function Postgres(a, b) {
       })
 
     move(c, reserved)
-    c.reserved = () => q.length
-      ? c.execute(q.shift())
+    c.reserved = () => queue.length
+      ? c.execute(queue.shift())
       : move(c, reserved)
     c.reserved.release = true
 
@@ -226,7 +226,7 @@ function Postgres(a, b) {
 
     function handler(q) {
       c.queue === full
-        ? q.push(q)
+        ? queue.push(q)
         : c.execute(q) || move(c, full)
     }
   }

diff --git a/cjs/src/index.js b/cjs/src/index.js
@@ -201,7 +201,7 @@ function Postgres(a, b) {
   }
 
   async function reserve() {
-    const q = Queue()
+    const queue = Queue()
     const c = open.length
       ? open.shift()
       : await new Promise(r => {
@@ -210,8 +210,8 @@ function Postgres(a, b) {
       })
 
     move(c, reserved)
-    c.reserved = () => q.length
-      ? c.execute(q.shift())
+    c.reserved = () => queue.length
+      ? c.execute(queue.shift())
       : move(c, reserved)
     c.reserved.release = true
 
@@ -225,7 +225,7 @@ function Postgres(a, b) {
 
     function handler(q) {
       c.queue === full
-        ? q.push(q)
+        ? queue.push(q)
         : c.execute(q) || move(c, full)
     }
   }

diff --git a/deno/src/index.js b/deno/src/index.js
@@ -202,7 +202,7 @@ function Postgres(a, b) {
   }
 
   async function reserve() {
-    const q = Queue()
+    const queue = Queue()
     const c = open.length
       ? open.shift()
       : await new Promise(r => {
@@ -211,8 +211,8 @@ function Postgres(a, b) {
       })
 
     move(c, reserved)
-    c.reserved = () => q.length
-      ? c.execute(q.shift())
+    c.reserved = () => queue.length
+      ? c.execute(queue.shift())
       : move(c, reserved)
     c.reserved.release = true
 
@@ -226,7 +226,7 @@ function Postgres(a, b) {
 
     function handler(q) {
       c.queue === full
-        ? q.push(q)
+        ? queue.push(q)
         : c.execute(q) || move(c, full)
     }
   }

diff --git a/src/index.js b/src/index.js
@@ -201,7 +201,7 @@ function Postgres(a, b) {
   }
 
   async function reserve() {
-    const q = Queue()
+    const queue = Queue()
     const c = open.length
       ? open.shift()
       : await new Promise(r => {
@@ -210,8 +210,8 @@ function Postgres(a, b) {
       })
 
     move(c, reserved)
-    c.reserved = () => q.length
-      ? c.execute(q.shift())
+    c.reserved = () => queue.length
+      ? c.execute(queue.shift())
       : move(c, reserved)
     c.reserved.release = true
 
@@ -225,7 +225,7 @@ function Postgres(a, b) {
 
     function handler(q) {
       c.queue === full
-        ? q.push(q)
+        ? queue.push(q)
         : c.execute(q) || move(c, full)
     }
   }