将 Flutter 流从 Firebase 转换为整数

Question

我有一个具有聊天功能的 Flutter 应用程序，其中的聊天记录存储在 Firebase 数据库中。我有一个BottomNavigationBar，它有一个用于聊天的图标按钮。如果有任何未读聊天，我会在此图标上显示一个徽章：

               BottomNavigationBarItem(
                  icon: new Stack(
                    children: <Widget>[
                      ImageIcon(AssetImage('images/icons.png')),
                      _unreadCount != null && _unreadCount > 0 ? Positioned(
                        right: 0,
                        child: new Container(
                          padding: EdgeInsets.all(1),
                          decoration: new BoxDecoration(
                            color: Colors.red,
                            borderRadius: BorderRadius.circular(6),
                          ),
                          constraints: BoxConstraints(
                            minWidth: 12,
                            minHeight: 12,
                          ),
                          child: new Text(
                            '$_unreadCount',
                            style: new TextStyle(
                              color: Colors.white,
                              fontSize: 8,
                            ),
                            textAlign: TextAlign.center,
                          ),
                        ),
                      ) : null
                    ].where((c) => c != null).toList(),
                  ),
                  title: Text('Chats', style: TextStyle(fontWeight: FontWeight.w500))
              ),

我使用返回Future<int> 的方法获取_unreadCount。它将查询 chats firebase 数据库并返回未读聊天的数量：

Future<int> getUnreadCount() async {

    bool isLoggedIn = await connection.isUserLoggedIn();
    int count = 0;

    if(isLoggedIn) {
      int userId = await _getUserId();

      final QuerySnapshot chatsQuerySnapshot =
        await Firestore.instance.collection("chats")
          .where("userIds", arrayContains: userId)
          .getDocuments();

      final List<DocumentSnapshot> documents = chatsQuerySnapshot.documents;

      if(documents != null && documents.isNotEmpty) {
        for (DocumentSnapshot chatsSnapshot in documents) {
          if(chatsSnapshot['unread'] as bool) {
            count++;
          }
        }
      }
    }

    return count;
  }

但是，因为这将返回 Future，所以只有在重建 BottomNavigationBar 时（即当我单击另一个选项卡时）并且调用 Future 方法时，徽章才会更新。

我需要一个返回 Stream 的方法，但我找不到任何可以按我想要的方式工作的示例。在我看来，流仅在返回数据集合/列表时使用，但我只想要一个int。我对响应式编程知之甚少，而且我是新手，但是如何以这种方式查询 Firebase？

Answer 1

这是map 函数的确切用例：只需将BottomNavigationBar 中的相关小部件包装在StreamBuilder 中，该StreamBuilder 将Firebase 流的映射版本作为参数。请参阅以下（未经测试的）Stream<int>，您可以在 StreamBuilder 中使用：

Firestore.instance.collection("chats")
      .where("userIds", arrayContains: userId)
      .snapshots()
      .map((snapshot) {
        return snapshot.documents.fold(0, (count, doc) {
          return (doc['unread'] as bool) ? count + 1 : count;
        });
      });

使用 Dart 中为Lists/Iterables 提供的众多方法之一，fold 调用可能会更干净，但我会留给你。

这是一个 Future<int>，您可以为 FutureBuilder 制作，如 cmets 中所述：

/// Returns the userId if the user is logged in, or null otherwise
Future<int> userIdWrapper() async {
    final isLoggedIn = await connection.isUserLoggedIn();
    return isLoggedIn ? await _getUserId() : null;
}