不要在顺序链式承诺中包含 q 承诺结果
Don't include q promise result in sequentially chained promises
我有以下顺序链接的Q承诺,它填充了用户>属性>租户>提醒的层次结构:
return getAllUsers() // get all users of the system
.then(function(users) {
return Q.all(users.map(function(user) {
return getUserProperties(user) // foreach user of the system get their properties
.then(function(properties) {
user.properties = properties;
return Q.all(properties.map(function(property) {
return getPropertyTenants(property) // foreach property get active tenants
.then(function(tenants) {
property.tenants = tenants;
return Q.all(tenants.map(function(tenant) {
return getTenantReminders(property, tenant) // foreach tenant get their payment reminders
.then(function(reminders) {
// if reminders.length == 0 we don't want to include this user
tenant.reminders = reminders;
});
}));
});
}));
}).thenResolve(user);
}));
});
此承诺链的要点是获取租户的所有付款提醒,然后向每个用户发送电子邮件,其中包含租户提醒列表(每个用户)。 如果没有从getTenantReminders()解析的提醒,那么理想情况下,来自顶级getAllUsers()的用户不会包含在结果中。
我想过从getTenantReminders().then()处理程序中抛出一个特殊的错误,该处理程序在链上并在thenResolve(user)中处理,然后不返回用户。 不确定这是否是正确的方法。
感谢任何建议。
正如赛斯所说,在这里保持理智的关键是避免厄运金字塔。这是一种我认为应该有效的方法(尽管显然我没有测试过它):
// Produces a function that takes an array of values as input,
// Applies func() to each of them, and merges the results into a
// promise for a single array.
// func() is assumed to take a single value as input and
// return an array or promise for an array
// (X -> Promise<Y[]>) -> (X[] -> Promise<Y[]>)
function applyAllAndMerge(func) {
return function (values) {
return Q.all(values.map(func))
.then(function (arrays) {
return Array.prototype.concat.apply([], arrays);
});
};
}
// returns a promise for an array of all tenant reminders for the
// specified property
// property -> Promise<tenantReminder[]>
function getTenantRemindersForProperty(property) {
return getPropertyTenants(property)
.then(applyAllAndMerge(function (tenant) {
return getTenantReminders(property, tenant);
}));
}
// returns a promise for an array of all tenant reminders for the
// specified user
// user -> Promise<tenantReminder[]>
function getTenantRemindersForUser(user) {
return getUserProperties(user)
.then(applyAllAndMerge(getTenantRemindersForProperty));
}
// returns a promise for an object containing the specified
// user and all of their tenant reminders
// user -> Promise<{user, tenantReminder}[]>
function getUserAndTenants(user) {
return getTenantRemindersForUser(user)
.then(function (reminders) {
return { user: user, reminders: reminders };
});
}
return getAllUsers() // get all users of the system
.then(function(users) {
return Q.all(users.map(getUserAndTenants));
})
.then(function (userReminders) {
// get rid of users with no reminders
var usersWithReminders = userReminders.filter(function (ur) {
return ur.reminders.length > 0;
});
// use usersWithReminders
});
相关文章:
- 当包含另一个asp文件时,是否也包含所有引用的样式和脚本页面
- 我的职位回报太快了,如何做出承诺
- 打破承诺链的好方法是什么
- 货币代码为欧元-金额的格式不应包含小数
- 如何包含特定于每个视图angularjs的javascript文件
- 从函数返回角度承诺
- 我如何修复包含在captcha的addthis中的错误
- 正在注入包含JS的HTML
- Json数据包含日期和时间格式
- Angular js-返回一个包含类似
- JQuery 承诺已经包含回调的函数
- 不要在顺序链式承诺中包含 q 承诺结果
- AngularFire $createUser 的承诺不返回包含用户数据的对象
- 如何在 EJS 中包含承诺值
- 如何从包含承诺链的常规 JavaScript 函数返回值
- 如何调用包含链式承诺的函数
- 调用一个包含承诺链的函数
- 如何使包含映射承诺的函数返回承诺?
- 包含承诺的队列异步操作
- 如何承诺一个不包含回调参数的函数