为什么我的返回 Future<int> 的异步函数会在等待时停止？

Question

我使用这个函数的目标是返回一个整数，表示用户完成的所有习惯。我的数据库结构是习惯的集合，每个习惯都有一个包含其历史的子集合。下面的函数利用了一个习惯列表，并使用习惯的 ID 获取该习惯的历史流。我的问题是，当我尝试遍历每个习惯的历史记录时，它会停在await for。任何建议都将不胜感激，我仍在尝试完全理解流/异步函数。

Future<int> getCompleteHabits(User user, List<Habit> habits) async {
  int completed = 0;
  if(habits.isNotEmpty) {
    for(Habit habit in habits) {
      Stream<List<HabitHistory>> streamHistory = db.streamHabitHistory(user, habit.id);
      await for(var h in streamHistory){
        print(habit.title);
        print(h);
      }
      print("test");
    }
  }
  return completed;
}

但是，这个函数将添加到已完成的变量中，因为我无法访问我尚未访问的所有历史记录。

此函数将以下内容打印到控制台，但没有到达print("test")。

flutter：晚上 11:30 之前上床睡觉

flutter：['HabitHistory' 实例，'HabitHistory' 实例，'HabitHistory' 实例，'HabitHistory' 实例，'HabitHistory' 实例]

Answer 1

正如 Abion47 所说，流尚未关闭，因此等待永远不会完成。它正在等待新的事件。

知道了这一点，我可以使用await streamHabitHistory(user, habit.id).first 来获取列表（因此它不会等待事件）。代码如下。

Future<int> getCompleteHabits(User user, List<Habit> habits) async {
  int completed = 0;
  if(habits.isNotEmpty) {
    for(Habit habit in habits) {
      List<HabitHistory> history = await db.streamHabitHistory(user, habit.id).first;
      for (HabitHistory h in history) {
        completed = completed + h.completed.length;
      }

    }
  }
  return completed;
}

Answer 2

来自documentaion on Streams：

流在其中没有更多事件时完成，并且接收事件的代码会收到通知，就像收到新事件的通知一样。当使用 await for 循环读取事件时，循环在流完成时停止。

您的循环挂起的原因是流尚未关闭。它将继续挂起，直到流关闭或直到您在循环中执行 break 或 return 语句。