diff --git a/src/subscribe.js b/src/subscribe.js
index 95a92ad7..7a70842e 100644
--- 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)