а если какой-то лист стримов и на новое сообщение просто сортировать его и как-то делать сет стейт на экране сообщений например?..

оно меньше кушать будет в теории или как?

что меньше жрет?
стрим стримов или на каждое сообщение сет стейт делать?

ну если бы я делал это, то делал на блоке. и каждое новое сообщение было типа стейта апдейт саккес с id комнаты

эт как? в пару строк

ну там не пару строк 😂

какой аналог у observable сейчас он деприкейтед вроде

Я такое делал, когда мне надо было с одного стрима (Websockets) делить на стримы - системные сообщения и сообщения в чате.
У меня репозиторий, в нем я объявил два стрим-контроллера

final _chatEventsController = StreamController<List<ChatMessage>>();
final _systemEventsController = StreamController<SystemMessage>();

Future<void> connect() async {
    WebsocketEventsDataSource source = await websocketEventsDataSource.connect();

    _eventsSubscribtion = source.events.listen((wsEvent) {
      final msg = MessageModelFactory.fromJson(jsonDecode(wsEvent));

      switch (msg.runtimeType) {
        case ChatMessageModel:
          {
            _chatEventsController.add(_addAndRotateChatMsgs(msg));
            return;
          }
        case SystemMessageModel:
          {
            _systemEventsController.add(msg);
            return;
          }
      }
    });
  }

собственно в методе connect подписываюсь на сообщения из ws и раскидываю их по стрим-контроллерам. В вашем случае наверно лучше как-то так же сделать

дададада

final _chatEventsController = StreamController<List<ChatMessage>>();
final _systemEventsController = StreamController<SystemMessage>();

Future<void> connect() async {
    WebsocketEventsDataSource source = await websocketEventsDataSource.connect();

    _eventsSubscribtion = source.events.listen((wsEvent) {
      final msg = MessageModelFactory.fromJson(jsonDecode(wsEvent));

      switch (msg.runtimeType) {
        case ChatMessageModel:
          {
            _chatEventsController.add(_addAndRotateChatMsgs(msg));
            return;
          }
        case SystemMessageModel:
          {
            _systemEventsController.add(msg);
            return;
          }
      }
    });
  }

спасибо
ну тип того я и спрашивал
какая практика лучше этого всего
а сортировку делал какую-то?
или со стороны клиента уже в контроллере оно?

дададдадададада

в смысле - сортировку?

ну тип по дате их по хорошему сортировать нужно или как

addAndRotateChatMsgs(msg)
наверное

не, сортировку не делал, какая разница как приходят сообщения - раньше или позже, у меня приложение не для чата с указанием точного времени, а просто - "позырить видосик" и "потрындеть"

тип пришло сообщение
комната выше стала в списке

этот метод просто отсекает "устаревшие" сообщения, неоптимально сделан, поэтому не приведу

ну сортировка это тупо клиент часть, какие с ней сложности то

а не, я такое не делал)

спасибо, Андрей
ну сортировку сам уж смогу написать)