Estoy intentando implementar las transmisiones y la paginación de Firebase con mi GetX. Con mi implementación surge el siguiente problema. El lote inicial de publicaciones recuperadas se transmite correctamente y se actualiza en tiempo real. Sin embargo, el segundo lote de publicaciones no se actualiza en tiempo real. Parece que la transmisión no está vinculada al segundo lote de publicaciones. Aquí está el código:
ScrollController scrollController = ScrollController();
CollectionReference get _posts => FirebaseFirestore.instance.collection(FirebaseConstants.postsCollection);
RxList<PostModel> viewPost = RxList<PostModel>([]);
@override
void onInit() {
super.onInit();
viewPost.bindStream(getPosts());
}
Stream<List<PostModel>> getPosts() {
Stream<QuerySnapshot> snapshotStream;
void handleScroll() {
if (scrollController.position.maxScrollExtent ==
scrollController.position.pixels) {
var lastPost = viewPost.isNotEmpty ? viewPost.last : null;
_posts
.orderBy('createdAt', descending: true)
.startAfter([lastPost!.createdAt])
.limit(2)
.snapshots()
.listen((event) {
List<PostModel> newPosts = [];
for (var doc in event.docs) {
newPosts
.add(PostModel.fromMap(doc.data() as Map<String, dynamic>));
}
viewPost.addAll(newPosts);
});
}
}
scrollController.addListener(handleScroll);
snapshotStream =
_posts.orderBy('createdAt', descending: true).limit(7).snapshots();
return snapshotStream.map((event) {
List<PostModel> posts = [];
for (var doc in event.docs) {
posts.add(PostModel.fromMap(doc.data() as Map<String, dynamic>));
}
return posts;
});
}
Probé varias implementaciones diferentes y siempre encuentro el mismo problema. Las publicaciones se recuperan y se muestran en el orden correcto. Sin embargo, las actualizaciones en tiempo real funcionan sólo para el lote inicial de publicaciones y no para el resto.