dart - 当Complete首先触发时，Dart嵌套 future

Question

我需要进行一系列数据库查询，每个查询都返回结果流。一旦收集并发送了所有信息，就需要最后发送“完成”消息。在我的代码中，“sendCompleteMessageToClient”首先发送。

 Future.forEach(centerLdapNames.values, (center) {
   db
       .collection(center)
       .find({'date': {'\$gte': json['from'], '\$lt': json['to']}})
       .forEach(sendAppointmentToClient);
 }).whenComplete(() => sendCompleteMessageToClient("all"));

如何等待所有“sendAppointmentToClient”正确完成？

Answer 1

我想你只是想念 future 的回归

Future.forEach(centerLdapNames.values, (center) {
   return db // <== always return the returned future from calls to async functions to keep the chain connected
       .collection(center)
       .find({'date': {'\$gte': json['from'], '\$lt': json['to']}})
       .forEach(sendAppointmentToClient);
 }).whenComplete(() => sendCompleteMessageToClient("all"));

如果使用wait，这些调用可能会并行执行，而不是一个接一个地执行

Future.wait(centerLdapNames.values.map((center) { ...}, eagerError: false)
.whenComplete((...))