rxjs-subject.js

 
import { Subject } from 'rxjs'
const notificationSubject = new Subject()
// Subject is also an Observable
const notificationObservable = notificationSubject.asObservable()
 
const publishNotification = (value) => {
 // multicasts a value onto the stream
 notificationSubject.next(value)
}
 
export { notificationObservable, publishNotification }