我遇到了一个我不太了解的问题。我觉得可能有一些我尚未掌握的概念，可能被优化的代码以及可能因适当原因而引发的错误。
要大大简化整体流程：
这是原始请求（＃1）：
await Store.get(Constants.Contentful.ENTRY, Contentful[page.file])
Store.get表示为：
async get(type, id) {
return await this._get(type, id);
}
哪个调用：
_get(type, id) {
return new Promise(async (resolve, reject) => {
var data = _json[id] = _json[id] || await this._api(type, id);
console.log(data)
if(isAsset(data)) {
resolve(data);
} else if(isEntry(data)) {
await this._scan(data);
resolve(data);
} else {
const error = 'Response is not entry/asset.';
console.log(error);
reject(error);
}
});
}
API调用为：
_api(type, id) {
return new Promise((resolve, reject) => {
Request('http://cdn.contentful.com/spaces/' + Constants.Contentful.SPACE + '/' + (!type || type === Constants.Contentful.ENTRY ? 'entries' : 'assets') + '/' + id + '?access_token=' + Constants.Contentful.PRODUCTION_TOKEN, (error, response, data) => {
if(error) {
console.log(error);
reject(error);
} else {
data = JSON.parse(data);
if(data.sys.type === Constants.Contentful.ERROR) {
console.log(data);
reject(data);
} else {
resolve(data);
}
}
});
});
}
返回条目后，将对其进行扫描：
_scan(data) {
return new Promise((resolve, reject) => {
if(data && data.fields) {
const keys = Object.keys(data.fields);
keys.forEach(async (key, i) => {
var val = data.fields[key];
if(isLink(val)) {
var child = await this._get(val.sys.linkType.toUpperCase(), val.sys.id);
this._inject(data.fields, key, undefined, child);
} else if(isLinkArray(val)) {
var children = await* val.map(async (link) => await this._get(link.sys.linkType.toUpperCase(), link.sys.id));
children.forEach((child, index) => {
this._inject(data.fields, key, index, child);
});
} else {
await new Promise((resolve) => setTimeout(resolve, 0));
}
if(i === keys.length - 1) {
resolve();
}
});
} else {
const error = 'Required data is unavailable.';
console.log(error);
reject(error);
}
});
}
如果找到了链接引用，则会发出其他请求，然后将结果JSON代替引用注入到原始JSON中：
_inject(fields, key, index, data) {
if(isNaN(index)) {
fields[key] = data;
} else {
fields[key][index] = data;
}
}
请注意，我正在使用async，await和Promise，我相信他们的预定庄园。最终发生的事情：对引用数据的调用（由_scan获取的结果）最终在返回原始请求之后发生。这样最终会向内容模板提供不完整的数据。
有关我的构建设置的其他信息：
我相信问题在于您forEach打来的电话_scan。作为参考，请参见使用ES7驯服异步野兽中的这一段：
但是，如果尝试使用异步功能，则会收到一个更细微的错误：
let docs = [{}, {}, {}]; // WARNING: this won't work docs.forEach(async function (doc, i) { await db.post(doc); console.log(i); }); console.log('main loop done');这将编译，但问题是它将打印出：
main loop done 0 1 2发生的情况是主要功能早已退出，因为
await实际在子功能中。此外，这将同时执行每个promise ，这不是我们想要的。课程是：异步函数中有任何函数时要小心。将
await只会暂停其父功能，因此检查它在做什么，你真的觉得它在做什么。
因此，该forEach调用的每个迭代都同时运行。他们一次不执行一个。只要符合条件的一个标准i === keys.length - 1完成，该promise就会被解决并_scan返回，即使通过via调用的其他异步函数forEach仍在执行。
您可能需要将其更改forEach为amap以返回一个promise数组，然后可以await*从中_scan（如果您要同时执行所有promise，然后在它们全部完成后调用某些东西），或者一次执行它们-time，如果您希望它们按顺序执行。
附带说明一下，如果我没看错的话，您的某些异步功能可以简化一些；记住这一点，而await荷兰国际集团的async函数调用返回一个值，只需调用它返回另一个承诺，并返回从价值async功能是一样的返回一个承诺解析为在非该值async的功能。因此，例如，_get可以是：
async _get(type, id) {
var data = _json[id] = _json[id] || await this._api(type, id);
console.log(data)
if (isAsset(data)) {
return data;
} else if (isEntry(data)) {
await this._scan(data);
return data;
} else {
const error = 'Response is not entry/asset.';
console.log(error);
throw error;
}
}
同样，_scan可能是（假设您希望forEach主体同时执行）：
async _scan(data) {
if (data && data.fields) {
const keys = Object.keys(data.fields);
const promises = keys.map(async (key, i) => {
var val = data.fields[key];
if (isLink(val)) {
var child = await this._get(val.sys.linkType.toUpperCase(), val.sys.id);
this._inject(data.fields, key, undefined, child);
} else if (isLinkArray(val)) {
var children = await* val.map(async (link) => await this._get(link.sys.linkType.toUpperCase(), link.sys.id));
children.forEach((child, index) => {
this._inject(data.fields, key, index, child);
});
} else {
await new Promise((resolve) => setTimeout(resolve, 0));
}
});
await* promises;
} else {
const error = 'Required data is unavailable.';
console.log(error);
throw error;
}
}
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句