my-service.service.ts 411 B

123456789101112131415161718192021
  1. import { Injectable } from '@angular/core';
  2. import { Subject, Observable } from 'rxjs';
  3. @Injectable({
  4. providedIn: 'root'
  5. })
  6. export class MyServiceService {
  7. public constructor() { }
  8. private subject = new Subject<any>();
  9. sendMsg(data) {
  10. let that = this;
  11. setTimeout(() => {
  12. that.subject.next(data);
  13. }, 1);
  14. }
  15. getMsg(): Observable<any> {
  16. return this.subject.asObservable();
  17. }
  18. }