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('发送数据');
上一篇: ESP8266 AP模式TCP server 串口透传
下一篇: 动态规划----最大子序和
推荐阅读
-
rxjs订阅发布实现数据通信
-
在PHP中如何使用RabbitMQ来实现消息的订阅和发布?
-
利用Spring Data Redis 来实现消息的发布订阅机制
-
Springboot2 之 Spring Data Redis 实现消息队列——发布/订阅模式
-
Java实现redis消息订阅/发布(PubSub)
-
【Springboot+Redis】Springboot+Redis实现消息队列(生产者/消费者、发布订阅模式)
-
redis实现消息队列(发布/订阅模式)
-
【困难版】如何实现一个类vue的双向绑定——Vue2.0 | MVVM | 数据劫持+发布订阅
-
C#订阅与发布标准实现
-
C#利用RabbitMQ实现消息订阅与发布