Throw proper query error if destroyed

porsager · Mar 28, 2022 · e148a0a · e148a0a
1 parent b3ac644
commit e148a0a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/cjs/src/connection.js b/cjs/src/connection.js
@@ -145,7 +145,7 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
 
   function execute(q) {
     if (terminated)
-      return q.reject(Errors.connection('CONNECTION_DESTROYED', options))
+      return queryError(q, Errors.connection('CONNECTION_DESTROYED', options))
 
     if (q.cancelled)
       return

diff --git a/deno/src/connection.js b/deno/src/connection.js
@@ -148,7 +148,7 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
 
   function execute(q) {
     if (terminated)
-      return q.reject(Errors.connection('CONNECTION_DESTROYED', options))
+      return queryError(q, Errors.connection('CONNECTION_DESTROYED', options))
 
     if (q.cancelled)
       return

diff --git a/src/connection.js b/src/connection.js
@@ -145,7 +145,7 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
 
   function execute(q) {
     if (terminated)
-      return q.reject(Errors.connection('CONNECTION_DESTROYED', options))
+      return queryError(q, Errors.connection('CONNECTION_DESTROYED', options))
 
     if (q.cancelled)
       return