ftp-reader
Advanced tools
Comparing version 0.0.5 to 0.0.6
@@ -22,6 +22,6 @@ "use strict"; | ||
} | ||
function processFile(sftpClient, fileGroup, processor) { | ||
function processFile(sftpClient, processor, fileGroup) { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
try { | ||
processor(sftpClient, fileGroup); | ||
yield processor(sftpClient, fileGroup); | ||
} | ||
@@ -38,3 +38,3 @@ catch (error) { | ||
const fileGroupsList = yield getSftpFiles(sftpClient, ftpBasePath, filter, grouper, sorter); | ||
yield bluebird_1.each(fileGroupsList, processFile.bind(null, processor)); | ||
yield bluebird_1.each(fileGroupsList, processFile.bind(null, sftpClient, processor)); | ||
sftpClient.end(); | ||
@@ -41,0 +41,0 @@ logger_1.removeLogger(); |
{ | ||
"name": "ftp-reader", | ||
"version": "0.0.5", | ||
"version": "0.0.6", | ||
"description": "Used to process files from s/ftp servers", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
Sorry, the diff of this file is not supported yet
20915