fix(stor): ensure rejection after destroy

2019-06-21 14:00:29 -06:00
parent 0d9131c370
commit 44999c714d
1 changed files with 7 additions and 4 deletions
--- a/src/commands/registration/stor.js
+++ b/src/commands/registration/stor.js
@@ -21,11 +21,14 @@ module.exports = {
      const serverPath = stream.path || fileName;

      const destroyConnection = (connection, reject) => (err) => {
-        if (connection) {
-          if (connection.writable) connection.end();
-          connection.destroy(err);
+        try {
+          if (connection) {
+            if (connection.writable) connection.end();
+            connection.destroy(err);
+          }
+        } finally {
+          reject(err);
        }
-        reject(err);
      };

      const streamPromise = new Promise((resolve, reject) => {