节点 JS 承诺。所有和为每个

我有一个类似数组的结构，它公开异步方法。异步方法调用返回数组结构，从而公开更多的异步方法。我正在创建另一个 JSON 对象来存储从这个结构中获得的值，因此需要注意跟踪回调中的引用。

我已经编写了一个蛮力解决方案，但我想学习一个更惯用或干净的解决方案。

  1. 对于 n 个嵌套级别，模式应该是可重复的。
  2. 我需要使用 nome.all 或者类似的技术来决定什么时候解决封闭例程。
  3. 并非每个元素都必然涉及异步调用。因此，在嵌套的 nose.all 中，我不能简单地根据索引对 JSON 数组元素进行赋值。尽管如此，我确实需要使用一些内嵌的 forEach 来确保在解决附加例程之前已经完成了所有的财产分配。
  4. 我使用的是蓝鸟承诺自由，但这不是一个必要条件

这里有一些部分代码-

var jsonItems = [];


items.forEach(function(item){


var jsonItem = {};
jsonItem.name = item.name;
item.getThings().then(function(things){
// or Promise.all(allItemGetThingCalls, function(things){


things.forEach(function(thing, index){


jsonItems[index].thingName = thing.name;
if(thing.type === 'file'){


thing.getFile().then(function(file){ //or promise.all?


jsonItems[index].filesize = file.getSize();
284198 次浏览
小开
最佳答案

有一些简单的规则:

  • 无论何时你在 then中创建一个承诺，返回它 ——任何你没有返回的承诺都不会在外面等待。
  • 每当您创建多个承诺时，.all them -这样它就会等待所有的承诺，并且不会消除其中任何一个承诺的错误。
  • 每当您嵌套 then时，您通常可以返回中间的 -then链通常最多有1级深度。
  • 无论何时执行 IO，它都应该带有一个项目 ——要么它应该在一个项目中，要么它应该使用一个项目来表示它的完成。

还有一些小贴士:

  • 与使用 for/push 相比，使用 .map进行映射更好——如果您使用函数映射值，那么使用 map可以简洁地表达逐个应用操作并聚合结果的概念。
  • 如果并发执行是免费的 ，那么并发执行比顺序执行更好——并发执行并等待它们比一个接一个执行更好——每个执行之前都等待下一个执行。

好了，我们开始吧:

var items = [1, 2, 3, 4, 5];
var fn = function asyncMultiplyBy2(v){ // sample async action
return new Promise(resolve => setTimeout(() => resolve(v * 2), 100));
};
// map over forEach since it returns


var actions = items.map(fn); // run the function over all items


// we now have a promises array and we want to wait for it


var results = Promise.all(actions); // pass array of promises


results.then(data => // or just .then(console.log)
console.log(data) // [2, 4, 6, 8, 10]
);


// we can nest this of course, as I said, `then` chains:


var res2 = Promise.all([1, 2, 3, 4, 5].map(fn)).then(
data => Promise.all(data.map(fn))
).then(function(data){
// the next `then` is executed after the promise has returned from the previous
// `then` fulfilled, in this case it's an aggregate promise because of
// the `.all`
return Promise.all(data.map(fn));
}).then(function(data){
// just for good measure
return Promise.all(data.map(fn));
});


// now to get the results:


res2.then(function(data){
console.log(data); // [16, 32, 48, 64, 80]
});
小开

下面是一个使用 reduce 的简单示例。

/**
*
* @param items An array of items.
* @param fn A function that accepts an item from the array and returns a promise.
* @returns {Promise}
*/
function forEachPromise(items, fn) {
return items.reduce(function (promise, item) {
return promise.then(function () {
return fn(item);
});
}, Promise.resolve());
}

像这样使用它:

var items = ['a', 'b', 'c'];


function logItem(item) {
return new Promise((resolve, reject) => {
process.nextTick(() => {
console.log(item);
resolve();
})
});
}


forEachPromise(items, logItem).then(() => {
console.log('done');
});

我们发现将可选上下文发送到循环中是有用的。上下文是可选的，并由所有迭代共享。

function forEachPromise(items, fn, context) {
return items.reduce(function (promise, item) {
return promise.then(function () {
return fn(item, context);
});
}, Promise.resolve());
}

你的承诺函数应该是这样的:

function logItem(item, context) {
return new Promise((resolve, reject) => {
process.nextTick(() => {
console.log(item);
context.itemCount++;
resolve();
})
});
}
小开

我也经历过同样的情况，我用两个承诺解决了。

我认为这是一个很好的解决方案，所以我把它发表在 npm: https://www.npmjs.com/package/promise-foreach上

我觉得你的代码应该是这样的

var promiseForeach = require('promise-foreach')
var jsonItems = [];
promiseForeach.each(jsonItems,
[function (jsonItems){
return new Promise(function(resolve, reject){
if(jsonItems.type === 'file'){
jsonItems.getFile().then(function(file){ //or promise.all?
resolve(file.getSize())
})
}
})
}],
function (result, current) {
return {
type: current.type,
size: jsonItems.result[0]
}
},
function (err, newList) {
if (err) {
console.error(err)
return;
}
console.log('new jsonItems : ', newList)
})
小开

为了增加解决方案，在我的例子中，我想从 Firebase 获取产品列表的多个数据。我是这样做的:

useEffect(() => {
const fn = p => firebase.firestore().doc(`products/${p.id}`).get();
const actions = data.occasion.products.map(fn);
const results = Promise.all(actions);
results.then(data => {
const newProducts = [];
data.forEach(p => {
newProducts.push({ id: p.id, ...p.data() });
});
setProducts(newProducts);
});
}, [data]);

提交答案