message-buss

messageBus.js

class messageBus {
  constructor() {
    this.subscribers = {};  
  }
  
  subscribe(topic, cb) {
    if (this.subscribers[topic]) {
      this.subscribers[topic].push(cb)
    } else {
      this.subscribers[topic] = [cb];
    }
  }
  
  publish(topic, payload) {
    if(this.subscribers[topic]) {
      for(var i = 0; i < this.subscribers[topic].length; i++) {
        this.subscribers[topic][i](payload);
      }
    }
  }
}

const mb = new messageBus;

const componentA = () => {
  mb.subscribe('new_signup', function(payload) {
  	console.log(payload);
  });
}

const componentB = () => {
  mb.publish('new_signup', {'foo': 'bar', 'goo': 'gar'});
}

componentA();
componentB();