JS event aggregator

EventAggregator.js

import * as Rx from 'rx';

const kSubject = Symbol('subject');

export default class EventAggregator {
  constructor(){
    this[kSubject] = new Rx.Subject();
  }

  publish(event, payload){
    this[kSubject].onNext({ payload, event });
  }

  suscribe(event, handler){
    this[kSubject]
      .filter(p => p.event === event)
      .map(p => p.payload)
      .forEach(handler);
  }

  dispose(){
    this[kSubject].dispose();
  }
}