Fix subscribe stream close

porsager · Sep 30, 2022 · 19c9684 · 19c9684
1 parent 57246a3
commit 19c9684
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/cjs/src/subscribe.js b/cjs/src/subscribe.js
@@ -36,12 +36,12 @@ module.exports = Subscribe;function Subscribe(postgres, options) {
 
   sql.end = async() => {
     ended = true
-    stream && (await new Promise(r => (stream.once('end', r), stream.end())))
+    stream && (await new Promise(r => (stream.once('close', r), stream.end())))
     return end()
   }
 
   sql.close = async() => {
-    stream && (await new Promise(r => (stream.once('end', r), stream.end())))
+    stream && (await new Promise(r => (stream.once('close', r), stream.end())))
     return close()
   }
 

diff --git a/deno/src/subscribe.js b/deno/src/subscribe.js
@@ -37,12 +37,12 @@ export default function Subscribe(postgres, options) {
 
   sql.end = async() => {
     ended = true
-    stream && (await new Promise(r => (stream.once('end', r), stream.end())))
+    stream && (await new Promise(r => (stream.once('close', r), stream.end())))
     return end()
   }
 
   sql.close = async() => {
-    stream && (await new Promise(r => (stream.once('end', r), stream.end())))
+    stream && (await new Promise(r => (stream.once('close', r), stream.end())))
     return close()
   }
 

diff --git a/src/subscribe.js b/src/subscribe.js
@@ -36,12 +36,12 @@ export default function Subscribe(postgres, options) {
 
   sql.end = async() => {
     ended = true
-    stream && (await new Promise(r => (stream.once('end', r), stream.end())))
+    stream && (await new Promise(r => (stream.once('close', r), stream.end())))
     return end()
   }
 
   sql.close = async() => {
-    stream && (await new Promise(r => (stream.once('end', r), stream.end())))
+    stream && (await new Promise(r => (stream.once('close', r), stream.end())))
     return close()
   }