Как именно объединить несколько потоков в firebase firestore

Вы можете использовать StreamGroup из асинхронного пакета: https://pub.dev/documentation/async/latest/async/StreamGroup-class.html для группировки событий из нескольких потоков - это хорошо документировано и поддерживается командой dart. Если у вас нет опыта RxDart, это хороший выбор. У него нет всех функций rx, но для новичка должно быть легче понять это

Недавно у меня был похожий случай, и я предлагаю вам сделать следующее (я использую облачный хранилище, но я уверен, что ваши потоки уже написаны, поэтому важной частью является использование нескольких потоков):

Вам необходимо добавить этот плагин в 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
    });
  }
}

Затем, чтобы получить несколько потоков (эти два сверху вместе), сделайте это в своем классе виджета:

ВАЖНЫЙ! вам нужно импортировать это - 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();
    }
  );
}

Я написал код как с головы, поэтому могут быть небольшие ошибки, но надеюсь, вы поняли суть, наслаждайтесь :)