Build 574548stable
Module 625494
2,518 characters · in no known chunkDependencies
Required by (132)
1464271624226343373590336525559476315267319820388325792960104731105289115063119031129537138617141268163050164684175671178347184264187360191701207803215497217424234320251333251494258083267102272244274794275538277370287245315790318009320080328857332779333189337371339891348833349230350150352043365225367513371911381687390435392553395678436405438729439401448290453314467691482030490714494664496841499454518530519222532794540462552049554601559908560936561965595244625864627669636042638495639288645320649963674684677877682455699707703966710637712687720882731231732637738266738876739008747926753806754459761640774603780385798612803842811656823092835835836781837528854379860603868942869362874357874739877991888250890620901406913765928078933958946228953963957292970309976860981714990474
Lazily required by (0)none
Lazily requires (0)none
Source Raw
function(e,t,n){"use strict";n.d(t,{H:()=>s,_:()=>u});var i=n(423034);n(321073);var r=n(143236);class s{emitter=new r.EventEmitter;options;_savedDispatches={};constructor(e={}){this.options={maxListeners:100,enableDevtools:!1,...e};const t=this.options.maxListeners??100;this.emitter.setMaxListeners(t)}safeDispatch(e){for(var t=arguments.length,n=Array(t>1?t-1:0),i=1;i<t;i++)n[i-1]=arguments[i];if(!this.hasSubscribers(e)){let[t]=n;return(this._savedDispatches[e]=this._savedDispatches[e]??[]).push(t),this}return this.dispatch(e,...n)}dispatch(e,t){let n=Date.now();try{return this.emitter.emit(e,t),this}finally{this.options.enableDevtools&&this.options.devtoolsReporter&&this.options.devtoolsReporter(e,t,Date.now()-n)}}dispatchToLastSubscribed(e,t){let n=Date.now();try{let n=this.emitter.listeners(e);return n.length>0&&n[n.length-1](t),this}finally{this.options.enableDevtools&&this.options.devtoolsReporter&&this.options.devtoolsReporter(e,t,Date.now()-n)}}hasSubscribers(e){return this.emitter.listenerCount(e)>0}_checkSavedDispatches(e){let t=this._savedDispatches[e];null!=t&&(t.forEach(t=>{this.dispatch(e,t)}),this._savedDispatches[e]=void 0)}subscribe(e,t){return this.emitter.listeners(e).indexOf(t)>=0?this.options.logger&&this.options.logger.warn("ComponentDispatch.subscribe: Attempting to add a duplicate listener",e):(this.emitter.on(e,t),this._checkSavedDispatches(e)),this}subscribeOnce(e,t){return this.emitter.once(e,t),this._checkSavedDispatches(e),this}resubscribe(e,t){return this.emitter.listeners(e).includes(t)?(this.emitter.off(e,t),this.emitter.on(e,t)):this.options.logger&&this.options.logger.warn("ComponentDispatch.resubscribe: Resubscribe without existing subscription",e),this}unsubscribe(e,t){return this.emitter.removeListener(e,t),this}reset(){return this.emitter.removeAllListeners(),this}dispatchKeyed(e,t){for(var n=arguments.length,i=Array(n>2?n-2:0),r=2;r<n;r++)i[r-2]=arguments[r];return this.dispatch(`${e}_${t}`,...i)}subscribeKeyed(e,t,n){return this.subscribe(`${e}_${t}`,n)}unsubscribeKeyed(e,t,n){return this.unsubscribe(`${e}_${t}`,n)}}var a=n(626584),o=n(652215);let l=new a.A("ComponentDispatchUtils"),u=new s({maxListeners:100,enableDevtools:!1,logger:{warn:function(e){for(var t=arguments.length,n=Array(t>1?t-1:0),i=1;i<t;i++)n[i-1]=arguments[i];return l.warn(e,...n)}},devtoolsReporter:function(e,t,n){let r=Object.values(o.zOV).find(t=>e.startsWith(t))??e;i.HF({type:"ComponentDispatch",description:r,data:{actionData:t,fullActionName:e},durationMs:n})}})}