Блог

Я пытаюсь реализовать базу данных Firebase в реальном времени в Flutter, и я хочу отображать обновленные значения в режиме реального времени. Я пытаюсь добиться этого с StreamBuilder помощью .

Код StreamBuilder

 StreamBuilder(
  stream: GuestbooksDatabase().getAllGuestbooksSync().asStream(),
  builder: (context, snapshot) {
    if (!snapshot.hasData || !snapshot.data.length) {
      return CircularProgressIndicator();
    } else {
      return ListView.builder(
          shrinkWrap: true,
          itemCount: snapshot.data.length,
          itemBuilder: (context, index) {
            return Text(snapshot.data[index].title);
          });
    }
  }),
  

Функция потока

 Future<List<Guestbook>> getAllGuestbooksSync() async {
    List<Guestbook> guestbooks = [];
    databaseRef.onValue.listen((event) async {
      var dataSnapshot = event.snapshot;

      if (dataSnapshot.value != null) {
        dataSnapshot.value.forEach((key, value) async {
          Guestbook guestbook = await Guestbook.fromJson(value);
          guestbook.setId(key);
          guestbooks.add(guestbook);
        });

        await Future.delayed(Duration.zero);
        print(guestbooks); // Result: All Instances of Guestbook
        return guestbooks;
      }
    });
  }
  

Я вижу только CircularProgressIndicator() то, что означает, что в моментальном снимке нет данных.
В чем проблема?

Вы можете использовать StreamController для этого.

Создайте новый контроллер —

 final StreamController streamController = StreamController<List>.broadcast();
  

Преобразуйте Future<List> в void type для вашей getAllGuestbooksSync() функции и ничего не возвращайте.

Он может и будет вызываться в initState() —

 void getAllGuestbooksSync() {
    List<Guestbook> guestbooks = [];
    databaseRef.onValue.listen((event) async {
      var dataSnapshot = event.snapshot;

      if (dataSnapshot.value != null) {
        dataSnapshot.value.forEach((key, value) async {
          Guestbook guestbook = await Guestbook.fromJson(value);
          guestbook.setId(key);
          guestbooks.add(guestbook);
        });

        print(guestbooks); // Result: All Instances of Guestbook

        streamController.add(guestbooks); // Adding list to the stream
      }
    });
}
  

В вашем StreamBuilder использовании —

 stream: streamController.stream,