为什么我在 Promise.race() 的实现中出现意外行为?
Why am I getting an unexpected behavior in my implementation of Promise.race()?
我有 Promise.race() 实现的代码,它基本上可以工作。但是,在这种情况下:
promiseRace([Promise.reject('test_error'), Promise.resolve('test_value')])
我得到的是 test_value
而不是 test_error
。
为什么会这样?
const promiseRace = promises => new Promise((resolve, reject) => {
promises.forEach(p => {
if (
typeof p === 'object'
&& 'then' in p
&& typeof p.then === 'function'
) {
p.then(resolve).catch(reject);
} else {
resolve(p);
}
});
});
promiseRace([Promise.reject('test_error'),
Promise.resolve('test_value')]).then(value => { console.log(value); });
发生这种情况是因为在下一行中,您在另一个(链式)承诺而不是原始承诺上调用 .catch
:
p.then(resolve).catch(reject);
请注意 then
调用如何没有获得 reject
回调参数,因此有一个额外的 -- 中间异步承诺周期。在调用 .catch
回调时 (reject
),另一个案例已经处理完毕(已实现的承诺)。
所以改为:
p.then(resolve, reject);
我有 Promise.race() 实现的代码,它基本上可以工作。但是,在这种情况下:
promiseRace([Promise.reject('test_error'), Promise.resolve('test_value')])
我得到的是 test_value
而不是 test_error
。
为什么会这样?
const promiseRace = promises => new Promise((resolve, reject) => {
promises.forEach(p => {
if (
typeof p === 'object'
&& 'then' in p
&& typeof p.then === 'function'
) {
p.then(resolve).catch(reject);
} else {
resolve(p);
}
});
});
promiseRace([Promise.reject('test_error'),
Promise.resolve('test_value')]).then(value => { console.log(value); });
发生这种情况是因为在下一行中,您在另一个(链式)承诺而不是原始承诺上调用 .catch
:
p.then(resolve).catch(reject);
请注意 then
调用如何没有获得 reject
回调参数,因此有一个额外的 -- 中间异步承诺周期。在调用 .catch
回调时 (reject
),另一个案例已经处理完毕(已实现的承诺)。
所以改为:
p.then(resolve, reject);