залетел новый чат и нужно понять есть ли он уже, если нету то создать новый поток

сделай stackblitz какой с точкой входа (эмитим разные сообщения) и точкой выхода (как будут потреблять)
а мы уже че-нить накинем )
а то switchMap возвращает не стрим, а сабскрибшен…

тут же надо на исходный стрим навесить разного (scan?):
observables[message.chat.id] = listenOnStatCommand.pipe(filter(message.chat.id), debounce, mergeMap) + subscribe

соответственно динамически ты можешь создать функцию, которая будет возвращать тебе поток на каждый чат:

function getStreamForParticularChat(chatId: number){
  return socketStream$.pipe(
  filter(data => data.chatId === chatId),
  debounceTime(500)
);
}

@maximkoylo смотри мессагу выше

спасибо пойду опять курить)

если не выйдет то вернусь с сендбоксом

давай, я пока у компа

все равно ерунда, надо смотреть дальше, как потреблять будут (где будем .sub .unsub?)

Оффлайн в Москве с Тинькофф и онлайн Angular Kharkiv

👥👥👥 Приглашаем вас в офис Тинькофф на Angular митап:

— Владимир Агеев с докладом «Инвертируем зависимости правильно». Разберем реальную бизнес-задачу и попробуем ее решить с применением Open-Closed и Dependency Inversion
— Иван Ишмаметьев с докладом «Облачный Nx». Будет познавательно для тех, кому тесно в большом репозитории, у кого неудобные пайплайны или медленные ПРы / МРы.
— Круглый стол «Как не дать Angular-сообществу умереть». Поговорим про сообщество, опенсорс, доклады, митапы и нас с вами 😊

Встречаемся 28 апреля в 19:15, регистрация и подробности здесь: https://vk.tinkoff.ru/angular-meetup-19. Если не сможете прийти но заходите задать вопрос - сделайте это через online форму и получите приз 🎁

👀👀👀 Так-же  в этот четверг (29.04) будет проходить очередной Angular Kharkiv Meetup(Online).

- Katerina Skroumpelou (psybercity) — “Nx for Angular CLI Users”
- Maria Korneeva (BrowserPerson) — “HTTP Error Handling in Angular”
- Bonnie Brennan (bonnster75) — “Angular Nation”

Регистрация и подробная информация по докладам на страничке события

PS: А еще KirJS завел свой Telegram канал и прямо сейчас ведет трансляцию. Подписывайтесь на его канал и не пропускайте будущие трансляции :)
https://t.me/kirjs_ru/87

спасибо за инфу, круто)

Не я хз, помоги плиз)
https://codesandbox.io/s/priceless-chaum-q99zz?file=/src/index.ts

ну все верно да

В моем понимании это что то такого должно быть в итоге, или нет?

Ты че стал ангулярщиком?

эрыксером

А ну лан тогда

а чатов по рх как я понял нету потому тут зависаю)

Жиза)

ид то я могу только из потока получать