有很多回调时如何在异步函数中正确返回值

Question

我有一个异步函数，它调用其他异步函数，当它们都完成后，我将返回结果。

我不想使用Promise.all，因为万一这些函数中的任何一个失败，我只是不将它们添加到我的结果中。

ATM 我的代码如下所示。它可以工作，但我不喜欢 new Promise，我想以 ES6 异步方式进行，所以 callAll 函数应该看起来像 const callAll = async (query) => {

const callAll = (query) => {
    return new Promise((resolve, reject) => {
        const results = [];

        const jobs = [
            {
                promise: someModuleFirst.search(query), 
                done: false
            },
            {
                promise: someModuleSecond.search(query),
                done: false
            },
            {
                promise: someModuleThird.search(query),
                done: false    
            }
        ];

        const areAllDone = () => {
            if(!jobs.filter((job) => !job.done).length) {
                return true;
            }
        };

        jobs.forEach((job) => {
            job.promise.then((result) => {
                job.done = true;

                results.push(result);

                if(areAllDone()) {
                    resolve(results);
                }
            }).catch((error) => {
                job.done = true; 

                if(areAllDone()) {
                    resolve(results);
                }
            });
        });
    });
};

Answer 1

您可以将您的代码简化为以下内容。您可以从 catch 处理程序返回 false，然后过滤掉不会传递到结果集中的数据。

const callAll = async (query) => {
    const modules = [someModuleFirst, someModuleSecond, someModuleThird];
    const jobs = modules.map((module) => module.search(query).catch(() => false);
    const results = await Promise.all(jobs);
    return results.filter(Boolean);
};

Answer 2

您可以使用Promise.all，您唯一需要做的就是缓存拒绝并将其转化为解析。

function someAsyncFunction() {
	return new Promise((resolve, reject) => {
		setTimeout(function () {
			if (Math.round(Math.random() * 100) % 2) {
				return resolve('some result');
			}
			reject('some rejection');
		})
	}, 1);
}
var promises = [];
for (var i = 0; i < 10; i++) {
  // this is important part
  // catch block returns a promise with is resolved
  // so all promises now will resolve
	promises.push(someAsyncFunction().catch(function (reason) {
		return reason;
	}));
}
Promise.all(promises).then(function (results) {
  console.log('All resolved');
	console.log(results);
}).catch(function (reason) {
	console.error('Rejected');
	console.log(reason);
});

因此，在您的情况下，您需要将 someModuleFirst.search(query) 更改为类似 someModuleFirst.search(query).catch(e => e) 的东西