emit 'close' and end stream on errors

grncdr · Dec 26, 2013 · 9614060 · 9614060
1 parent 152603b
commit 9614060
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/index.js b/index.js
@@ -68,3 +68,9 @@ PostgresQuery.prototype.handleReadyForQuery = function () {
   this.emit('close')
   QueryStream.prototype.handleReadyForQuery.call(this)
 }
+
+PostgresQuery.prototype.handleError = function (err) {
+  this.emit('close')
+  this.push(null)
+  QueryStream.prototype.handleError.call(this, err)
+}