Hopiu/postal.js
1
0
Fork 0
mirror of https://github.com/Hopiu/postal.js.git synced 2026-03-16 22:20:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Starting consolidation and perf improvements, hopefully

Browse source
This commit is contained in:
Jim Cowart 2012-02-26 22:37:33 -05:00
parent 86713585e8
commit 5946df996f
1 changed files with 8 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/main/LocalBus.js
View file

@ -22,30 +22,24 @@ var localBus = {
},
subscribe: function(subDef) {
var idx, found, fn;
var idx, found, fn, exch, subs;
if(!this.subscriptions[subDef.exchange]) {
this.subscriptions[subDef.exchange] = {};
}
if(!this.subscriptions[subDef.exchange][subDef.topic]) {
this.subscriptions[subDef.exchange][subDef.topic] = [];
}
exch = this.subscriptions[subDef.exchange] = this.subscriptions[subDef.exchange] || {};
subs = this.subscriptions[subDef.exchange][subDef.topic] = this.subscriptions[subDef.exchange][subDef.topic] || [];
idx = this.subscriptions[subDef.exchange][subDef.topic].length - 1;
if(!_.any(this.subscriptions[subDef.exchange][subDef.topic], function(cfg) { return cfg === subDef; })) {
idx = subs.length - 1;
if(!_.any(subs, function(cfg) { return cfg === subDef; })) {
for(; idx >= 0; idx--) {
if(this.subscriptions[subDef.exchange][subDef.topic][idx].priority <= subDef.priority) {
this.subscriptions[subDef.exchange][subDef.topic].splice(idx + 1, 0, subDef);
if(subs[idx].priority <= subDef.priority) {
subs.splice(idx + 1, 0, subDef);
found = true;
break;
}
}
if(!found) {
this.subscriptions[subDef.exchange][subDef.topic].unshift(subDef);
subs.unshift(subDef);
}
}
return _.bind(function() { this.unsubscribe(subDef); }, this);
},
notifyTaps: function(data, envelope) {