RXJS EventAggregator

import { Subject, Observable } from 'rxjs';

class EventAggregator {
    constructor() {
        this.subject = new Subject(); // Can be ReplaySubject too
    }

    publish(type, data) {
        this.subject.onNext({ type, data });
    }

    listen(type) {
        return this.subject.filter(x => x.type === type).pluck('data').share();
    }

    dispose() {
        this.subject.dispose();
    }
}

export default new EventAggregator();