From edc0462470386957adf24d7c959e8143c19293ac Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Daniel=20Garc=C3=ADa=20Aubert?=
 <danielgarciaaubert@gmail.com>
Date: Fri, 24 May 2019 17:06:47 +0200
Subject: [PATCH] Do not detach streams before finishing

---
 copy-to.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/copy-to.js b/copy-to.js
index 557c55b..5b843d3 100644
--- a/copy-to.js
+++ b/copy-to.js
@@ -23,6 +23,7 @@ CopyStreamQuery.prototype.submit = function(connection) {
   connection.query(this.text)
   this.connection = connection
   this.connection.removeAllListeners('copyData')
+  this.on('end', () => this._detach())
   connection.stream.pipe(this)
 }
 
@@ -84,7 +85,6 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
       case code.ErrorResponse:
       case code.CopyDone:
         pushBufferIfneeded();
-        this._detach()
         this.push(null)
         return cb();
         break;