diff --git a/copy-to.js b/copy-to.js
index 4fd02ce..3ead141 100644
--- a/copy-to.js
+++ b/copy-to.js
@@ -15,7 +15,7 @@ var CopyStreamQuery = function(text) {
 
 util.inherits(CopyStreamQuery, Transform)
 
-var eventTypes = ['close', 'data', 'end']
+var eventTypes = ['close', 'data', 'end', 'error']
 
 CopyStreamQuery.prototype.submit = function(connection) {
   connection.query(this.text)
diff --git a/test/copy-to.js b/test/copy-to.js
index adae358..8e91be7 100644
--- a/test/copy-to.js
+++ b/test/copy-to.js
@@ -49,9 +49,10 @@ var testLeak = function(rounds) {
 
   async.timesSeries(rounds, runStream, function(err) {
     assert.equal(err, null)
+    assert.equal(fromClient.connection.stream.listeners('close').length, 0)
     assert.equal(fromClient.connection.stream.listeners('data').length, 1)
     assert.equal(fromClient.connection.stream.listeners('end').length, 2)
-    assert.equal(fromClient.connection.stream.listeners('close').length, 0)
+    assert.equal(fromClient.connection.stream.listeners('error').length, 1)
     fromClient.end()
   })
 }