From 1994c98063c27a41797dec01f2ca9fcbe33ceab0 Mon Sep 17 00:00:00 2001
From: Israel Lavi <israel.lavi@intl.att.com>
Date: Mon, 21 May 2018 17:42:00 +0300
Subject: init commit onap ui

Change-Id: I1dace78817dbba752c550c182dfea118b4a38646
Issue-ID: SDC-1350
Signed-off-by: Israel Lavi <il0695@att.com>
---
 .../services/notifications.service.ts              | 41 ++++++++++++++++++++++
 1 file changed, 41 insertions(+)
 create mode 100644 src/angular/notifications/services/notifications.service.ts

(limited to 'src/angular/notifications/services/notifications.service.ts')

diff --git a/src/angular/notifications/services/notifications.service.ts b/src/angular/notifications/services/notifications.service.ts
new file mode 100644
index 0000000..28a645c
--- /dev/null
+++ b/src/angular/notifications/services/notifications.service.ts
@@ -0,0 +1,41 @@
+import { Injectable } from '@angular/core';
+import { NotificationSettings } from '../utilities/notification.config'
+import { Subject } from 'rxjs/Subject';
+import { Subscription } from 'rxjs/Subscription';
+
+
+@Injectable()
+export class NotificationsService  {
+
+    notifs : NotificationSettings[] = [];
+
+    notifQueue : Subject<any> = new Subject<any>();
+
+    constructor() {}
+
+    public push(notif : NotificationSettings):void{
+
+        if( this.notifQueue.observers.length > 0 ) {
+            this.notifQueue.next(notif);
+        } else {
+            this.notifs.push(notif);
+        }
+    }
+
+
+
+    public getNotifications() : NotificationSettings[] {
+        return this.notifs;
+    }
+
+
+
+    public subscribe(observer): Subscription {
+        let s:Subscription = this.notifQueue.subscribe(observer);
+        this.notifs.forEach(notif => this.notifQueue.next(notif));
+        this.notifs = [];
+        return s;
+    }
+
+
+}
-- 
cgit 1.2.3-korg