给定以下代码:
var arr = [1,2,3,4,5];
var results: number[] = await arr.map(async (item): Promise<number> => {
await callAsynchronousOperation(item);
return item + 1;
});
这会产生以下错误:
TS2322:类型“Promise
我该如何解决?如何让 async await
和 Array.map
一起工作?
arr.map()
是同步的,不返回承诺。
map
)并期望它能够工作。
async
时,都会使该函数返回一个 Promise。所以当然,async 的映射会返回一组 promise :)
这里的问题是您试图 await
一组承诺而不是承诺。这不符合您的预期。
当传递给 await
的对象不是 Promise 时,await
会立即按原样返回值,而不是尝试解析它。因此,由于您在此处传递 await
一个(Promise 对象的)数组而不是 Promise,await 返回的值就是该数组,它的类型为 Promise<number>[]
。
您可能想要做的是在 map
返回的数组上调用 Promise.all
,以便在 await
之前将其转换为单个 Promise。
Promise.all(iterable) 方法返回一个当可迭代参数中的所有承诺都已解决时解决的承诺,或者以第一个被拒绝的承诺的原因拒绝。
所以在你的情况下:
var arr = [1, 2, 3, 4, 5];
var results: number[] = await Promise.all(arr.map(async (item): Promise<number> => {
await callAsynchronousOperation(item);
return item + 1;
}));
这将解决您在此处遇到的特定错误。
根据您要执行的具体操作,您也可以考虑使用 Promise.allSettled
、Promise.any
或 Promise.race
而不是 Promise.all
,但在大多数情况下(几乎肯定包括这个)Promise.all
会成为你想要的那个。
下面的解决方案可以一起正确使用 async await 和 Array.map。并行、异步处理数组的所有元素并保留顺序:
const arr = [1, 2, 3, 4, 5, 6, 7, 8];
const randomDelay = () => new Promise(resolve => setTimeout(resolve, Math.random() * 1000));
const calc = async n => {
await randomDelay();
return n * 2;
};
const asyncFunc = async () => {
const unresolvedPromises = arr.map(n => calc(n));
const results = await Promise.all(unresolvedPromises);
};
asyncFunc();
还有codepen。
请注意,我们只“等待” Promise.all。我们多次调用 calc 而没有“等待”,我们会立即收集一系列未解决的 Promise。然后 Promise.all 等待所有它们的解析并按顺序返回一个包含解析值的数组。
如果您使用的不是原生 Promises 而是 Bluebird,还有另一种解决方案。
您也可以尝试使用 Promise.map(),混合使用 array.map 和 Promise.all
在你的情况下:
var arr = [1,2,3,4,5];
var results: number[] = await Promise.map(arr, async (item): Promise<number> => {
await callAsynchronousOperation(item);
return item + 1;
});
Promise.mapSeries
或 Promise.each
是顺序的,Promise.map
一次启动它们。
concurrency
选项并行运行所有或部分操作。
这是最简单的方法。
await Promise.all(
arr.map(async (element) => {
....
})
)
您可以使用:
for await (let resolvedPromise of arrayOfPromises) {
console.log(resolvedPromise)
}
https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Statements/for-await...of
如果您想改用 Promise.all()
,您可以选择 Promise.allSettled()
,这样您就可以更好地控制被拒绝的承诺。
https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise/allSettled
我建议使用上面提到的 Promise.all,但如果你真的想避免这种方法,你可以做一个 for 或任何其他循环:
const arr = [1,2,3,4,5];
let resultingArr = [];
for (let i in arr){
await callAsynchronousOperation(i);
resultingArr.push(i + 1)
}
仅供参考:如果您想迭代数组的项目,而不是索引(@ralfoide 的评论),请在 let i in arr
语句中使用 of
而不是 in
。
使用 modern-async's map() 的解决方案:
import { map } from 'modern-async'
...
const result = await map(myArray, async (v) => {
...
})
使用该库的优点是您可以使用 mapLimit() 或 mapSeries() 控制并发。
我在 BE 方面有一项任务,即从 repo 中查找所有实体,并添加一个新的属性 url 并返回到控制器层。这就是我实现它的方式(感谢 Ajedi32 的回应):
async findAll(): Promise<ImageResponse[]> {
const images = await this.imageRepository.find(); // This is an array of type Image (DB entity)
const host = this.request.get('host');
const mappedImages = await Promise.all(images.map(image => ({...image, url: `http://${host}/images/${image.id}`}))); // This is an array of type Object
return plainToClass(ImageResponse, mappedImages); // Result is an array of type ImageResponse
}
注意:图像(实体)没有属性 url,但 ImageResponse - 有
这可能会帮助某人。
const APISimulator = (v) => new Promise((resolve, reject) => {
setTimeout(() => {
resolve({ data: v });
}, v * 100);
});
const arr = [7, 6, 5, 1, 2, 3];
const res = () => arr.reduce(async (memo, v, i) => {
const results = await memo;
console.log(`proccessing item-${i + 1} :`, v)
await APISimulator(v);
console.log(`completed proccessing-${i + 1} :`, v)
return [...results, v];
}, []);
res().then(proccessed => console.log(proccessed))
:
冒号是什么意思?callAsynchronousOperation(item);
和不使用await
有什么区别?await
函数将等待异步操作完成(或失败)然后继续,否则它将立即继续而不等待。