Jan*_*ert 4 callback dart dart-html dart-async
我想知道是否可以在继续处理之前等待回调。
我正在使用一个在内部处理 future 的库,如果成功,则进行回调,否则在内部处理错误而不进行回调。
现在我尝试使用这个库创建一个实例,然后用随机测试数据填充它,然后更新该实体。
Map generateRandomizedInstance() {
lib.createEntity((result1){
result1["a"] = generateRandomA();
result1["b"] = generateRandomB();
result1["c"] = generateRandomC();
...
lib.updateEntity(result1, (result2){
// want to return this result2
return result2;
})
});
}
Run Code Online (Sandbox Code Playgroud)
如果我只创建一个实体并更新一次,那就没问题了,但我想创建大量随机数据:
ButtonElement b = querySelector("button.create")..onClick.listen((e){
for (int i = 0; i < 500; i++) {
generateRandomizedInstance();
}
});
Run Code Online (Sandbox Code Playgroud)
由于回调返回的速度不够快,这段代码很快就会崩溃。
我尝试将方法签名更改为
generateRandomizedInstance() async {
Run Code Online (Sandbox Code Playgroud)
然后做:
for (int i = 0; i < 500; i++) {
print(await generateRandomizedInstance());
}
Run Code Online (Sandbox Code Playgroud)
但该等待语法似乎无效,并且我不完全确定如何在某种将来包装该回调代码,以便我可以等待回调返回,然后再继续循环的下一次迭代。
我在末尾尝试了一个 while 循环,generateRandomizedInstance等待结果变量不为空,但这会杀死浏览器,并且看到我并不总是得到回调,在某些情况下它可能会导致无限循环。
关于如何在等待回调时暂停 for 循环的任何想法/建议?
这应该做你想要的:
Future<Map> generateRandomizedInstance() {
Completer<Map> c = new Completer<Map>();
lib.createEntity((result1){
result1["a"] = generateRandomA();
result1["b"] = generateRandomB();
result1["c"] = generateRandomC();
...
lib.updateEntity(result1, (result2){
// want to return this result2
c.complete(result2);
})
});
return c.future;
}
ButtonElement b = querySelector("button.create")..onClick.listen((e) async {
for (int i = 0; i < 500; i++) {
await generateRandomizedInstance();
}
});
Run Code Online (Sandbox Code Playgroud)