Skip to content

Instantly share code, notes, and snippets.

View bangedorrunt's full-sized avatar

bangedorrunt ヽ(ヅ)ノ bangedorrunt

  • Melbourne, Australia
View GitHub Profile
var Rx = require('rx');
function EventAggregator() {
this._subject = new Rx.Subject(); // Can be ReplaySubject too
}
EventAggregator.prototype.publish = function (type, data) {
this._subject.onNext( { type: type, data: data });
};