diff --git a/index.js b/index.js
index b29eab0c..fcc61d67 100644
--- a/index.js
+++ b/index.js
@@ -98,6 +98,7 @@ QueryStream.prototype.handleCommandComplete = function(msg) {
 }
 
 QueryStream.prototype.handleReadyForQuery = function() {
+  this.emit('close')
   this.push(null)
 }