diff options
author | Chocobozzz <me@florianbigard.com> | 2020-09-25 10:04:21 +0200 |
---|---|---|
committer | Chocobozzz <chocobozzz@cpy.re> | 2020-11-09 15:33:04 +0100 |
commit | a5cf76afa378aae81af2a9b0ce548e5d2582f832 (patch) | |
tree | 58da320232bee7c9656774c5d6811e82bbf6c696 /client/src/app/menu/avatar-notification.component.ts | |
parent | de6310b2fcbb8a6b79c546b23dfa1920724faaa7 (diff) | |
download | PeerTube-a5cf76afa378aae81af2a9b0ce548e5d2582f832.tar.gz PeerTube-a5cf76afa378aae81af2a9b0ce548e5d2582f832.tar.zst PeerTube-a5cf76afa378aae81af2a9b0ce548e5d2582f832.zip |
Add watch messages if live has not started
Diffstat (limited to 'client/src/app/menu/avatar-notification.component.ts')
-rw-r--r-- | client/src/app/menu/avatar-notification.component.ts | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/client/src/app/menu/avatar-notification.component.ts b/client/src/app/menu/avatar-notification.component.ts index 8b9955069..ed3ffc2d8 100644 --- a/client/src/app/menu/avatar-notification.component.ts +++ b/client/src/app/menu/avatar-notification.component.ts | |||
@@ -2,7 +2,7 @@ import { Subject, Subscription } from 'rxjs' | |||
2 | import { filter } from 'rxjs/operators' | 2 | import { filter } from 'rxjs/operators' |
3 | import { Component, EventEmitter, Input, Output, OnDestroy, OnInit, ViewChild } from '@angular/core' | 3 | import { Component, EventEmitter, Input, Output, OnDestroy, OnInit, ViewChild } from '@angular/core' |
4 | import { NavigationEnd, Router } from '@angular/router' | 4 | import { NavigationEnd, Router } from '@angular/router' |
5 | import { Notifier, User, UserNotificationSocket } from '@app/core' | 5 | import { Notifier, User, PeerTubeSocket } from '@app/core' |
6 | import { UserNotificationService } from '@app/shared/shared-main' | 6 | import { UserNotificationService } from '@app/shared/shared-main' |
7 | import { NgbPopover } from '@ng-bootstrap/ng-bootstrap' | 7 | import { NgbPopover } from '@ng-bootstrap/ng-bootstrap' |
8 | 8 | ||
@@ -27,7 +27,7 @@ export class AvatarNotificationComponent implements OnInit, OnDestroy { | |||
27 | 27 | ||
28 | constructor ( | 28 | constructor ( |
29 | private userNotificationService: UserNotificationService, | 29 | private userNotificationService: UserNotificationService, |
30 | private userNotificationSocket: UserNotificationSocket, | 30 | private peertubeSocket: PeerTubeSocket, |
31 | private notifier: Notifier, | 31 | private notifier: Notifier, |
32 | private router: Router | 32 | private router: Router |
33 | ) { | 33 | ) { |
@@ -75,7 +75,7 @@ export class AvatarNotificationComponent implements OnInit, OnDestroy { | |||
75 | } | 75 | } |
76 | 76 | ||
77 | private async subscribeToNotifications () { | 77 | private async subscribeToNotifications () { |
78 | const obs = await this.userNotificationSocket.getMyNotificationsSocket() | 78 | const obs = await this.peertubeSocket.getMyNotificationsSocket() |
79 | 79 | ||
80 | this.notificationSub = obs.subscribe(data => { | 80 | this.notificationSub = obs.subscribe(data => { |
81 | if (data.type === 'new') return this.unreadNotifications++ | 81 | if (data.type === 'new') return this.unreadNotifications++ |