diff --git a/lib/client.js b/lib/client.js
index 490e1d18..7eab164b 100644
--- a/lib/client.js
+++ b/lib/client.js
@@ -175,7 +175,7 @@ Client.prototype.connect = function(callback) {
   con.once('end', function() {
     if(self.activeQuery) {
       var disconnectError = new Error('Stream unexpectedly ended during query execution');
-      self.activeQuery.handleError(disconnectError);
+      self.activeQuery.handleError(disconnectError, con);
       self.activeQuery = null;
     }
     self.emit('end');