Как вызывать несколько одинаковых промисов синхронно подряд до выполнения условия внутри промиса?

Question

[Oleg Ulyanov]

Есть обращение к стороннему api, к примеру, шлю GET api/?name=bla-bal&last_id=
В ответ получаю массив объектов [{id: <идентификатор элемента>}, ..., {id: <идентификатор элемента>}]. Количество элементов произвольно в каждом ответе.
Первый вызов идет без last_id, последующие с id последнего элемента последней выборки.
Идет подсчет кол-ва полученных объектов и как только получено нужное кол-во остановить обращения к api.
Как это сделать?

Answer 1

[Дмитрий Беляев]

//Ваша функция запроса, я же просто посчитаю рандомы для примера
//Значение аргумента по умолчанию подставил для 1-ого случая, у Вас же может быть проверка
function someAsync(cur = 1){
  return Promise.resolve(cur * Math.random());
}

//Функция раннер, которая будет асинхронно-рекурсивно перевызываться
function run(next){
  return someAsync(next).then(result => {
    if(result < 0.1) { //Некое условие, что последний результат получен
      return result;
    }
    return run(result); //Перезапуск
  });
}

run().then(result => console.log('Последний результат:', result));

Answer 2

[Виталий]

1 - async await (node 7 --harmony или babel)

async function go(){
    let p1 = await promise1(...);
    let p2 = await promise2(p1);
    let p3 = await promise3(p2);
    return p3;
}
go().then(response=>{
    console.log(response); // <= p3
}).catch(console.error);

2. Можно использовать модуль vo (там есть режим последовательной отработки промисов, менее удобно.
3. Писать нечто такое:

promise1
    .then(response1=>{
        return promise2(response1);
    })
     .then(response2=>{
        return promise3(response2);
    })
     .then(response3=>{
        console.log(response3) // <=ваш результат
    })
    .catch(console.error);

Естественно все функции promise1, promise2, promise3 это такого рода функции:

const promise =  (params) => new Promise((resolve, reject) => { ..... какой - то код });

Comments

[Oleg Ulyanov]

Увы, но кол-во промисов у меня не определено. Т.е будет ли следующий или нет - решает значение выполнения текущего промиса.

[Виталий]

Oleg Ulyanov: тогда надо событийную модель строить,
число промисов же в любом случае лимитировано, а значит реакция на каждый промис может быть оценена, а дальше берете редукс и через состояния управляете цепочками промисов. В вашем случае делаете объект состояний, в подписки запихиваете промисы которые должны реагировать на вашу работу, и диспетчите в then всех промисов состояние и требование что с ним делать дальше. Условно говоря у вас есть стартовый промис, который в тхен изменяет состояние, тот промис, что попал под задачу получает из подписки информацию и продолжает цепочку. Если лень мараться с редуксом, можно тоже самое построить через EventEmmiter