发布订阅模式 #

const fs = require('fs')
const path = require('path')

let events = {
    _obj:{},
    _arr:[], // 订阅中心,将所有的事，都订阅到数组中
    on(callback){
        this._arr.push(callback)
    },
    emit(key,value){ // 事情发生后，来依次触发
        this._obj[key] = value;
        this._arr.forEach(cb => cb(this._obj));
    }
}

// 监控每次触发的逻辑、可以订阅多次

events.on(()=>{
   console.log('读取完毕后机会触发');
})

// 监控所有数据完毕
events.on((data)=>{
  if(Reflect.ownKeys(data).length === 2){
     console.log('数据全部读取完毕');
  }
})


fs.readFile(path.resolve(__dirname,'a.txt','utf-8',function (err,data) {
    events.emit('msg',data);
});

fs.readFile(path.resolve(__dirname,'b.txt','utf-8',function (err,data) {
    events.emit('age',data);
});