diff --git a/rpc.js b/rpc.js index dad806a5b..83d166e2e 100644 --- a/rpc.js +++ b/rpc.js @@ -369,15 +369,19 @@ var getDeletedPads = function (Env, channels, cb) { var sem = Saferphore.create(10); var absentees = []; + + var job = function (channel, wait) { + return function (give) { + getFileSize(Env, channel, wait(give(function (e, size) { + if (e) { return; } + if (size === 0) { absentees.push(channel); } + }))); + }; + }; + nThen(function (w) { for (var i = 0; i < L; i++) { - let channel = channels[i]; - sem.take(function (give) { - getFileSize(Env, channel, w(give(function (e, size) { - if (e) { return; } - if (size === 0) { absentees.push(channel); } - }))); - }); + sem.take(job(channels[i], w)); } }).nThen(function () { cb(void 0, absentees); diff --git a/storage/tasks.js b/storage/tasks.js index b25a3a637..85df70a8d 100644 --- a/storage/tasks.js +++ b/storage/tasks.js @@ -63,7 +63,7 @@ var write = function (env, task, cb) { return void cb(err); } })); - }).nThen(function (w) { + }).nThen(function () { // write the file to the path Fs.writeFile(mkPath(env, id), str, function (e) { if (e) { return void cb(e); }