diff --git a/lib/store.js b/lib/store.js
index 724ee2a..2c93335 100644
--- a/lib/store.js
+++ b/lib/store.js
@@ -83,12 +83,6 @@ class Store {
         return resolve({ offset: info.offset, upload: info });
       });
       ws.on('error', reject);
-      // End writeStream on connection abort and wait for drain
-      readStream.on('close', () => {
-        ws.on('drain', () => {
-          ws.end();
-        });
-      });
     });
 
     readStream.pipe(uploadSize).pipe(ws);