Mark connection as closed immediately on terminate

porsager · porsager · commit fc1fac50d7b8 · 2022-03-21T20:55:26.000+01:00
diff --git a/cjs/src/connection.js b/cjs/src/connection.js
@@ -400,6 +400,7 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
     if (stream || query || initial || sent.length)
       error(Errors.connection('CONNECTION_DESTROYED', options))
 
+    onclose(connection)
     clearImmediate(nextWriteTimer)
     socket.removeListener('data', data)
     socket.removeListener('connect', connected)
diff --git a/deno/src/connection.js b/deno/src/connection.js
@@ -403,6 +403,7 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
     if (stream || query || initial || sent.length)
       error(Errors.connection('CONNECTION_DESTROYED', options))
 
+    onclose(connection)
     clearImmediate(nextWriteTimer)
     socket.removeListener('data', data)
     socket.removeListener('connect', connected)
diff --git a/src/connection.js b/src/connection.js
@@ -400,6 +400,7 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
     if (stream || query || initial || sent.length)
       error(Errors.connection('CONNECTION_DESTROYED', options))
 
+    onclose(connection)
     clearImmediate(nextWriteTimer)
     socket.removeListener('data', data)
     socket.removeListener('connect', connected)
