Can we do the same functionality with Observable.
- private messageSubject = new Observable
(); - import { Injectable } from '@angular/core';
- import { Observable, Subject } from 'rxjs';
- @Injectable({ providedIn: 'root' })
- export class MessageService {
- private messageSubject = new Subject
(); - sendMessage(dialog: {type: number, message: string}) {
- this.messageSubject.next(dialog);
- }
- clearMessage() {
- this.messageSubject.next();
- }
- getMessage(): Observable
{ - return this.messageSubject.asObservable();
- }
- }
Jignesh KumarPosted Jul 18, 2020, 6:44 AM