Pub Sub pattern with RxJS

rxjs_event_emitter.js

// Reference from: https://github.com/Reactive-Extensions/RxJS/blob/master/doc/howdoi/eventemitter.md

var hasOwnProp = {}.hasOwnProperty;

function createName (name) {
    return '$' + name;
}

function Emitter() {
    this.subjects = {};
}

Emitter.prototype.emit = function (name, data) {
    var fnName = createName(name);
    this.subjects[fnName] || (this.subjects[fnName] = new Rx.Subject());
    this.subjects[fnName].onNext(data);
};

Emitter.prototype.listen = function (name, handler) {
    var fnName = createName(name);
    this.subjects[fnName] || (this.subjects[fnName] = new Rx.Subject());
    return this.subjects[fnName].subscribe(handler);
};

Emitter.prototype.dispose = function () {
    var subjects = this.subjects;
    for (var prop in subjects) {
        if (hasOwnProp.call(subjects, prop)) {
            subjects[prop].dispose();
        }
    }

    this.subjects = {};
};

var emitter = new Emitter();

var subcription = emitter.listen('data', function (data) {
    console.log('data: ' + data);
});

emitter.emit('data', 'foo');
// => data: foo

// Destroy the subscription
subscription.dispose();