欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

rxjs订阅发布实现数据通信

程序员文章站 2024-03-23 09:36:52
...
import { Observable, Subject } from 'rxjs';

export default class MsgService {

  private static subject = new Subject<any>();

  static getObserver(): Observable<any> {
    return this.subject.asObservable();
  }

  static send(data: any) {
    this.subject.next(data);
  }

}


MsgService.getObserver().subscribe((data: any) => {
  console.log('msgService', data);
});

MsgService.getObserver().subscribe((data: any) => {
  console.log('msgService', data);
});

MsgService.send('发送数据');