sftp

plugins/di/di-sftp-filesync/perform.js

@@ -77,17 +77,17 @@ function perform_function(context,response){
 
     }).then((data) => {
     	if(data){
-    		data.on('data',(dat)=>{
-          var nb = Buffer.concat([buff_out,dat]);
+    
+          var nb = Buffer.concat([buff_out,data]);
           buff_out = nb;
-        })
-    		data.on('end',()=>{
+     
+    		
           sftp.end()
           memstore.setItem('lastmodify',last_mod,function(err){
             var result=(prm_encoding=='binary')?buff_out:buff_out.toString('utf8');
             response.success(result, {"meta":meta,"continue": fs_continue});
           });
-        });
+    
     	}else{
     		sftp.end();
     		response.reject();