listenToMessages method

ResponseModel<Stream<List<ChatMessage>>> listenToMessages()

Implementation

ResponseModel<Stream<List<ChatMessage>>> listenToMessages() {
  try {
    final stream = FirebaseFirestore.instance
        .collection('CommunityChatRoom')
        .orderBy('createdOn', descending: true)
        .snapshots()
        .map((event) {
      List<ChatMessage> products = [];
      for (var item in event.docs) {
        products.add(ChatMessage.fromJson(item.data(), item.id));
      }
      return products;
    });
    return ResponseModel.completed(stream);
  } catch (e) {
    return ResponseModel.error(
        'Error listening from listenToLimtedPosts: $e');
  }
}