Приветствую! Взываю к вашей помощи. Затрудняюсь корректно подписаться на пуши от

Question

Приветствую! Взываю к вашей помощи. Затрудняюсь корректно подписаться на пуши от

SignalR (.NET Core).
Подписался на пуши, их отображаю. Всё хорошо.
this._hubConnection
.start()
.then(() => console.log('Connection started!'))
.catch(err => console.log('Error while establishing connection :(',err));

this._hubConnection.on('BroadcastMessage', (subject: string, body: string) => {
this.notificationService.info(subject, body); //показ уведомления
});
Этот код в одном из родительских компонентов.
Но как сделать приходящие от сервера данные глобальными, чтобы любой компонент можно было "подписать" на обновления от сервера?
Запускать подключение нужно, естественно, один раз, поэтому подключение в нужном компоненте не вариант(((

Надеюсь, вопрос задал корректно :D
Спасибо!

#angular #frontend #javascript #programming #russian

0

30.10.2018

2 ответов

13 просмотров

Dmitriy Teplov

завести сервис, который при инициализации будет подписываться на пуши и раздавать их через сабжект @Injectable() export class PushService { public readonly pushMessages$: Observable; private _pushMessages$: Subject; constructor(private _hubConnection) { this.pushMessages$ = this._pushMessages$.asObservable().pipe(share()); this._hubConnection .start() .then(() => console.log('Connection started!')) .catch(err => console.log('Error while establishing connection :(',err)); this._hubConnection.on( 'BroadcastMessage', (subject: string, body: string) => this._pushMessages$.next({subject, body}) ); } }

0

30.10.2018

Hey 👋, i'm 𝖙𝖍𝖊𝖐𝖎𝖇𝖆! キバ · Accepted Answer

Hey 👋, i'm 𝖙𝖍𝖊𝖐𝖎𝖇𝖆! キバ

https://blog.angularindepth.com/rxjs-understanding-the-publish-and-share-operators-16ea2f446635

0

30.10.2018

169 похожих чатов

Приветствую! Взываю к вашей помощи. Затрудняюсь корректно подписаться на пуши от

2 ответов

Похожие вопросы