Don't crash on errors in logical streaming, but log and reconnect

porsager · Jun 2, 2023 · a4bf5fa · a4bf5fa
1 parent 087c414
commit a4bf5fa
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/subscribe.js b/src/subscribe.js
@@ -97,11 +97,15 @@ export default function Subscribe(postgres, options) {
     }
 
     stream.on('data', data)
-    stream.on('error', sql.close)
+    stream.on('error', error)
     stream.on('close', sql.close)
 
     return { stream, state: xs.state }
 
+    function error(e) {
+      console.error('Unexpected error during logical streaming - reconnecting', e)
+    }
+
     function data(x) {
       if (x[0] === 0x77)
         parse(x.subarray(25), state, sql.options.parsers, handle, options.transform)