0

Всем привет. Задача такая:

Есть массив ссылок на файлы на удаленном сервере, нужно их асинхронно загрузить сложить в архив и отдать клиенту.

Все выше перечисленное удалось сделать за исключением одного, самого важного - сделать это асинхронно

код:

async function download(files) {
fs.mkdirSync(cat); //создаю каталог

var length = Object.keys(files).length; //длина входного объекта

for (var i = 0; length > i; i++) { // бегу циклом по объекту
    if (i > 10 && i < 15) { // чтобы сразу не качать 1000 файлов
        try {
            res = await save(files[i]); // вот тут то и вся загвоздка, дожидаюсь пока не сохранится один файл чтобы перейти к другому
        } catch(e) {
            console.log(e);
        }
    }
}

fse.remove(cat, err => { // удаляю каталог с файлами (зачем они мне)
    if (err) return console.error(err)

    console.log(cat + 'was removed!')
})

return archiveName; // возвращаю клиенту название архива для скачивания

}

async function save(file) {
return new Promise(resolve => {
    var title = file.title.replace(/[^a-zA-Z ]/g, "") + '.mp3'
      , link  = file.link
      ;

    thenRequest('GET', link) // отправяю запрос удаленному серверу чтобы получить файл
        .done(function(res) {
            //console.log(res.getBody());

            fs.writeFile(cat + title, res.getBody(), (err) => { //создаю файл
            if (err) throw err;
                console.log("The file" + title + " was succesfully saved!");

                zip.zipFolder(cat, function() { //добавляю файл в афхив
                    zip.writeToFile(archiveName + '.zip');
                })

                resolve();
            });


        })
});

}

Пытался копать в сторону async.parallel но безуспешно, не могу понять как создать массив с одинаковыми функциями но разными параметрами.

Помогите люди добрые, скоро сойду с ума))

4
  • 1
    Можно же попробовать await Promise.all(), т.е. когда все все промисы в Promise.all выполнятся, тогда отдавать ответ пользователю. По-моему где-то я читал что так достигается параллельное выполнение async/await. Да, тут 9 ноя 2017 в 13:42
  • а как собрать массив промисов? 9 ноя 2017 в 14:07
  • ну через map можно, как в статье, на которую я дал ссылку. 9 ноя 2017 в 14:19
  • а вообще у вас же есть функция save, которая возвращает промис. Немного поправить код, чтобы в цикле формировался массив из вызовов функции save. И передать его в promise.all. 9 ноя 2017 в 14:23

1 ответ 1

0

function newPromise( n ) {
  return new Promise( ( resolve, reject ) => {
    setTimeout( () => {
      console.log( `Прошло ${ n } секунд` );
      resolve();
    }, n*1000);
  } )
}

async function parallel() {
  let callArr = [];
  
  for( let i = 1; i <= 5; i++ ) {
    callArr.push ( newPromise( i ) );
  }
  
  await Promise.all( callArr );
  console.log( 'Всё' )
  
}

parallel();

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.