Dart异步函数返回Future与StreamBuilder需求冲突问题求助

我编写了followingUser函数但无法正常运行——使用async关键字时必须返回Future类型，但我需要返回Iterable类型的值来为StreamBuilder创建流。

原函数代码 #

Iterable<Object>? followingUser(String uid)  async {
  final firestore = FirebaseFirestore.instance;

  try {
    final userSnapshot = await firestore.collection('users').doc(uid).get();

    if (userSnapshot.exists) {
      final followedUsers = List<String>.from(userSnapshot['following']);

      final posts = await firestore
          .collection('posts')
          .where('uid', whereIn: followedUsers)
          .get();
      print('this is following users');
      print(followedUsers);
      return followedUsers;
    } else {
      print('User not found.');
      return null;
    }
  } catch (e) {
    print('Error retrieving posts: $e');
  }
}

StreamBuilder代码 #

final followingUsers = firestoreMethods.followingUser(uid);
...
StreamBuilder(
        stream: FirebaseFirestore.instance
            .collection('posts')
            .where(
              'uid',whereIn: followingUsers
            )
            .orderBy('datePublished', descending: true)
            .snapshots(),
builder:.....
),

遇到的报错 #

• 移除async关键字时，报错：

  The await expression can only be used in an async function.
  Try marking the function body with either 'async' or 'async*'

• 添加Future返回类型时，报错：

  The argument type 'Future<Iterable?>' can't be assigned to the parameter type 'Iterable<Object?>?'

问题根源 #

async函数必然返回Future，但StreamBuilder的whereIn参数需要同步的Iterable值，无法直接接收Future。另外原函数中查询posts的代码未实际使用，可简化逻辑。

解决步骤 #

1. 修正followingUser函数的返回类型 #

既然使用了async，直接将返回类型改为Future<List<String>?>，同时处理字段为null的情况：

Future<List<String>?> followingUser(String uid) async {
  final firestore = FirebaseFirestore.instance;

  try {
    final userSnapshot = await firestore.collection('users').doc(uid).get();

    if (userSnapshot.exists) {
      final followedUsers = List<String>.from(userSnapshot['following'] ?? []);
      print('已关注用户列表：$followedUsers');
      return followedUsers;
    } else {
      print('未找到用户');
      return null;
    }
  } catch (e) {
    print('获取关注列表失败：$e');
    return null;
  }
}

2. 用FutureBuilder嵌套StreamBuilder #

需要先异步获取关注列表，再基于该列表构建posts流：

FutureBuilder<List<String>?>(
  future: firestoreMethods.followingUser(uid),
  builder: (context, snapshot) {
    if (snapshot.connectionState == ConnectionState.waiting) {
      return const CircularProgressIndicator();
    }
    final followingUsers = snapshot.data ?? [];
    return StreamBuilder(
      stream: FirebaseFirestore.instance
          .collection('posts')
          .where('uid', whereIn: followingUsers)
          .orderBy('datePublished', descending: true)
          .snapshots(),
      builder: (context, postSnapshot) {
        if (postSnapshot.connectionState == ConnectionState.waiting) {
          return const CircularProgressIndicator();
        }
        // 这里替换为你的posts渲染逻辑
        return ListView.builder(
          itemCount: postSnapshot.data?.docs.length ?? 0,
          itemBuilder: (context, index) {
            final postData = postSnapshot.data?.docs[index].data();
            return Text(postData?['caption'] ?? '暂无内容');
          },
        );
      },
    );
  },
)

3. 进阶优化：实时监听关注列表变化 #

如果需要在用户关注/取消关注时自动更新posts流，可将函数改为返回Stream：

Stream<List<String>> followingUserStream(String uid) {
  return FirebaseFirestore.instance
      .collection('users')
      .doc(uid)
      .snapshots()
      .map((userSnapshot) {
    if (userSnapshot.exists) {
      return List<String>.from(userSnapshot['following'] ?? []);
    }
    return [];
  }).handleError((e) {
    print('监听关注列表失败：$e');
    return [];
  });
}

使用时用StreamBuilder嵌套：

StreamBuilder<List<String>>(
  stream: firestoreMethods.followingUserStream(uid),
  builder: (context, snapshot) {
    if (snapshot.connectionState == ConnectionState.waiting) {
      return const CircularProgressIndicator();
    }
    final followingUsers = snapshot.data ?? [];
    return StreamBuilder(
      stream: FirebaseFirestore.instance
          .collection('posts')
          .where('uid', whereIn: followingUsers)
          .orderBy('datePublished', descending: true)
          .snapshots(),
      builder: (context, postSnapshot) {
        // 渲染posts逻辑
        // ...
      },
    );
  },
)

内容的提问来源于stack exchange，提问作者Moath Zayn