如何将 Firebase 快照与 rxdart 流一起使用

Question

我有一个类具有所有与 firebase 相关的功能，还有一个类来管理状态（块）。如何使它们始终如一地工作？

class UserFirebase {

Stream<List<User>> fetchUsers() {
  // I want this function to return a Stream<List<User>> where i can 
  //listen to in UserBloc
  return Firestore.instance.collection('users').snapshots();
 }
}



class UserBloc {
   UserFirebase _sService;
   Observable<List<User>> get users => _sService.fetchUsers();
}

我的方法可能不正确，但我想描述一下问题。

Answer 1

您可以观看本教程，只需将数据源替换为 firebase： https://www.youtube.com/watch?v=fahC3ky_zW0

这是我所做的，它对我有用。本教程的不同之处在于，我在流“UnmodifiableListView”时流式传输“List”。在流式传输之前，您必须将数据映射到列表。 然后，您可以在任何地方使用该集团。