https://loadboard.truckerpath.com/@react-rxjs.b0199e99.js

1import{s as e}from"./use-sync-external-store.9b689ced.js";import{r as t}from"./react.28cd72ec.js";import{O as r,n,S as s,a as o}from"./rxjs.c0e2ad92.js";var u=Object.defineProperty,l=(e,t,r)=>(((e,t,r)=>{t in e?u(e,t,{enumerable:!0,configurable:!0,writable:!0,value:r}):e[t]=r})(e,"symbol"!=typeof t?t+"":t,r),r),c={},i=Symbol("SUSPENSE"),b=(e,t,u=!0,l=n)=>{let b,a,f,g=0,p=c;const h=t===c?n:()=>{p===c&&b&&b.next(p=t)},w=new r((t=>{let r;u||(t.complete=n),g++,t.add((()=>{g--,r.unsubscribe(),0===g&&(p=c,a&&a.unsubscribe(),l(),b=null,a=null,f=null)})),b?(r=b.subscribe(t),p!==c&&t.next(p)):(b=new s,r=b.subscribe(t),a=null,a=new o({next:e=>{b.next(p=e)},error:e=>{const t=b;a=null,b=null,t.error(e)},complete:()=>{a=null,h(),b.complete()}}),e.subscribe(a),h())}));return w.gV=e=>{if(p!==i&&p!==c)return p;if(t!==c)return t;if(!a){if(!e)throw new Error("Missing Subscribe");let t=c;const r=w.subscribe({error(e){t=e}});if(t!==c)throw t;return e.add(r),w.gV()}if(f)throw f;throw f=new Promise(((e,t)=>{const r=e=>{t(e),f=null},n=b.subscribe({next:t=>{t!==i&&(n.unsubscribe(),e(t),f=null)},error:r,complete:()=>{r(new Error("Empty observable"))}});a.add(n)}))},w},a=(r,n)=>{const[,s]=t.exports.useState(),o=t.exports.useRef();return o.current&&o.current.source$===r||(o.current={source$:r,args:[e=>{const t=r.subscribe({next:e,error:e=>{s((()=>{throw e}))}});return()=>t.unsubscribe()},()=>r.gV(n)]}),e.exports.useSyncExternalStore(...o.current.args)},f=t.exports.createContext(null),g=()=>t.exports.useContext(f);function p(e,t){const s=new h,o="function"==typeof t?t:()=>t,u=t=>{for(let e=t.length-1;void 0===t[e]&&e>-1;e--)t.splice(-1);const n=[t.length,...t],u=s.get(n);if(void 0!==u)return u;const l=b(new r((r=>e(...t).subscribe(r))),o(...t),!1,(()=>{s.delete(n)})),c=new r((e=>{const t=s.get(n);let r=l;return t?t!==c&&(r=t,c.gV=r.gV):s.set(n,i),r.subscribe(e)}));c.gV=l.gV;const i=c;return s.set(n,i),i},l=t===c?g:n;return[(...e)=>a(u(e),l()),(...e)=>u(e)]}Promise.resolve();var h=class{constructor(){l(this,"root"),this.root=new Map}get(e){let t=this.root;for(let r=0;r<e.length;r++)if(t=t.get(e[r]),!t)return;return t}set(e,t){let r,n=this.root;for(r=0;r<e.length-1;r++){let t=n.get(e[r]);t||(t=new Map,n.set(e[r],t)),n=t}n.set(e[r],t)}delete(e){const t=[this.root];let r=this.root;for(let s=0;s<e.length-1;s++)t.push(r=r.get(e[s]));let n=t.length-1;for(t[n].delete(e[n]);--n>-1&&0===t[n].get(e[n]).size;)t[n].delete(e[n])}};function w(e,t){const r=b(e,t,!1),s=t===c?g:n;return[()=>a(r,s()),r]}function x(e,t){return("function"==typeof e?p:w)(e,arguments.length>1?t:c)}export{x as b};