getMessagesStream method

Stream<List<PeamanMessage>> getMessagesStream({
  1. required String chatId,
  2. int? startAfter,
})

Implementation

Stream<List<PeamanMessage>> getMessagesStream({
  required String chatId,
  int? startAfter,
}) {
  final query = PeamanReferenceHelper.messagesCol(chatId: chatId)
      .where('visibility', isEqualTo: true)
      .orderBy('created_at', descending: true);
  if (startAfter != null) {
    return query
        .endBefore([startAfter])
        .snapshots()
        .map(_messagesFromFirestore);
  }
  return query.snapshots().map(_messagesFromFirestore);
}