getMessagesStream method

  1. @override
Stream<List<ChatMessageModel>> getMessagesStream(
  1. String chatId
)
override

Retrieves a stream of messages for the specified chat.

Implementation

@override
Stream<List<ChatMessageModel>> getMessagesStream(
  String chatId,
) {
  _controller.onListen = () async {
    _subscription =
        chatOverviewService.getChatById(chatId).asStream().listen((event) {
      if (event.messages != null) {
        _cumulativeMessages.clear();
        _cumulativeMessages.addAll(event.messages!);
        _controller.add(_cumulativeMessages);
      }
    });
  };

  return _controller.stream;
}