как использовать снимок 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». Перед потоковой передачей необходимо сопоставить свои данные со списком. Затем вы можете использовать блок где угодно.