Вложенные Promise.map() не возвращают никакого результата

Question

Я пытаюсь использовать обещания для выполнения цикла внутри цикла. Я хочу, чтобы внутренний цикл завершил свою итерацию, а затем внешняя петля должна итерации.

, например: -

arr1 = [1,2,3,4]; 
arr2 = [5,6,7,8]; 

loopOfArr1{ 
    loopOfArr2{ 
     //functionality 
    } 
} 

Я хочу, чтобы для каждого значения arr1, петля arr2 должны получить казнены. и это будет как синхронизация цикла, так и синхронизация.

Вот мой код, используя обещания: -

exports.getAtpagesWeights = function(atpagesDataArray,selectedTagsIds, taggings, callback){ 
    var atpageData, forHubCount; 
    return Promise.map(selectedTagsIds, function(tag, index, count){ 
     return Promise.map(taggings, function(tagging, index, count){ 
      return new Promise(function(resolve, reject){ 
       var atpageArray = _.filter(atpagesDataArray, function(item){ 
        if(tagging.taggable_id == item.id && tagging.tag_id == tag){ 
         item = item.toObject(); 
         item.rank_weight = tagging.atpages_weight; 
         resolve(item); 
        } 
       }) 
      }) 
     })  
    }).then(function(result){ 
     console.log(result); 
     callback(null, result); 
    }).catch(function(error){ 
     callback(error, null); 
    }) 
} 

Но когда я проверить журнал, ничего не печатается, может кто-нибудь сказать, где я буду неправильно, или есть лучший подход?

Answer 1

В меру моего понимания вашего кода, вы хотите что-то так просто, как это:

exports.getAtpagesWeights = function (atpagesData, selectedTagIds, taggings) { 
    var atpagesIndex = {}, 
     atpagesWeights = atpagesData.map(item => { 
      var weighted = item.toObject(); 
      weighted.rank_weight = null; 
      atpagesIndex[item.id] = weighted; 
      return weighted; 
     }); 

    taggings.filter(t => selectedTagIds.includes(t.id)).forEach(t => { 
     atpagesIndex[t.taggable_id].rank_weight = t.atpages_weight; 
    }); 

    return atpagesWeights; 
}; 

Это возвращает плоский массив объектов, непосредственно полученных из atpagesData элементов, с rank_weight добавляемые для выбранных.

Как правило, существуют асинхронные обратные вызовы продолжения для одной цели и одной цели: для работы с асинхронными операциями.

Обещания - это один уровень абстракции над продолжением. По сути, это обратные вызовы с обратным вызовом с удобной обработкой, но они по-прежнему являются обратными вызовами по своему ядру.

Если ваш код не имеет асинхронных путей (и ваш пример кода не похож на него), то вам не нужен параметр callback, и вам также не нужны никакие обещания. Будь проще.

Answer 2

1) Подробнее о методе _.filter, ваше использование не является неправильным

2) Последнее обещание не решить, а не отвергать, поэтому консоль печати ничего

3) вместо того, чтобы эта конструкция (если это не promisification)

return new Promise(function(resolve, reject){ 
    resolve(somthing) 
}) 

лучше использовать эту конструкцию

return Promise.resolve() 
    .then(function(){ 
     return somthing; 
    }) 

4) Я добавляю некоторую элегантность к вашему коду

exports.getAtpagesWeights = function(atpagesDataArray, selectedTagsIds, taggings, callback){ 
    var atpageData, forHubCount; 
    return Promise.map(selectedTagsIds, function(tag, index, count){ 
     return Promise.resolve() 
      .then(function() { 
       return Promise.filter(taggings, function(tagging) { 
        return tagging.tag_id === tag; 
       }) 
      }) 
      .then(function(taggings) { 
       return Promise.filter(atpagesDataArray, function(item) { 
        return _.chain(taggings) 
         .map('taggable_id') 
         .includes(item.id) 
         .value(); 
       }); 
      }) 
      .then(function(atpagesDataArray) { 
       return Promise.map(atpagesDataArray, function(item) { 
        item = item.toObject(); 
        item.rank_weight = _.chain(taggings) 
         .find({taggable_id: item.id}) 
         .get('atpages_weight') 
         .value(); 
        return item; 
       }); 

      }) 
      .value(); 
     })  
    }) 
    .then(function(result){ 
     console.log(result); 
     callback(null, result); 
    }) 
    .catch(function(error){ 
     callback(error, null); 
    }) 
}