Как после выполнения forEach вызывать callback?

Question

[Миша Коган]

Как после выполнения forEach вызывать callback?

То есть я прошел весь массив и после выполнил определенное действие, а то у меня выходит, что код начинает выполнятся дальше, а мне нужно синхронное выполнение.

items.forEach(function(item) {
                    var newItem = new Item();
                    newItem.name = item.name;
                    newItem.icon_url =  item.icon_url;
                    newItem.icon_url_large =  item.icon_url_large;
                    newItem.type =  item.type;    
                                
                    community.getMarketItem(item.appid, item.market_hash_name, function(err, item) {
                        if(err) throw err;
                        newItem.lowestPrice = item.lowestPrice;
                        logger.info('Get price');
                        newItem.save(function(err) {
                            if(err) throw err;
                            logger.info(' New Item saved!');
                        });
                    });

                    newBet.item.push(newItem);
                });
                // нужно чтобы этот код выполнялся после цикла 
                newBet.save(function(err) {
                    if(err) throw err;
                    logger.info(' New Bet saved!');
                });

Comments

[Super User]

Код в студию.

Answer 1

[Александр Прозоров]

Для этих целей используйте библиотеку async. В частности async.each(arr, iterator, [callback]).

Comments

[Миша Коган]

Спасибо, как раз сам до этого только что дошел.

[Александр Прозоров]

Миша Коган: в дополнение хочу посоветовать метод aync.auto() для разматывания вложенной последовательно-параллельной лапши с зависимостями. Серебряная пуля - не иначе.

[Степан]

Александр Прозоров как в async.serials передать массив функций? Я преобразую свои функции, что бы они возвращали сами сбея и затем передаю этот массив этих функций в serial но это не работает! Может подскажите совета?

[Александр Прозоров]

xoma2: может оформите это отдельным вопросом? В комментариях не удобно приводить пример кода.

[Степан]

Александр Прозоров Как в async.serials передать массив функций?

Answer 2

[Миша Коган]

Вот рабочий код, если кому нужно будет.
 async.each(items, function(item, callback){
                    var newItem = new Item();
                    newItem.name = item.name;
                    newItem.icon_url =  item.icon_url;
                    newItem.icon_url_large =  item.icon_url_large;
                    newItem.type =  item.type;    
                                
                    community.getMarketItem(item.appid, item.market_hash_name, function(err, item) {
                        if(err) throw err;
                        newItem.lowestPrice = item.lowestPrice;
                        logger.info('Get price');

                        newItem.save(function(err) {
                            if(err) throw err;
                            logger.info(' New Item saved!');
                            newBet.item.push(newItem);
                            callback();
                        });
                    });
                }, function(err) {
                    newBet.save(function(err) {
                        if(err) throw err;
                        logger.info(' New Bet saved!');
                    });
                });

Answer 3

[Дмитрий Кравченко]

forEach cинхронен

[1,2,3].forEach(function(item){
  console.log(item)
});
console.log(4)
//1 2 3 4

update:
Ты используешь в цикле асинхронные функции. Можно заменить forEach на map, собрать массив промисов и написать что-то типа Promise.all(promises).then(function(){/*код далее*/});

Comments

[Миша Коган]

Просто дальше идет код, который должен быть вызван только после завершения forEach, а он выполняется раньше.

[Дмитрий Кравченко]

Скопируй мой пример в консоль и увидишь, что 4 появится в самом конце. Покажи код.

[Миша Коган]

Добавил код.

Answer 4

[Ivan Zmerzlyi]

var resultHolder = document.querySelector('#result');
var result = '';

[1,2,3,4,5].forEach(function(item, index, arr) {
	result += index + ':' + item + '<br>';
    if(index === arr.length-1) 
        resultHolder.innerHTML = result;
});

Пример тут

Comments

[Александр Прозоров]

В вашем примере синхронный код. У спрашивающего асинхронный вызов community.getMarketItem() в каждой итерации. И вопрос был в том как получить callback после того как все итерации отработают. Возможно вы не поняли вопроса.

[Ivan Zmerzlyi]

Вы правы, не до конца вопрос осмыслил.