diff options
Diffstat (limited to 'src/angular/notifications/services/notifications.service.ts')
-rw-r--r-- | src/angular/notifications/services/notifications.service.ts | 18 |
1 files changed, 6 insertions, 12 deletions
diff --git a/src/angular/notifications/services/notifications.service.ts b/src/angular/notifications/services/notifications.service.ts index 28a645c..8c77e20 100644 --- a/src/angular/notifications/services/notifications.service.ts +++ b/src/angular/notifications/services/notifications.service.ts @@ -3,39 +3,33 @@ import { NotificationSettings } from '../utilities/notification.config' import { Subject } from 'rxjs/Subject'; import { Subscription } from 'rxjs/Subscription'; - @Injectable() export class NotificationsService { - notifs : NotificationSettings[] = []; + notifs: NotificationSettings[] = []; - notifQueue : Subject<any> = new Subject<any>(); + notifQueue: Subject<any> = new Subject<any>(); constructor() {} - public push(notif : NotificationSettings):void{ + public push(notif: NotificationSettings): void { - if( this.notifQueue.observers.length > 0 ) { + if ( this.notifQueue.observers.length > 0 ) { this.notifQueue.next(notif); } else { this.notifs.push(notif); } } - - - public getNotifications() : NotificationSettings[] { + public getNotifications(): NotificationSettings[] { return this.notifs; } - - public subscribe(observer): Subscription { - let s:Subscription = this.notifQueue.subscribe(observer); + const s: Subscription = this.notifQueue.subscribe(observer); this.notifs.forEach(notif => this.notifQueue.next(notif)); this.notifs = []; return s; } - } |