diff options
author | Israel Lavi <il0695@att.com> | 2018-08-07 10:54:17 +0300 |
---|---|---|
committer | Israel Lavi <il0695@att.com> | 2018-08-07 11:06:44 +0300 |
commit | b2a3acea0d0f66028c9ce5fad02d4ecc64abf70c (patch) | |
tree | 8d70110f34cb845965c42a5915e950bca967d2c3 /src/angular/notifications/services/notifications.service.ts | |
parent | 05b37297177e8a342668c15e5d6f738b51f7aedd (diff) |
Initial commit.
Adding files needed for Linux Foundation.
Change-Id: I9f2b4851a5ae01f83800c7f8bab8608a2221c730
Issue-ID: SDC-1608
Signed-off-by: Israel Lavi <il0695@att.com>
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; } - } |