From b9f574449e68b360f6ea931d4201913dd6ef0490 Mon Sep 17 00:00:00 2001 From: Jim Cowart Date: Tue, 20 Mar 2012 02:10:23 -0400 Subject: [PATCH] Updated Version Header to v0.4.4 --- example/amd/js/libs/postal/postal.js | 28 ++++++++++++++---- example/standard/js/postal.js | 28 ++++++++++++++---- lib/browser/amd/postal.diagnostics.min.gz.js | Bin 243 -> 243 bytes lib/browser/amd/postal.js | 28 ++++++++++++++---- lib/browser/amd/postal.min.gz.js | Bin 1535 -> 1602 bytes lib/browser/amd/postal.min.js | 2 +- .../standard/postal.diagnostics.min.gz.js | Bin 220 -> 220 bytes lib/browser/standard/postal.js | 28 ++++++++++++++---- lib/browser/standard/postal.min.gz.js | Bin 1518 -> 1584 bytes lib/browser/standard/postal.min.js | 2 +- lib/node/postal.js | 28 ++++++++++++++---- src/main/VersionHeader.js | 2 +- 12 files changed, 118 insertions(+), 28 deletions(-) diff --git a/example/amd/js/libs/postal/postal.js b/example/amd/js/libs/postal/postal.js index 62f4dad..9754406 100644 --- a/example/amd/js/libs/postal/postal.js +++ b/example/amd/js/libs/postal/postal.js @@ -3,12 +3,13 @@ define(['underscore'], function(_) { postal.js Author: Jim Cowart License: Dual licensed MIT (http://www.opensource.org/licenses/mit-license) & GPL (http://www.opensource.org/licenses/gpl-license) - Version 0.4.0 + Version 0.4.4 */ var DEFAULT_EXCHANGE = "/", DEFAULT_PRIORITY = 50, DEFAULT_DISPOSEAFTER = 0, + SYSTEM_EXCHANGE = "postal", NO_OP = function() { }, parsePublishArgs = function(args) { var parsed = { envelope: { } }, env; @@ -90,11 +91,24 @@ var SubscriptionDefinition = function(exchange, topic, callback) { this.maxCalls = DEFAULT_DISPOSEAFTER; this.onHandled = NO_OP; this.context = null; + + postal.publish(SYSTEM_EXCHANGE, "subscription.created", + { + event: "subscription.created", + exchange: exchange, + topic: topic + }); }; SubscriptionDefinition.prototype = { unsubscribe: function() { postal.configuration.bus.unsubscribe(this); + postal.publish(SYSTEM_EXCHANGE, "subscription.removed", + { + event: "subscription.removed", + exchange: this.exchange, + topic: this.topic + }); }, defer: function() { @@ -226,9 +240,7 @@ var localBus = { wireTaps: [], publish: function(data, envelope) { - _.each(this.wireTaps,function(tap) { - tap(data, envelope); - }); + this.notifyTaps(data, envelope); _.each(this.subscriptions[envelope.exchange], function(topic) { _.each(topic, function(binding){ @@ -271,6 +283,12 @@ var localBus = { return _.bind(function() { this.unsubscribe(subDef); }, this); }, + notifyTaps: function(data, envelope) { + _.each(this.wireTaps,function(tap) { + tap(data, envelope); + }); + }, + unsubscribe: function(config) { if(this.subscriptions[config.exchange][config.topic]) { var len = this.subscriptions[config.exchange][config.topic].length, @@ -322,7 +340,7 @@ var postal = { }, addWireTap: function(callback) { - this.configuration.bus.addWireTap(callback); + return this.configuration.bus.addWireTap(callback); } }; diff --git a/example/standard/js/postal.js b/example/standard/js/postal.js index 9894230..2bc5ebc 100644 --- a/example/standard/js/postal.js +++ b/example/standard/js/postal.js @@ -3,12 +3,13 @@ postal.js Author: Jim Cowart License: Dual licensed MIT (http://www.opensource.org/licenses/mit-license) & GPL (http://www.opensource.org/licenses/gpl-license) - Version 0.4.0 + Version 0.4.4 */ var DEFAULT_EXCHANGE = "/", DEFAULT_PRIORITY = 50, DEFAULT_DISPOSEAFTER = 0, + SYSTEM_EXCHANGE = "postal", NO_OP = function() { }, parsePublishArgs = function(args) { var parsed = { envelope: { } }, env; @@ -90,11 +91,24 @@ var SubscriptionDefinition = function(exchange, topic, callback) { this.maxCalls = DEFAULT_DISPOSEAFTER; this.onHandled = NO_OP; this.context = null; + + postal.publish(SYSTEM_EXCHANGE, "subscription.created", + { + event: "subscription.created", + exchange: exchange, + topic: topic + }); }; SubscriptionDefinition.prototype = { unsubscribe: function() { postal.configuration.bus.unsubscribe(this); + postal.publish(SYSTEM_EXCHANGE, "subscription.removed", + { + event: "subscription.removed", + exchange: this.exchange, + topic: this.topic + }); }, defer: function() { @@ -226,9 +240,7 @@ var localBus = { wireTaps: [], publish: function(data, envelope) { - _.each(this.wireTaps,function(tap) { - tap(data, envelope); - }); + this.notifyTaps(data, envelope); _.each(this.subscriptions[envelope.exchange], function(topic) { _.each(topic, function(binding){ @@ -271,6 +283,12 @@ var localBus = { return _.bind(function() { this.unsubscribe(subDef); }, this); }, + notifyTaps: function(data, envelope) { + _.each(this.wireTaps,function(tap) { + tap(data, envelope); + }); + }, + unsubscribe: function(config) { if(this.subscriptions[config.exchange][config.topic]) { var len = this.subscriptions[config.exchange][config.topic].length, @@ -322,7 +340,7 @@ var postal = { }, addWireTap: function(callback) { - this.configuration.bus.addWireTap(callback); + return this.configuration.bus.addWireTap(callback); } }; diff --git a/lib/browser/amd/postal.diagnostics.min.gz.js b/lib/browser/amd/postal.diagnostics.min.gz.js index 3a59cdd56302213c9147e97be5179dced6d3a17a..998adf4099a95e2c1db416b7520d56c6dccb9427 100644 GIT binary patch delta 15 Wcmey&_?eMizMF%gRW4&9`x^i$WCbw* delta 15 Wcmey&_?eMizMF$#<#DZv>~8=pkp;j2 diff --git a/lib/browser/amd/postal.js b/lib/browser/amd/postal.js index 62f4dad..9754406 100644 --- a/lib/browser/amd/postal.js +++ b/lib/browser/amd/postal.js @@ -3,12 +3,13 @@ define(['underscore'], function(_) { postal.js Author: Jim Cowart License: Dual licensed MIT (http://www.opensource.org/licenses/mit-license) & GPL (http://www.opensource.org/licenses/gpl-license) - Version 0.4.0 + Version 0.4.4 */ var DEFAULT_EXCHANGE = "/", DEFAULT_PRIORITY = 50, DEFAULT_DISPOSEAFTER = 0, + SYSTEM_EXCHANGE = "postal", NO_OP = function() { }, parsePublishArgs = function(args) { var parsed = { envelope: { } }, env; @@ -90,11 +91,24 @@ var SubscriptionDefinition = function(exchange, topic, callback) { this.maxCalls = DEFAULT_DISPOSEAFTER; this.onHandled = NO_OP; this.context = null; + + postal.publish(SYSTEM_EXCHANGE, "subscription.created", + { + event: "subscription.created", + exchange: exchange, + topic: topic + }); }; SubscriptionDefinition.prototype = { unsubscribe: function() { postal.configuration.bus.unsubscribe(this); + postal.publish(SYSTEM_EXCHANGE, "subscription.removed", + { + event: "subscription.removed", + exchange: this.exchange, + topic: this.topic + }); }, defer: function() { @@ -226,9 +240,7 @@ var localBus = { wireTaps: [], publish: function(data, envelope) { - _.each(this.wireTaps,function(tap) { - tap(data, envelope); - }); + this.notifyTaps(data, envelope); _.each(this.subscriptions[envelope.exchange], function(topic) { _.each(topic, function(binding){ @@ -271,6 +283,12 @@ var localBus = { return _.bind(function() { this.unsubscribe(subDef); }, this); }, + notifyTaps: function(data, envelope) { + _.each(this.wireTaps,function(tap) { + tap(data, envelope); + }); + }, + unsubscribe: function(config) { if(this.subscriptions[config.exchange][config.topic]) { var len = this.subscriptions[config.exchange][config.topic].length, @@ -322,7 +340,7 @@ var postal = { }, addWireTap: function(callback) { - this.configuration.bus.addWireTap(callback); + return this.configuration.bus.addWireTap(callback); } }; diff --git a/lib/browser/amd/postal.min.gz.js b/lib/browser/amd/postal.min.gz.js index 3d4deb99247114f1cceb05b6f205c357f74e5f81..dfbf9043fc1bebb6d416171cfb116d49babdfec2 100644 GIT binary patch literal 1602 zcmV-I2EF+oiwFRP9%xSh1HD*VZ`(E${ws<$q+&y>cDp@HDpwS3hrO&V)?fqXdH_XI zmqeB{iE`p9`tLi`m9pi=*nmFSB9G4b_?;`og&!rtTAO9UMP9Hp7v={0Wx`~XCKg52 zj^>6(%x5NMx{JzjK;A? z*)0j$=PZxXJd%6Dy8SdMWKN?*7G%9?*S7Tj4ZKzm-aeI?bz{ZRJ%92yUS$8;i#J9O%rWm0DT2uF1G3J zB*0R7%Pfug>Q!Fw^W9PsMB#5iXH{< zm%O_dtd!!A@e4)yFXLLr_#a1XKbhC}M5DV`ZJyx5>yb@RpNZ&WE_g$RF{b;YwzbLt z38X3!n#E8|K#Z}Ww~5zzPWP~Vc?mU>GF8>|y3G!qK~aq`8!RbrPYV43&ZZbq4c%Me zr64X&=SauQZ&3`DL4Xck90mU*(!ZX))aISZw%h4YV!HokICPS`ZEIXq)FPfjN|gYDmQ_-DWh`X9wH@>$HK`+S|Zr zsz0vj2DL^nmK`EhGkzDryZg*C|2D50@mvJrKJxeAfh+TS6G{_dHk2U=r|m)W%gd>$ zhllAiscM7|t&@u-XsdB=VJ;&m*w11LVfgH`{Vc%d=g+o@w8f`t(SEA0eW#YzuNQw| zy7+>Zi=Q^I4dYonj9E=TEEIEhQ7*1&RyZ&#%#TJ5>Lir_Pzg4RxXb!xZ=!R}hJLEu zN;s;zH~3`nu;1sRNaLNz?arYv&bKojYk!-11F-??S~bISyn%OWG+ajb7*fO>$|HDf z+~^t-AG*;RPPzdHjYZo+pi@l+Gs8iHb}xa z2sN0TDcxQ67Av=HLp0f+YiQOV>MBtqRQYLcx$I}MblGBo`V@U!=^7yQHR&bshW}lF zo^hZ;4G>UAu2#(m26+s5-(0?G{_t?F7MOX$$XCf<4=MWSaMTZc@H1x8L7wR;)o0~| zN!rM%@SB~U=~(cl$DrCVXm^bMYIUY~7Yqk>49r{*vRHL(Vi4$ncmPB}*h1gY zi&-7!&Y}&4Ow8V!MlpnruJHc zO}s?ltph{HpF^-X_!xp*f4mX)pF}h%bXMFP-#o{c)cjfxUm0rjFAvMAXoV91058lF AP5=M^ literal 1535 zcmVcDsF;6s{=R4EwUSSc46i>j4x= zNlau(lc*%FqyN66UMWXuj14IK!4`SC=i%M)Ud%-(Q{k-bD&?XmSyl*pgTpFiN@l4; z(f)=ORzU0*HfH3*WSk zbGl11%86DEoJTR^4MIVa5-E2C)@TTMvnZX)2SBSS5Ge42LeOi!Io}W7|I&3F=~n|L z7a^?@<^6Xv)rC-1ky^aQk?G_n2>fpIp|?*~{T_8?`AHQrjbIlXMi?Q09T27sOZ4`| zKNU?Jh64o4)MZHq0mu--Cmcd09$_hn>{Tqw@e~v{&n^F;_G33MGL`9YA^WllN><1~ zcn{+@6}OgjCdv#|n4OtC-%bO*DcmQFq$L*W!EHZpYuXy zg;YDjy8SFIRY7H{O0wRxYg>Bv7G5g}Z=bXDSDNxfa3Y466dawTRg%=cG#yi=Gp<4V zxf2?qjki#ZA*w~;9RwpKlaut`J2>9pAG9xpx&+H-l>$30A+qX*HmH|no|WQFs7w@i zLxzqH*Z1^2Jl)?1=VXagTx7TQWh|^4npDDqL*7U(xTP}7RAf25y^yu7N@WGYqE=dM z1K5k;vT7Lx94HT13@Wfa4M7&R`=MrBE2&Re2&AP%lkym^hH+|9xH{)R%$;cwW3Cc!o(E8Y=(I=Vp zf-|g4218ml1N9O#D3yFmH>eKMa6?;rt_ZYoEY>|9X4y8Ug;{!WORUodV(VZ7ot^o( zrW@3Po-8{?I%oVYqKmuSvH!Nu8u3Cz;!cJ;@W7ei&NE zO!hUxhv?*F3EFDhBh1|h3ix?KAq-!9c3(u;{`}dsk+Jw(FS^goweR%O`px1mOc!79 za`Dp!wxPSZ9=eoVqmMVEEnjCr2Ep z)LjK6m$OyVm%-(RWY7#WHNU?hO({@=0_`aD zqsEcqog=~XOTRV#dEm3NGju#6*dE+RXH7i|*_#@#x{` z@Zo4krea`sarXg=62P1gvRHL_e-P-11VBVnNT86I3CG*REZ|+^KJR!}P+;INsYuKM zGY(yS*V-8stn%_T^#T~6XSbL~`?{g)jZS}JK79ZP%vuf1tgcrLOgO&Kn>KmV88Gn@2J7em=;7Z3SRDL0fc$8f lHbwszfgyz+jhnuKJQ(aoY2As|!?<0ee*qsBn(TuT007Jq;phMW diff --git a/lib/browser/amd/postal.min.js b/lib/browser/amd/postal.min.js index 3419f72..c027241 100644 --- a/lib/browser/amd/postal.min.js +++ b/lib/browser/amd/postal.min.js @@ -1 +1 @@ -define(["underscore"],function(a){var b="/",c=50,d=0,e=function(){},f=function(c){var d={envelope:{}},e;switch(c.length){case 3:typeof c[1]=="Object"&&typeof c[2]=="Object"?(d.envelope.exchange=b,d.envelope.topic=c[0],d.payload=c[1],e=d.envelope,d.envelope=a.extend(e,c[2])):(d.envelope.exchange=c[0],d.envelope.topic=c[1],d.payload=c[2]);break;case 4:d.envelope.exchange=c[0],d.envelope.topic=c[1],d.payload=c[2],e=d.envelope,d.envelope=a.extend(e,c[3]);break;default:d.envelope.exchange=b,d.envelope.topic=c[0],d.payload=c[1]}return d},g=function(){var b;return function(c){var d=!1;return a.isString(c)?(d=c===b,b=c):(d=a.isEqual(c,b),b=a.clone(c)),!d}},h=function(a,b){this.exchange=a,this.topic=b};h.prototype={subscribe:function(a){var b=new i(this.exchange,this.topic,a);return l.configuration.bus.subscribe(b),b},publish:function(b,c){var d=a.extend({exchange:this.exchange,timeStamp:new Date,topic:this.topic},c);l.configuration.bus.publish(b,d)}};var i=function(a,b,f){this.exchange=a,this.topic=b,this.callback=f,this.priority=c,this.constraints=[],this.maxCalls=d,this.onHandled=e,this.context=null};i.prototype={unsubscribe:function(){l.configuration.bus.unsubscribe(this)},defer:function(){var a=this.callback;return this.callback=function(b){setTimeout(a,0,b)},this},disposeAfter:function(b){if(a.isNaN(b)||b<=0)throw"The value provided to disposeAfter (maxCalls) must be a number greater than zero.";var c=this.onHandled,d=a.after(b,a.bind(function(){this.unsubscribe(this)},this));return this.onHandled=function(){c.apply(this.context,arguments),d()},this},ignoreDuplicates:function(){return this.withConstraint(new g),this},whenHandledThenExecute:function(b){if(!a.isFunction(b))throw"Value provided to 'whenHandledThenExecute' must be a function";return this.onHandled=b,this},withConstraint:function(b){if(!a.isFunction(b))throw"Predicate constraint must be a function";return this.constraints.push(b),this},withConstraints:function(b){var c=this;return a.isArray(b)&&a.each(b,function(a){c.withConstraint(a)}),c},withContext:function(a){return this.context=a,this},withDebounce:function(b){if(a.isNaN(b))throw"Milliseconds must be a number";var c=this.callback;return this.callback=a.debounce(c,b),this},withDelay:function(b){if(a.isNaN(b))throw"Milliseconds must be a number";var c=this.callback;return this.callback=function(a){setTimeout(c,b,a)},this},withPriority:function(b){if(a.isNaN(b))throw"Priority must be a number";return this.priority=b,this},withThrottle:function(b){if(a.isNaN(b))throw"Milliseconds must be a number";var c=this.callback;return this.callback=a.throttle(c,b),this}};var j={cache:{},compare:function(a,b){if(this.cache[b]&&this.cache[b][a])return!0;var c=new RegExp("^"+this.regexify(a)+"$"),d=c.test(b);return d&&(this.cache[b]||(this.cache[b]={}),this.cache[b][a]=!0),d},regexify:function(a){return a.replace(/\./g,"\\.").replace(/\*/g,".*").replace(/#/g,"[A-Z,a-z,0-9]*")}},k={subscriptions:{},wireTaps:[],publish:function(b,c){a.each(this.wireTaps,function(a){a(b,c)}),a.each(this.subscriptions[c.exchange],function(d){a.each(d,function(d){l.configuration.resolver.compare(d.topic,c.topic)&&a.all(d.constraints,function(a){return a(b)})&&typeof d.callback=="function"&&(d.callback.apply(d.context,[b,c]),d.onHandled())})})},subscribe:function(b){var c,d,e;this.subscriptions[b.exchange]||(this.subscriptions[b.exchange]={}),this.subscriptions[b.exchange][b.topic]||(this.subscriptions[b.exchange][b.topic]=[]),c=this.subscriptions[b.exchange][b.topic].length-1;if(!a.any(this.subscriptions[b.exchange][b.topic],function(a){return a===b})){for(;c>=0;c--)if(this.subscriptions[b.exchange][b.topic][c].priority<=b.priority){this.subscriptions[b.exchange][b.topic].splice(c+1,0,b),d=!0;break}d||this.subscriptions[b.exchange][b.topic].unshift(b)}return a.bind(function(){this.unsubscribe(b)},this)},unsubscribe:function(a){if(this.subscriptions[a.exchange][a.topic]){var b=this.subscriptions[a.exchange][a.topic].length,c=0;for(;c=0;c--)if(this.subscriptions[b.exchange][b.topic][c].priority<=b.priority){this.subscriptions[b.exchange][b.topic].splice(c+1,0,b),d=!0;break}d||this.subscriptions[b.exchange][b.topic].unshift(b)}return a.bind(function(){this.unsubscribe(b)},this)},notifyTaps:function(b,c){a.each(this.wireTaps,function(a){a(b,c)})},unsubscribe:function(a){if(this.subscriptions[a.exchange][a.topic]){var b=this.subscriptions[a.exchange][a.topic].length,c=0;for(;c{kIP@CAAR diff --git a/lib/browser/standard/postal.js b/lib/browser/standard/postal.js index 9894230..2bc5ebc 100644 --- a/lib/browser/standard/postal.js +++ b/lib/browser/standard/postal.js @@ -3,12 +3,13 @@ postal.js Author: Jim Cowart License: Dual licensed MIT (http://www.opensource.org/licenses/mit-license) & GPL (http://www.opensource.org/licenses/gpl-license) - Version 0.4.0 + Version 0.4.4 */ var DEFAULT_EXCHANGE = "/", DEFAULT_PRIORITY = 50, DEFAULT_DISPOSEAFTER = 0, + SYSTEM_EXCHANGE = "postal", NO_OP = function() { }, parsePublishArgs = function(args) { var parsed = { envelope: { } }, env; @@ -90,11 +91,24 @@ var SubscriptionDefinition = function(exchange, topic, callback) { this.maxCalls = DEFAULT_DISPOSEAFTER; this.onHandled = NO_OP; this.context = null; + + postal.publish(SYSTEM_EXCHANGE, "subscription.created", + { + event: "subscription.created", + exchange: exchange, + topic: topic + }); }; SubscriptionDefinition.prototype = { unsubscribe: function() { postal.configuration.bus.unsubscribe(this); + postal.publish(SYSTEM_EXCHANGE, "subscription.removed", + { + event: "subscription.removed", + exchange: this.exchange, + topic: this.topic + }); }, defer: function() { @@ -226,9 +240,7 @@ var localBus = { wireTaps: [], publish: function(data, envelope) { - _.each(this.wireTaps,function(tap) { - tap(data, envelope); - }); + this.notifyTaps(data, envelope); _.each(this.subscriptions[envelope.exchange], function(topic) { _.each(topic, function(binding){ @@ -271,6 +283,12 @@ var localBus = { return _.bind(function() { this.unsubscribe(subDef); }, this); }, + notifyTaps: function(data, envelope) { + _.each(this.wireTaps,function(tap) { + tap(data, envelope); + }); + }, + unsubscribe: function(config) { if(this.subscriptions[config.exchange][config.topic]) { var len = this.subscriptions[config.exchange][config.topic].length, @@ -322,7 +340,7 @@ var postal = { }, addWireTap: function(callback) { - this.configuration.bus.addWireTap(callback); + return this.configuration.bus.addWireTap(callback); } }; diff --git a/lib/browser/standard/postal.min.gz.js b/lib/browser/standard/postal.min.gz.js index 799945fe4b8e83def7201558f01e3f73ee646dba..8bd21feb75c82a385ceced6485d4a695145d7595 100644 GIT binary patch literal 1584 zcmV-02G98)iwFRO9%xSh1HD*nZ`(Ey{ws<$q+-LUPP=`WRIVu64*RmUSc46i>jfl5 zSxRI|lPD*tqyN66UTDgZ6L$mpDbewGcYN;MUR+DA(p-8JGqhRL(&5B?=HiI_IKzU> za7^4HuN2K(yd;JjZ5o_xKWTTBk&TdRk>!O5Hcf-0u)0naPdw^pLM~N;Hk?+%c@e1F zLgcYS=VuE-+z;$haOEB!8}f6D{K{kgAl4T*JfU(a2*(yxe7)B|bGpyFyRJk~{X{Iv zU^kn{$Q48Qjs0V1S|!vugic;7aP$l!q-k*n@o5ExS-g&wtpy@KjXj-j@9BH^y1Sz< z$qcEa%&*<^L^x}j)xrTh*J&goN9B$!$nge;BWG1t%3;Exj;vP<&X%p0N-&m6=Zh$F z-wnGo8;1tg=|HtOF!{n~DWru3L(6>6HQloi8X>ZcHtRm~X;Eaio*jOemdknteghwK z&tQ};WnPN6b&;hUOs{Nj*m|H#C2vghdpbi?)XTU|#9#&BC*R!&UMsPS_>qSEmo2SF z{EvHRKbe;I#DaSe?e4*X4wj9qKG33%rHEQEoNc;4s@tjzkU+W;p-CI6i4v^&>^AYb zEa@#AA0I=_qE=?`b`g&*}QyKZNjlF{35W{1(kM^yxD(rv^t>to*s9<^*>oUqEa!1NW{4d)<1 zsq9<2LG>yvH+0Q2BQS^ZL=UN$=c|I2VyCHtVZAh9o3jOsruOHYE>NfRXcl$@fUX(8 zi{-nU!gK$2Pg?d;EX7S4>u5i5zjqM~cHDFQtGc@zf0Ipv@UC`pGy`c3 z9yCm41O@#?Mj;HJefFO%vHSV6?;?x%R1^KDHtjo2n!i5%3)9mtcy{{J0*+xkTbVJd z?T3{{?m8{SIW4LHW`*g|sI^+=3JlbYEfM!w-=2+R&Y9__3v35(e}j*RyZyctRi3Ry z>Guxxct7K@?r&RfAU1$*RWoe2+F=N8OO9Da_%@`7Ysw>dZF|r+ByPIV9A3JBPP8rB z9s-$qDtKU8#T+)K30&wFmmxUzGHjz|FAMzNBJ#K}!wKUc)L?QTcfahNo`qc-qVo1o zMU(!}t3-p)CeBMQWIvNx$WBkukfM(Zg_JQh=_R4&|2{wucu=JW2&f|`XE1_6ErHc% z)-7KRzq>nB3d}r78n+$I^utGoBRWh*4c=zbPM+B*HDu)|S$NB*!*6nWrrUz|_%rOj zet0kdWV5h!Ab-h1esc0P{(}I75cq0$aeUUV$PJV*8byD0*z6r22JFm?vopN+k2Y-J zJ8|jfl5 zy(F@vNmLxy(SP4jFEr)Ijk^JbKiE2+?vBqLpF7$K>x|1J&m4*w+TPOA;>3Ptxw%b(<~B%V?!$QBH@HCW=oJ3bd%;ZAj&udzf&{b zAXi{XiY#yfth^!QO?v4~K5#T2I|2hfD+Rsr+x`9E{V!X`1^q(%3`9ulRC@m%rlu6K zE;EZYI5v~4l1lx4QOk98oXm%{D>tb=$}-6!SbgPi!U!Q0Q^EjPPSoj7> zNhT|@Saz}%y?X<%Riwu)&wiy@kcxnW`XvclCt01Qjel(>rp_i(gSJyUG*sJcAs`PC ziqhLJMl#yTkiGHt%tEb%yaeR)S^`cp0Jv$x2J=Z(P;ahb2}%UD>qG_8dNo4ic|5m+*}OhcA4;DxMJT}g`xi&|N|Vz3s$VO2U3GGu)g zW$xO3SEXZQv8pDj%t6RkE=!=Q3>aGF3B1}bG(yBk*6w}g(xON=j+s47%cx!nNIb&a z(HJFBmY3pfU8D(z&?_?=rXL{r_>C?eM-_OCdK>Fl3{e1n*~OjUwG{h^pD4(G*~xmu z|9F7*lWBWT47dl=_5m#D5ZNf|BP04yil7C<+MSk1eH#Z0&ayhlXflRsg29xY$+EA@ zl5Sx6^b{zEs@{stm)L$XC~8{r>cuMCBQJY#wrANy=&fKmsEfmAq(|nrBn6TZU?Zp= z6#uBwzkGVH+@N>aH48J8ly1IR9NG^bu?WPZSl9^bLre?NXE+Xmr%@8o0#)*3u` zm^u*@{1+*OGJN*QeHLN+(!*rACDWyJ(gQx<)furhXF@7>3w@X3xDfjXc2U2me<=2%CQ z`B39|gU~k2OUGwFlbO%X&(UyhA2$l;NE6jdLiO){J~?7Tm6|GmT+Ze&mjS`Rbz;_C zXc~Thf2dC&V=VaPcI zqC!|fBQXib+rnMIOYy)v-VHPu*i0tUiAxtua>LZxg9@lTe?>ix#q<*M^kr7{n*{FB z;sAZXohs~#{SwMCb zrY&ze+9#gD#X8(`^ziQiEcX5!Kz^uin_~Ejz|cYm>t+}r_bzrjZFTAzADAMqBu&Yx ULCzWqCSRj}0ZnPG$a)e00AM8C;Q#;t diff --git a/lib/browser/standard/postal.min.js b/lib/browser/standard/postal.min.js index 9a736d7..a812263 100644 --- a/lib/browser/standard/postal.min.js +++ b/lib/browser/standard/postal.min.js @@ -1 +1 @@ -(function(a,b){var c="/",d=50,e=0,f=function(){},g=function(a){var b={envelope:{}},d;switch(a.length){case 3:typeof a[1]=="Object"&&typeof a[2]=="Object"?(b.envelope.exchange=c,b.envelope.topic=a[0],b.payload=a[1],d=b.envelope,b.envelope=_.extend(d,a[2])):(b.envelope.exchange=a[0],b.envelope.topic=a[1],b.payload=a[2]);break;case 4:b.envelope.exchange=a[0],b.envelope.topic=a[1],b.payload=a[2],d=b.envelope,b.envelope=_.extend(d,a[3]);break;default:b.envelope.exchange=c,b.envelope.topic=a[0],b.payload=a[1]}return b},h=function(){var a;return function(b){var c=!1;return _.isString(b)?(c=b===a,a=b):(c=_.isEqual(b,a),a=_.clone(b)),!c}},i=function(a,b){this.exchange=a,this.topic=b};i.prototype={subscribe:function(a){var b=new j(this.exchange,this.topic,a);return m.configuration.bus.subscribe(b),b},publish:function(a,b){var c=_.extend({exchange:this.exchange,timeStamp:new Date,topic:this.topic},b);m.configuration.bus.publish(a,c)}};var j=function(a,b,c){this.exchange=a,this.topic=b,this.callback=c,this.priority=d,this.constraints=[],this.maxCalls=e,this.onHandled=f,this.context=null};j.prototype={unsubscribe:function(){m.configuration.bus.unsubscribe(this)},defer:function(){var a=this.callback;return this.callback=function(b){setTimeout(a,0,b)},this},disposeAfter:function(a){if(_.isNaN(a)||a<=0)throw"The value provided to disposeAfter (maxCalls) must be a number greater than zero.";var b=this.onHandled,c=_.after(a,_.bind(function(){this.unsubscribe(this)},this));return this.onHandled=function(){b.apply(this.context,arguments),c()},this},ignoreDuplicates:function(){return this.withConstraint(new h),this},whenHandledThenExecute:function(a){if(!_.isFunction(a))throw"Value provided to 'whenHandledThenExecute' must be a function";return this.onHandled=a,this},withConstraint:function(a){if(!_.isFunction(a))throw"Predicate constraint must be a function";return this.constraints.push(a),this},withConstraints:function(a){var b=this;return _.isArray(a)&&_.each(a,function(a){b.withConstraint(a)}),b},withContext:function(a){return this.context=a,this},withDebounce:function(a){if(_.isNaN(a))throw"Milliseconds must be a number";var b=this.callback;return this.callback=_.debounce(b,a),this},withDelay:function(a){if(_.isNaN(a))throw"Milliseconds must be a number";var b=this.callback;return this.callback=function(c){setTimeout(b,a,c)},this},withPriority:function(a){if(_.isNaN(a))throw"Priority must be a number";return this.priority=a,this},withThrottle:function(a){if(_.isNaN(a))throw"Milliseconds must be a number";var b=this.callback;return this.callback=_.throttle(b,a),this}};var k={cache:{},compare:function(a,b){if(this.cache[b]&&this.cache[b][a])return!0;var c=new RegExp("^"+this.regexify(a)+"$"),d=c.test(b);return d&&(this.cache[b]||(this.cache[b]={}),this.cache[b][a]=!0),d},regexify:function(a){return a.replace(/\./g,"\\.").replace(/\*/g,".*").replace(/#/g,"[A-Z,a-z,0-9]*")}},l={subscriptions:{},wireTaps:[],publish:function(a,b){_.each(this.wireTaps,function(c){c(a,b)}),_.each(this.subscriptions[b.exchange],function(c){_.each(c,function(c){m.configuration.resolver.compare(c.topic,b.topic)&&_.all(c.constraints,function(b){return b(a)})&&typeof c.callback=="function"&&(c.callback.apply(c.context,[a,b]),c.onHandled())})})},subscribe:function(a){var b,c,d;this.subscriptions[a.exchange]||(this.subscriptions[a.exchange]={}),this.subscriptions[a.exchange][a.topic]||(this.subscriptions[a.exchange][a.topic]=[]),b=this.subscriptions[a.exchange][a.topic].length-1;if(!_.any(this.subscriptions[a.exchange][a.topic],function(b){return b===a})){for(;b>=0;b--)if(this.subscriptions[a.exchange][a.topic][b].priority<=a.priority){this.subscriptions[a.exchange][a.topic].splice(b+1,0,a),c=!0;break}c||this.subscriptions[a.exchange][a.topic].unshift(a)}return _.bind(function(){this.unsubscribe(a)},this)},unsubscribe:function(a){if(this.subscriptions[a.exchange][a.topic]){var b=this.subscriptions[a.exchange][a.topic].length,c=0;for(;c=0;b--)if(this.subscriptions[a.exchange][a.topic][b].priority<=a.priority){this.subscriptions[a.exchange][a.topic].splice(b+1,0,a),c=!0;break}c||this.subscriptions[a.exchange][a.topic].unshift(a)}return _.bind(function(){this.unsubscribe(a)},this)},notifyTaps:function(a,b){_.each(this.wireTaps,function(c){c(a,b)})},unsubscribe:function(a){if(this.subscriptions[a.exchange][a.topic]){var b=this.subscriptions[a.exchange][a.topic].length,c=0;for(;c