与 Object.create() 的参数一起使用可创建一个不从 Object.prototype继承属性的空对象 null 。
对于emit,根据参数 Array.prototype.forEach() 解析处理程序数组,然后通过将数据作为参数传递来event运行每个处理程序。
对于on,如果事件尚不存在,则为该事件创建一个数组,然后用Array.prototype.push()添加处理程序到数组。
对于off,使用Array.prototype.findIndex()在事件数组中查找处理程序的索引并使用 Array.prototype.splice() 删除它。
JavaScript
const createEventHub = () => ({
hub: Object.create(null),
emit(event, data) {
(this.hub[event] || []).forEach(handler => handler(data));
},
on(event, handler) {
if (!this.hub[event]) this.hub[event] = [];
this.hub[event].push(handler);
},
off(event, handler) {
const i = (this.hub[event] || []).findIndex(h => h === handler);
if (i > -1) this.hub[event].splice(i, 1);
if (this.hub[event].length === 0) delete this.hub[event];
}
});
示例:
const handler = data => console.log(data);
const hub = createEventHub();
let increment = 0;
//订阅:监听不同类型的事件
hub.on('message', handler);
hub.on('message', () => console.log('Message event fired'));
hub.on('increment', () => increment++);
// 发布:发出事件以调用所有订阅它们的处理程序,将数据作为参数传递给它们
hub.emit('message', 'hello world'); // 记录“hello world”和“消息事件触发”
hub.emit('message', { hello: 'world' }); // l记录对象和“触发消息事件”
hub.emit('increment'); // `increment` 变量现在是 1
// 取消订阅:停止特定处理程序侦听“消息”事件
hub.off('message', handler);
更多内容请访问我的网站:https://www.icoderoad.com