Fix streaming errors

dengelke · Oct 22, 2017 · 52c6b1b · 52c6b1b
1 parent d6cd34e
commit 52c6b1b
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/read-stream.js b/lib/read-stream.js
@@ -65,9 +65,11 @@ stream._read = function () {
 
 stream.destroy = function () {
   var state = this._zoomState;
-  state.destroyed = true;
-  delete this._zoomState;
-  this.emit('close');
+  if (state && !state.destroyed) {
+    state.destroyed = true;
+    delete this._zoomState;
+    this.emit('close');
+  }
 };
 
 stream._getResultset = function () {