Я пытаюсь вернуть Observable из службы, которая позволила бы вам прослушивать любой канал Pusher.
Работает нормально, ожидайте, что я бы хотел unsubscribe
из канала-отправителя, когда Observable (сгенерированный с помощью createRealtimeObservable(...)
) был отписан от подписки.
Есть идеи?
public realtimeObservable (channelName, eventName): Observable<any> {
const realtimeObservable$ = new Observable((observer) => {
const channel = this.pusher.subscribe(`private-organization-${this.authService.userProfile.organization_id}-${channelName}`)
channel.bind(eventName, (data) => {
observer.next(data.payload)
})
})
return realtimeObservable$
}