getMessages method

  1. @override
Future<ChatResult<List<ChatMessage>>> getMessages(
  1. String roomId, {
  2. int? limit,
})
override

Implementation

@override
Future<ChatResult<List<ChatMessage>>> getMessages(
  String roomId, {
  int? limit,
}) async {
  var messages = _messages[roomId] ?? [];
  final clearedAt = _clearedAt[roomId];
  if (clearedAt != null) {
    messages = messages.where((m) => m.timestamp.isAfter(clearedAt)).toList();
  }
  if (limit != null && messages.length > limit) {
    return ChatSuccess(messages.sublist(0, limit));
  }
  return ChatSuccess(messages);
}