https://imprintedlogo.com/chunk-Xnut8LmN.js

1import{ht as ut,pt as te,tt as h}from"./chunk-CSa5EmPS.js";import{n as t,r as u}from"./chunk-BnV2llXI.js";import{E as Fe,Hr as ts,Nt as Tt,Un as he,Ut as Vr,W as JN,ci as y$1,fr as me,nn as YN,ot as Na,qr as ue,v as D}from"./chunk-jV-HsxzN.js";function q(n){n||(n=y$1(me));let e=new h(t=>{if(n.destroyed){t.next();return}return n.onDestroy(t.next.bind(t))});return t=>t.pipe(ut(e))}var y=class{source;destroyed=!1;destroyRef=y$1(me);constructor(e){this.source=e,this.destroyRef.onDestroy(()=>{this.destroyed=!0})}subscribe(e){if(this.destroyed)throw new D(953,!1);let t=this.source.pipe(q(this.destroyRef)).subscribe({next:r=>e(r)});return{unsubscribe:()=>t.unsubscribe()}}};function P(n,e){return new y(n)}function V(n){let e=YN(n);return new h(t=>{let r=e?.onDestroy(()=>t.complete()),s=n.subscribe(o=>t.next(o));return()=>{s.unsubscribe(),r?.()}})}function W(n,e){let t=e?.injector??y$1(ue),r=new te(1),s=Na(()=>{let o;try{o=n()}catch(u){he(()=>r.error(u));return}he(()=>r.next(o))},{injector:t,manualCleanup:!0});return t.get(me).onDestroy(()=>{s.destroy(),r.complete()}),r.asObservable()}function z(n,e){let r=!e?.manualCleanup?e?.injector?.get(me)??y$1(me):null,s=E(e?.equal),o;e?.requireSync?o=Fe({kind:0},{equal:s}):o=Fe({kind:1,value:e?.initialValue},{equal:s});let u,c=n.subscribe({next:i=>o.set({kind:1,value:i}),error:i=>{o.set({kind:2,error:i}),u?.()},complete:()=>{u?.()}});if(e?.requireSync&&o().kind===0)throw new D(601,!1);return u=r?.onDestroy(c.unsubscribe.bind(c)),Tt(()=>{let i=o();switch(i.kind){case 1:return i.value;case 2:throw i.error;case 0:throw new D(601,!1)}},{equal:e?.equal})}function E(n=Object.is){return(e,t)=>e.kind===1&&t.kind===1&&n(e.value,t.value)}function B(n){return JN(u(t({},n),{loader:void 0,stream:e=>{let t,r=!1,s=Fe({value:void 0}),{resolve:o,promise:u}=Vr(),c=!1;function i(){c||(c=!0,o(s))}let v=()=>{r=!0,t?.unsubscribe(),e.abortSignal.removeEventListener(`abort`,v),i()};e.abortSignal.addEventListener(`abort`,v);function g(l){s.set(l),i()}let D$1=n.stream;if(D$1===void 0)throw new D(990,!1);return t=D$1(e).subscribe({next:l=>g({value:l}),error:l=>{g({error:ts(l)}),e.abortSignal.removeEventListener(`abort`,v)},complete:()=>{c||g({error:new D(991,!1)}),e.abortSignal.removeEventListener(`abort`,v)}}),r&&t.unsubscribe(),c?s:u}}))}export{q as a,W as i,P as n,z as o,V as r,B as t};