/**
 * 發(fā)布-訂閱 實(shí)現(xiàn)
 */

class PubSub {
    constructor (){
        // 訂閱的事件對(duì)象
        this.events = {}
    }
    
    // 發(fā)布
    publish(eventName, ...data){
        if(this.events[eventName]){
            // 遍歷執(zhí)行該事件的所有訂閱 回調(diào)
            this.events[eventName].forEach(cb => {
                // 繼承訂閱的回調(diào)方法，并把發(fā)布的參數(shù)傳過去，同時(shí)執(zhí)行其回調(diào)方法
                cb.call(this, ...data)
            });
        }
    }

    // 訂閱
    substribe(eventName, callback){
        // 可能有多個(gè)地方訂閱同一個(gè)事件，所以每一個(gè)事件對(duì)象用數(shù)組保存
        if(this.events[eventName]){
            this.events[eventName].push(callback)
        }else{
            this.events[eventName] = [callback]
        }
    }

    // 刪除訂閱
    unSubstribe(eventName, callback){
        if(this.events[eventName]){
            this.events[eventName] = this.events[eventName].filter((cb)=>{
                // 在當(dāng)前事件數(shù)組中，剔除出事件回調(diào)和callback相同的訂閱
                return cb !== callback;
            })
        }
    }
}


// 發(fā)布-訂閱  調(diào)用

var pdd = new PubSub();

console.log('start');

// 訂閱回調(diào) 1 
function subCallback(data, name){
    console.log('訂閱到：age=' + data + name)
}

// 訂閱回調(diào) 2
function subCallback2(data, name){
    console.log('訂閱2：age=' + data + name)
}

setTimeout(function(){
    console.log('=====發(fā)布：age => 21=====')
    pdd.publish('age', 21, 'hwb');
},1000)

console.log('訂閱：age')
pdd.substribe('age', subCallback);
pdd.substribe('age', subCallback2);

setTimeout(function(){
    console.log('=====發(fā)布：age => 25=====')
    pdd.publish('age', 25, 'hwb');
},2000)

setTimeout(function(){
    console.log('****移除訂閱subCallback****')
    pdd.unSubstribe('age', subCallback);
},2500)

setTimeout(function(){
    console.log('=====發(fā)布：age => 30=====')
    pdd.publish('age', 30, 'abc');
},3000)