В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Angular - русскоговорящее сообщество

5922 membersпожаловаться на группу
2021 June 17

OP

Oleg P in Angular - русскоговорящее сообщество
мне нужна шина сообщений. Чтобы при отправке данных указать в какой канал отправлять и payload.
Затем в нужном месте подписываюсь на нужный канал и получаю сообщения. Когда-то нужно отписаться именно от конкретного канала - чтобы больше не получать сообщения
источник
23:25пожаловаться#1

OP

Oleg P in Angular - русскоговорящее сообщество
Вот мой сервис - шина:
источник
23:26пожаловаться#2

OP

Oleg P in Angular - русскоговорящее сообщество
Отправка сообщения в канал с именем EDIT_LAYER_MAP:
источник
23:27пожаловаться#3

OP

Oleg P in Angular - русскоговорящее сообщество
Подписка на канал и получение данных:
источник
23:27пожаловаться#4

RY

Roman Yazvinsky in Angular - русскоговорящее сообщество
1) В сервисе возвращайте return this.emitter.pipe(...), без .subscribe. Тогда не понадобится handler прокидывать и будет возможность нормально организовать отписку
источник
23:28пожаловаться#5

OP

Oleg P in Angular - русскоговорящее сообщество
а фильтровать тогда на стороне подписчика? там проверять на канал?
источник
23:28пожаловаться#6

RY

Roman Yazvinsky in Angular - русскоговорящее сообщество
2) Еще раз, зачем вызывается subscribe во второй раз?
источник
23:29пожаловаться#7

RY

Roman Yazvinsky in Angular - русскоговорящее сообщество
filter и map оставьте в сервисе
источник
23:29пожаловаться#8

OP

Oleg P in Angular - русскоговорящее сообщество
компонент пересоздается и в конструкторе опять подписывается на канал. А в этом канале - последнее сообщение
источник
23:29пожаловаться#9

OP

Oleg P in Angular - русскоговорящее сообщество
так?
источник
23:32пожаловаться#10

RY

Roman Yazvinsky in Angular - русскоговорящее сообщество
Можно немного переделать логику и в take() прокидывать число оставшихся непрочитанных сообщений. Соответственно, надо где-то хранить информацию, какие сообщения прочитаны, а какие нет
источник
23:32пожаловаться#11

OP

Oleg P in Angular - русскоговорящее сообщество
источник
23:33пожаловаться#12

RY

Roman Yazvinsky in Angular - русскоговорящее сообщество
Да, только возвращаемый тип все же укажите у метода
источник
23:33пожаловаться#13

RY

Roman Yazvinsky in Angular - русскоговорящее сообщество
Если в инкогнито работает, а в обычном режиме нет - почистите кэш
источник
23:36пожаловаться#14

А

Александр (Alex)... in Angular - русскоговорящее сообщество
чистил не помогает
источник
23:38пожаловаться#15

А

Александр (Alex)... in Angular - русскоговорящее сообщество
заходит на все модули кроме одного
источник
23:38пожаловаться#16

OP

Oleg P in Angular - русскоговорящее сообщество
все равно будет приходить. Даже если поставить take на стороне подписчика. Из-за того что компонент заново создается. Опять прилетает сообщение.
источник
23:39пожаловаться#17

OP

Oleg P in Angular - русскоговорящее сообщество
Все-таки нужно пробросить левое значение - чтобы не приходило больше сообщение
источник
23:39пожаловаться#18

RY

Roman Yazvinsky in Angular - русскоговорящее сообщество
Не, вынос subscribe вне сервиса не решает проблему. Вам скорее всего надо делать filter(message => message.isUnread) или что-то подобное
источник
23:40пожаловаться#19

OP

Oleg P in Angular - русскоговорящее сообщество
спасибо. нужно что-то попроще
источник
23:49пожаловаться#20