Bagaimana tepatnya menggabungkan beberapa aliran di firebase firestore

Anda dapat menggunakan StreamGroup dari paket async: https://pub.dev/documentation/async/latest/async/StreamGroup-class.html untuk mengelompokkan acara dari beberapa aliran - ini didokumentasikan dan dikelola dengan baik oleh tim dart. Jika Anda tidak memiliki pengalaman RxDart, ini adalah pilihan yang baik. Ia tidak memiliki semua fitur rx tetapi bagi pemula akan lebih mudah untuk memahaminya

Saya baru-baru ini mengalami kasus serupa, dan yang saya sarankan Anda lakukan adalah ini (Saya menggunakan cloud firestore, tapi saya yakin streaming Anda sudah ditulis jadi yang penting adalah penggunaan beberapa aliran):

Anda harus menambahkan plugin ini ke pub spec.yaml: https://pub.dev/packages/rxdart

Berikut adalah repositori untuk (dalam kasus Anda posting, katakanlah newPosts, oldPosts):

class PostRepository {

  static CollectionReference get collection => yourCollectionRef;
    
  static Stream<List<Post>> newPosts() {
    Query query = collection
        .where('Your condition like was viewed', isEqualTo: false)
        .orderBy('updateDate', descending: true)
        .limit(50);
    return query.snapshots().map<List<Post>>((querySnapshot) {
      final _newPosts = querySnapshot.documents.map((doc) {
        final post = Post.fromDoc(doc);
        return post;
      }).where((p) => p != null);

      return _newPosts
    });
  }

  static Stream<List<Post>> oldPosts() {
    Query query = collection
        .where('Your condition like was viewed', isEqualTo: true)
        .orderBy('updateDate', descending: true)
        .limit(50);
    return query.snapshots().map<List<Post>>((querySnapshot) {
      final _oldPosts = querySnapshot.documents.map((doc) {
        final post = Post.fromDoc(doc);
        return post;
      }).where((p) => p != null);

      return _oldPosts
    });
  }
}

Kemudian untuk mendapatkan beberapa aliran (gabungan keduanya dari atas), lakukan seperti ini di kelas widget Anda:

PENTING! Anda harus mengimpor ini - import 'package:rxdart/streams.dart';

List<Post> newPosts;
List<Post> oldPosts;

Widget _pageContent() {
  return SingleChildScrollView(
    child: Column(
      children: [
        ListView.builder(
          shrinkWrap: true,
          physics: NeverScrollableScrollPhysics(),
          itemCount: newPosts.length,
          itemBuilder: (context, index) {
            return ListTile(
              title: Text(newPosts[index].title)
            );
          }
        ),
        ListView.builder(
          shrinkWrap: true,
          physics: NeverScrollableScrollPhysics(),
          itemCount: oldPosts.length,
          itemBuilder: (context, index) {
            return ListTile(
              title: Text(oldPosts[index].title)
            );
          }
        )
      ]
    )
  );
}

Widget _posts() {
  return StreamBuilder(
    stream: CombineLatestStream.list([
      PostRepository.getNewPosts(),
      PostRepository.getOldPosts()
    ]),
    builder: (context, snap) {
     if (snap.hasError) {

        debugPrint('${snap.error}');
        return ErrorContent(snap.error);

      } else if (!snap.hasData) {

        return Center(
          child: CircularProgressIndicator(),
        );

      }

      newPosts = snap.data[0];
      oldPosts = snap.data[1];

      return _pageContent();
    }
  );
}

Saya menulis kode seperti dari kepala, jadi mungkin ada beberapa kesalahan kecil, tapi saya harap Anda mengerti maksudnya, selamat menikmati :)