Merge pull request #134 from 85204/cy/fix_listener

fix(connect): remove listener after connect successfully
theophilusx · Aug 21, 2019 · 791c491 · 791c491
2 parents 58fd0f9 + fae1407
commit 791c491
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/index.js b/src/index.js
@@ -607,12 +607,17 @@ SftpClient.prototype.connect = function(config, connectMethod) {
     operation.attempt(function(number) {
       sftpObj.client[connectMethod]('ready', () => {
         sftpObj.client.sftp((err, sftp) => {
+          if (err) {
+            reject(new Error(`Failed to connect to server: ${err.message}`));
+          }
           sftpObj.client.removeListener('error', reject);
           sftpObj.client.removeListener('end', reject);
+          sftpObj.client.removeListener('ready', reject);
           sftpObj.sftp = sftp;
           resolve(sftp);
         });
       })
+
       .on('end', reject)
       .on('error', function () {
         operation.retry( new Error());