ждать обещания в цикле - PullRequest
       0

ждать обещания в цикле

0 голосов
/ 16 января 2019

Я получил эту функцию:

const upload = (example) => {
    console.log('uploading...');
    return new Promise(function (resolve, reject) {
        resolve & reject
    });
};

Я вызываю функцию выше здесь:

const dirents = await fs.readdirSync(path, {withFileTypes:true});
await Promise.all(dirents.map(async (dirent) => {
    await upload(example).then((response) => {
        console.log('success');
    }, (err) => {
        console.log(err);
    });
});

Вывод должен быть

'uploading' -> 'success' -> 'uploading' ...

Но на самом деле это

'uploading' -> 'uploading' -> 'success' -> 'success'

Я тоже пытался (for ... of), но у меня это тоже не работает.

Ответы [ 3 ]

0 голосов
/ 16 января 2019

Для последовательных обещаний использование простого цикла в функции async очень понятно и читабельно:

let userIDs = [1, 2, 3];

async function uploadIDS(ids) {
  for (let id of ids) {
    let res = await upload(id)
    console.log("Success:", res)
  }
}

const upload = (example) => {
  console.log('uploading...');
  return new Promise(function(resolve, reject) {
    resolve(example)
  });
};

uploadIDS(userIDs)
0 голосов
/ 16 января 2019

** Вы можете сделать это также с функцией рекурсии **

 //const dirents = await fs.readdirSync(path, {withFileTypes:true});

    const dirents = [1,2,3]


    const upload = (example) => {
        console.log('uploading...');
        return new Promise(function (resolve, reject) {
            resolve(example)
        });
    };

    function callUpload(dirent, length, count) {

        if(count >= dirents.length){
            return;
        }
        upload(dirent).then(() => {
            count += 1;
            console.log("success")
            callUpload(dirents[count], dirents.length, count)
        })
    }
    callUpload(dirents[0], dirents.length, 0)
0 голосов
/ 16 января 2019

Вот современный пример использования reduce с async/ await (который вы можете запустить здесь )

let userIDs = [1,2,3];

userIDs.reduce( async (previousPromise, nextID) => {
  await previousPromise;
  return upload(nextID).then((val) => {
    console.log("success", val);
  })
}, Promise.resolve());


const upload = (id) => {
    console.log('uploading...', id);
    return new Promise(function (resolve, reject) {
        resolve(id);
    });
};
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...