1import{Ea as w,Ga as l,Jd as f,Kd as h,Ma as v,Md as j,Nd as M,Oa as x,Od as S,Pa as C,Qa as O,c as m,da as D,f as y,ia as I,ka as d,sa as b}from"./chunk-AAE36BVF.js";import{a as g,b as p,d as k}from"./chunk-YZFYTRZT.js";function A(r){r||(r=b(l));let e=new m(t=>{if(r.destroyed){t.next();return}return r.onDestroy(t.next.bind(t))});return t=>t.pipe(D(e))}function V(r,e){let t=e?.injector??b(w),o=new y(1),i=x(()=>{let n;try{n=r()}catch(u){f(()=>o.error(u));return}f(()=>o.next(n))},{injector:t,manualCleanup:!0});return t.get(l).onDestroy(()=>{i.destroy(),o.complete()}),o.asObservable()}function z(r,e){let o=!e?.manualCleanup?e?.injector?.get(l)??b(l):null,i=q(e?.equal),n;e?.requireSync?n=v({kind:0},{equal:i}):n=v({kind:1,value:e?.initialValue},{equal:i});let u,a=r.subscribe({next:s=>n.set({kind:1,value:s}),error:s=>{n.set({kind:2,error:s}),u?.()},complete:()=>{u?.()}});if(e?.requireSync&&n().kind===0)throw new d(601,!1);return u=o?.onDestroy(a.unsubscribe.bind(a)),h(()=>{let s=n();switch(s.kind){case 1:return s.value;case 2:throw s.error;case 0:throw new d(601,!1)}},{equal:e?.equal})}function q(r=Object.is){return(e,t)=>e.kind===1&&t.kind===1&&r(e.value,t.value)}function B(r){return j(p(g({},r),{loader:void 0,stream:e=>{let t,o=()=>t?.unsubscribe();e.abortSignal.addEventListener("abort",o);let i=v({value:void 0}),n,u=new Promise(c=>n=c);function a(c){i.set(c),n?.(i),n=void 0}let s=r.stream;if(s===void 0)throw new d(990,!1);return t=s(e).subscribe({next:c=>a({value:c}),error:c=>{a({error:M(c)}),e.abortSignal.removeEventListener("abort",o)},complete:()=>{n&&a({error:new d(991,!1)}),e.abortSignal.removeEventListener("abort",o)}}),u}}))}var R=k(()=>{"use strict";I();O();C();S();});export{A as a,V as b,z as c,B as d,R as e}; 2//# sourceMappingURL=chunk-QWXB4XKK.js.map
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.