Fix stuck queries on non busy connections

porsager · porsager · commit 76c13f2f2f5a · 2025-05-20T17:09:49.000-06:00
diff --git a/src/connection.js b/src/connection.js
@@ -293,7 +293,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
     if (incomings) {
       incomings.push(x)
       remaining -= x.length
-      if (remaining >= 0)
+      if (remaining > 0)
         return
     }
 

Original file line number	Diff line number	Diff line change
`@@ -293,7 +293,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`293`	`293`	`if (incomings) {`
`294`	`294`	`incomings.push(x)`
`295`	`295`	`remaining -= x.length`
`296`		`- if (remaining >= 0)`
	`296`	`+ if (remaining > 0)`
`297`	`297`	`return`
`298`	`298`	`}`
`299`	`299`