我想使用 StreamController 来控制从 Firestore 中的集合获取数据的 StreamBuilder。这将使我能够使用 RefereshIndicator，这样当我下拉列表时，它会刷新/获取更多数据(如果有的话)。

我使用了这个 article 中的大部分信息.我当前的代码在下面

    class _Lists extends State<List> {
      StreamController _controller;
      final GlobalKey<ScaffoldState> scaffoldKey = new GlobalKey<ScaffoldState>();

        @override
         void initState() {
        _controller = new StreamController();
         loadPosts();         
        super.initState();
        }

       Future fetchPost() async {
       return await . 
       Firestore.instance.collection(_locationState).snapshots();
        }

      Future<Null> _handleRefresh() async {
      count++;
      print(count);
       fetchPost().then((res) async {
       _controller.add(res);
       showSnack();
        return null;
      });
     }

      showSnack() {
      return scaffoldKey.currentState.showSnackBar(
      SnackBar(
      content: Text('New content loaded'),
      ),
       );  
     }

      loadPosts() async {
      fetchPost().then((res) async {
       print(res.document);
       _controller.add(res);
      return res;
      });
      }


       @override
   Widget build(BuildContext context) {
   final topBar = AppBar(Title("List"));
   bottom: TabBar(
    indicatorColor: Colors.blueAccent,
    indicatorWeight: 3.0,
    //indicatorSize: 2.0,
    indicatorPadding:
        const EdgeInsets.only(bottom: 10.0, left: 47.0, right: 
    47.0),
    tabs: [
      Tab(
        child: Image(
          image: AssetImage("MyImage1"),
          width: 65.0,
          height: 65.0,
        ),
      ),
      Tab(
        child: Image(
          image: AssetImage("Image2"),
          width: 90.0,
          height: 90.0,
        ),
      ),
    ],
  ),

return DefaultTabController(
    length: 2,
    child: Scaffold(
        key: scaffoldKey,
        appBar: topBar,
        body: StreamBuilder(
            stream: _controller.stream,
            builder: (BuildContext context, AsyncSnapshot snapshot) {
              if (snapshot.hasError) {
                return Text(snapshot.error);
              }
              if (snapshot.connectionState == ConnectionState.active) {
                List aList = new List();
                aList.clear();
                for (DocumentSnapshot _doc in snapshot.data.documents) {
                  Model _add = new Model.from(_doc);
                  aList.add(_add);
                }
                return TabBarView(
                  children: <Widget>[
                    RefreshIndicator(
                      onRefresh: _handleRefresh,
                      child: ListView.builder(
                        itemCount: aList.length,
                        itemBuilder: (context, index) {
                          return Card(aList[index]);
                        },
                      ),
                    ),
                    Icon(Icons.directions_transit),
                  ],
                );
              } else {
                return Container(
                    child: Center(child: CircularProgressIndicator()));
              }
            })));
 }
}
}

我遇到的问题是我一直收到错误

    flutter: ══╡ EXCEPTION CAUGHT BY WIDGETS LIBRARY 
╞═══════════════════════════════════════════════════════════
flutter: The following NoSuchMethodError was thrown building 
StreamBuilder<dynamic>(dirty, state:
flutter: _StreamBuilderBaseState<dynamic, 
AsyncSnapshot<dynamic>>#53c04):
flutter: Class '_BroadcastStream<QuerySnapshot>' has no instance getter 'documents'.
flutter: Receiver: Instance of '_BroadcastStream<QuerySnapshot>'
flutter: Tried calling: documents

关于如何使用 StreamController 处理来自 Firestore 的数据有什么想法吗？

最佳答案

密切关注 IDE 中的返回类型可能有助于避免很多像这样令人困惑的问题。遗憾的是，该博客并未指明 API 调用、StreamController 或 then 语句中的“res”的任何类型。声明这些类型将有助于显示您正在使用的内容(至少它在 Android Studio 中对我有用)。例如，在我的带有来自 Firestore 的流的 StreamBuilder 中，我使用 AsyncSnapshot<QuerySnapshot> snapshot而不仅仅是 AsyncSnapshot .这允许 Android Studio 中的工具告诉我 snapshot.data.documents是来自 QuerySnapshot 的 map 类(class)。如果我不添加额外的类型，我将看不到它。

这是一个从 Firestore Dart package 监听流的例子.

//Performing a query:

Firestore.instance
    .collection('talks')
    .where("topic", isEqualTo: "flutter")
    .snapshots()
    .listen((data: QuerySnapshot) =>
        // do stuff here
    );

由于您使用的是 async/await 样式(也非常好)，因此您将获得与 .listen((data) => 中相同的结果。 .我们可以按照文档/类来查看返回的类型。

Firestore.instance.collection(<whatever>).snapshots() 将返回 Stream<QuerySnapshot> , 所以我们知道 await Firestore.instance.collection(<whatever>).snapshots() 将返回 QuerySnapshot .

进一步深入这个类，我们发现它有一个名为 documents 的属性.

  /// Gets a list of all the documents included in this snapshot
  final List<DocumentSnapshot> documents;

这最终给了我们那些 DocumentSnapshot s，你必须拉出 data属性(property)来自。

所以在你的情况下，我相信 res类型为 QuerySnapshot将帮助您显示要放入流中的数据，此时可以通过多种方式完成。 List<DocumentSnapshot>看起来像你想要的，但你可以走得更远 List<YourClass>从 DocumentSnapshot 构建data属性(property)。有了它，您可以说出您的 StreamController 将返回什么数据类型，使构建器的 AsyncSnapshot<your stream type>使用起来更加清晰。

我不确定您使用的是什么开发工具，但如果您不熟悉，大多数工具将允许您执行以下操作:按住(命令或 ctrl)，将鼠标悬停在类型/类/函数/var 你想看，左键单击，你应该被带到源文件/声明(我发现这非常方便)。

关于firebase - 带有 Firestore 的 StreamController，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/54525982/