如何在 rxdart 流中使用 Firebase 快照

Question

我有一个 class 具有所有与 firebase 相关的功能，另一个 class 用于管理状态（集团）。如何使它们始终如一地工作？

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

这就是我所做的，它对我有用。与教程的不同之处在于，我流 "List" 而流 "UnmodifiableListView"。在流式传输之前，您必须将数据映射到列表。然后，您可以随心所欲地使用该集团。

如何在 rxdart 流中使用 Firebase 快照

how to use Firebase snapshot with rxdart streams

reactive-programming

dart

flutter

rxdart