1
Answer

Can we use next() method with Observable

Mohammad Irshad

Mohammad Irshad
4y
865
1
Can we do the same functionality with Observable.
  1. private messageSubject = new Observable<any>();  
  2. import { Injectable } from '@angular/core';  
  3. import { Observable, Subject } from 'rxjs';  
  4. @Injectable({ providedIn: 'root' })  
  5. export class MessageService {  
  6. private messageSubject = new Subject<any>();  
  7. sendMessage(dialog: {type: number, message: string}) {  
  8. this.messageSubject.next(dialog);  
  9. }  
  10. clearMessage() {  
  11. this.messageSubject.next();  
  12. }  
  13. getMessage(): Observable<any> {  
  14. return this.messageSubject.asObservable();  
  15. }  
  16. }  
Answers (1)
Next Recommended Forum