วิธีรวมหลายสตรีมใน firebase firestore

คุณสามารถใช้ StreamGroup จากแพ็คเกจ async: https://pub.dev/documentation/async/latest/async/StreamGroup-class.html เพื่อจัดกลุ่มกิจกรรมจากหลายสตรีม - ได้รับการจัดทำเป็นเอกสารและดูแลรักษาอย่างดีโดยทีมงานโผ หากคุณไม่มีประสบการณ์ RxDart นี่เป็นตัวเลือกที่ดี มันไม่ได้มีคุณสมบัติทั้งหมดของ rx แต่สำหรับมือใหม่ ควรจะง่ายกว่านี้

ฉันเพิ่งมีกรณีที่คล้ายกัน และสิ่งที่ฉันแนะนำให้คุณทำคือ (ฉันใช้ cloud firestore แต่ฉันแน่ใจว่าคุณได้เขียนสตรีมของคุณไว้แล้ว ดังนั้นส่วนสำคัญคือการใช้หลายสตรีม):

คุณต้องเพิ่มปลั๊กอินนี้ใน pub spec.yaml: https://pub.dev/packages/rxdart

นี่คือพื้นที่เก็บข้อมูลสำหรับ (ในโพสต์เคสของคุณ สมมติว่า 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
    });
  }
}

จากนั้นหากต้องการรับหลายสตรีม (ทั้งสองจากด้านบนรวมกัน) ให้ทำสิ่งนี้ในคลาสวิดเจ็ตของคุณ:

สำคัญ! คุณต้องนำเข้าสิ่งนี้ - นำเข้า '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();
    }
  );
}

ฉันเขียนโค้ดเหมือนจากส่วนหัว ดังนั้นอาจมีข้อผิดพลาดเล็กน้อย แต่ฉันหวังว่าคุณจะเข้าใจประเด็น ขอให้สนุกนะ :)