https://www.urbanekuensteruhr.de/chunk-FUKTUNX4.js

1import{b as y}from"./chunk-ZEH2WMTB.js";import{Fa as O}from"./chunk-3H2GI3MM.js";import{$ as p,A as I,Ea as g,H as u,P as $,R as x,Va as j,Z as R,aa as m,ca as v,g as b,h as l,ia as _,la as k,ma as c,na as w,t as f,z as r}from"./chunk-N4XFLIUN.js";import{a as n,b as o}from"./chunk-DIH54OSL.js";var M=new k("LOADING_BAR_CONFIG"),d=class{#t;#e;#i;constructor(e={}){this.config=e,this.state={action:void 0,value:0,initialValue:0},this.#t=null,this.#e=!1,this.#i=new l,this._value$=null,this.timer$=t=>{let s=f(t);switch(t.action){case"start":case"increment":case"set":{t.action==="start"&&this.config.latencyThreshold===0&&t.value===0&&(t.value=t.initialValue),this.#t>0&&(s=u(this.config.latencyThreshold??0,250).pipe(r(a=>o(n({},t),{value:a===0?this.state.value||t.initialValue:this._increment()}))));break}case"complete":case"stop":{s=t.value===0?f(n({},t)):u(0,500).pipe($(2),r(a=>({value:a===0?100:0})));break}}return s.pipe(r(a=>o(n({},a),{action:"set"})),v(a=>this.next(a,!1)))},this.config=n({latencyThreshold:0},e)}get value$(){return this._value$?this._value$:this._value$=this.#i.pipe(p(this.state),m(e=>this.timer$(e)),R(),r(e=>e.value))}start(e=2){this.#e||this.next({action:"start",initialValue:e})}stop(){this.next({action:"stop"})}complete(){this.next({action:"complete"})}disable(){this.#e=!0}set(e){this.next({action:"set",value:e})}increment(e=0){this.next({action:"increment",value:e})}next(e,t=!0){switch(e.action){case"start":this.#t=(this.#t||0)+1;break;case"complete":if(this.#t=(this.#t||1)-1,this.#t>0)return;break;case"stop":this.#t=0;break;case"increment":e.value=this._increment(e.value);break}this.state=n(o(n({},this.state),{action:void 0}),e),t&&this.#i.next(this.state)}_increment(e=0){let t=this.state.value;return t>=99&&(e=0),e===0&&(t>=0&&t<25?e=Math.random()*3+3:t>=25&&t<65?e=Math.random()*3:t>=65&&t<90?e=Math.random()*2:t>=90&&t<99?e=.5:e=0),e+t}},N=(()=>{class i{constructor(t,s={},a){this.platformId=t,this.config=s,this.zone=a,this.refs={},this.streams$=new l,this.value$=this.streams$.pipe(p(null),m(()=>I(Object.keys(this.refs).map(h=>this.refs[h].value$))),A(this.zone),r(h=>Math.max(0,...h)))}start(t=2){this.useRef().start(t)}set(t){this.useRef().set(t)}increment(t){this.useRef().increment(t)}complete(){this.useRef().complete()}stop(){this.useRef().stop()}useRef(t="default"){return this.refs[t]||(this.refs[t]=new d(this.config),this.streams$.next(),O(this.platformId)||this.refs[t].disable()),this.refs[t]}static{this.\u0275fac=function(s){return new(s||i)(c(j),c(M,8),c(g,8))}}static{this.\u0275prov=_({token:i,factory:i.\u0275fac,providedIn:"root"})}}return i})();function A(i){return i?e=>new b(t=>e.subscribe(s=>i.run(()=>t.next(s)),s=>i.run(()=>t.error(s)),()=>i.run(()=>t.complete()))):e=>e}var D=new y(()=>!1),E=(i,e)=>{let t=w(N);if(i.context.get(D)===!0)return e(i);let s=!1,a=t.useRef("http");return e(i).pipe(v(()=>{s||(a.start(),s=!0)}),x(()=>s&&a.complete()))};export{N as a,E as b};
2//# sourceMappingURL=chunk-FUKTUNX4.js.map