async-pubsub
v1.0.2
Published
async pubsub
Downloads
7
Readme
async-pubsub
- pubsub.js
这里是传统模式观察者模式 实现的只是一种模式,如果开发使用的是异步的操作
- 会导致以下问题:
事件的发布Publish时,为了不阻断进程使用setTimeout重新开启了一个进程,在一定场景下提升了性能. 造成的问题:
使用观察者模式,开发者使用的肯定是同步式的写法,并没有开启异步回调。
所以当发布一个事件之后在短时间内取消了这个订阅。会导致在事件的发布过程中就被扼杀掉。
pubsub.subscribe('sayName',function () {
console.log('my name is caozheng');
});
pubsub.publish('sayName');
pubsub.unTopic('sayName');
// 理想的结果是输出: my name is caozheng
// 再将sayName订阅的事件给杀掉
// 然而因为publish的时候使用的是setTimeout异步处理
// 结果没有输出的时候就被unTopic杀掉了
- 处理方案: (将使用第二种方案)
1、 观察者模式不变,改变开发者写法。
开发者将使用async await、promise、co等异步转同步的写法。 从而解决publish的时候被unTopic/unSubscribe给杀掉
2、改变观察者模式转换成异步写法 async pubsub 观察者模式监听观察者模式直到publish事件之后,才能被杀掉。 开发者依然可以使用同步写法
理想实现写法与之前相同 asyncPubsub.js
asyncPubsub.subscribe('sayName',function () { console.log('my name is caozheng'); }); asyncPubsub.publish('sayName'); asyncPubsub.unTopic('sayName'); // 输出: my name is caozheng