schemas/libraries/effect/download_compiled/index/minified.js
const e=e=>typeof e==`function`,t=function(e,t){if(typeof e==`function`)return function(){return e(arguments)?t.apply(this,arguments):e=>t(e,...arguments)};switch(e){case 0:case 1:throw RangeError(`Invalid arity ${e}`);case 2:return function(e,n){return arguments.length>=2?t(e,n):function(n){return t(n,e)}};case 3:return function(e,n,r){return arguments.length>=3?t(e,n,r):function(r){return t(r,e,n)}};case 4:return function(e,n,r,i){return arguments.length>=4?t(e,n,r,i):function(i){return t(i,e,n,r)}};case 5:return function(e,n,r,i,a){return arguments.length>=5?t(e,n,r,i,a):function(a){return t(a,e,n,r,i)}};default:return function(){if(arguments.length>=e)return t.apply(this,arguments);let n=arguments;return function(e){return t(e,...n)}}}},n=e=>e,r=e=>()=>e,i= r(!0),a= r(!1),o= r(void 0),s=o;function c(e,t,n,r,i,a,o,s,c){switch(arguments.length){case 1:return e;case 2:return t(e);case 3:return n(t(e));case 4:return r(n(t(e)));case 5:return i(r(n(t(e))));case 6:return a(i(r(n(t(e)))));case 7:return o(a(i(r(n(t(e))))));case 8:return s(o(a(i(r(n(t(e)))))));case 9:return c(s(o(a(i(r(n(t(e))))))));default:{let e=arguments[0];for(let t=1;t<arguments.length;t++)e=arguments[t](e);return e}}}const l=e=>(t,n)=>t===n||e(t,n),u= t(2,(e,t)=>l((n,r)=>e(t(n),t(r)))),d=e=>l((t,n)=>{if(t.length!==n.length)return!1;for(let r=0;r<t.length;r++)if(!e(t[r],n[r]))return!1;return!0}),f=`effect/GlobalValue`;let p;const m=(e,t)=>(p||=(globalThis[f]??= new Map,globalThis[f]),p.has(e)||p.set(e,t()),p.get(e)),h=e=>typeof e==`string`,g=e=>typeof e==`number`,_=e=>typeof e==`boolean`,v=e=>typeof e==`bigint`,ee=e=>typeof e==`symbol`,te=e,ne=e=>e===void 0,re=e=>!1,ie=e=>typeof e==`object`&&!!e,ae=e=>ie(e)||te(e),y= t(2,(e,t)=>ae(e)&&t in e),oe= t(2,(e,t)=>y(e,`_tag`)&&e._tag===t),se=e=>e==null,ce=e=>e!=null,le=e=>e instanceof Date,ue=e=>typeof e==`string`||y(e,Symbol.iterator),de=e=>ie(e)&&!Array.isArray(e),fe=e=>y(e,`then`)&&te(e.then),pe=e=>`BUG: ${e} - please report an issue at https://github.com/Effect-TS/effect/issues`;var me=class e{self;called=!1;constructor(e){this.self=e}next(e){return this.called?{value:e,done:!0}:(this.called=!0,{value:this.self,done:!1})}return(e){return{value:e,done:!0}}throw(e){throw e}[Symbol.iterator](){return new e(this.self)}},he=class{_state;constructor(e,t,n,r){return se(t)&&se(e)?(t=Math.random()*4294967295>>>0,e=0):se(t)&&(t=e,e=0),se(r)&&se(n)?(r=this._state?this._state[3]:4150755663,n=this._state?this._state[2]:335903614):se(r)&&(r=n,n=0),this._state=new Int32Array([0,0,n>>>0,((r||0)|1)>>>0]),this._next(),_e(this._state,this._state[0],this._state[1],e>>>0,t>>>0),this._next(),this}getState(){return[this._state[0],this._state[1],this._state[2],this._state[3]]}setState(e){this._state[0]=e[0],this._state[1]=e[1],this._state[2]=e[2],this._state[3]=e[3]|1}integer(e){return Math.round(this.number()*(2**53-1))%e}number(){let e=(this._next()&67108863)*1,t=(this._next()&134217727)*1;return(e*134217728+t)/9007199254740992}_next(){let e=this._state[0]>>>0,t=this._state[1]>>>0;ge(this._state,e,t,1481765933,1284865837),_e(this._state,this._state[0],this._state[1],this._state[2],this._state[3]);let n=e>>>18,r=(t>>>18|e<<14)>>>0;n=(n^e)>>>0,r=(r^t)>>>0;let i=(r>>>27|n<<5)>>>0,a=e>>>27,o=(-a>>>0&31)>>>0;return(i>>>a|i<<o)>>>0}};function ge(e,t,n,r,i){let a=(n>>>16)*(i&65535)>>>0,o=(n&65535)*(i>>>16)>>>0,s=(n&65535)*(i&65535)>>>0,c=(n>>>16)*(i>>>16)+((o>>>16)+(a>>>16))>>>0;o=o<<16>>>0,s=s+o>>>0,s>>>0<o>>>0&&(c=c+1>>>0),a=a<<16>>>0,s=s+a>>>0,s>>>0<a>>>0&&(c=c+1>>>0),c=c+Math.imul(n,r)>>>0,c=c+Math.imul(t,i)>>>0,e[0]=c,e[1]=s}function _e(e,t,n,r,i){let a=t+r>>>0,o=n+i>>>0;o>>>0<n>>>0&&(a=a+1|0),e[0]=a,e[1]=o}const ve= Symbol.for(`effect/Utils/YieldWrap`);var ye=class{#e;constructor(e){this.#e=e}[ve](){return this.#e}};function be(e){if(typeof e==`object`&&e&&ve in e)return e[ve]();throw Error(pe(`yieldWrapGet`))}const xe= m(`effect/Utils/isStructuralRegion`,()=>({enabled:!1,tester:void 0})),Se={effect_internal_function:e=>e()},Ce= Se.effect_internal_function(()=>( Error()).stack)?.includes(`effect_internal_function`)===!0?Se.effect_internal_function:{effect_internal_function:e=>{try{return e()}finally{}}}.effect_internal_function;(function*(){}).constructor;const we= m( Symbol.for(`effect/Hash/randomHashCache`),()=> new WeakMap),b= Symbol.for(`effect/Hash`),x=e=>{if(xe.enabled===!0)return 0;switch(typeof e){case`number`:return Oe(e);case`bigint`:return C(e.toString(10));case`boolean`:return C(String(e));case`symbol`:return C(String(e));case`string`:return C(e);case`undefined`:return C(`undefined`);case`function`:case`object`:return e===null?C(`null`):e instanceof Date?Number.isNaN(e.getTime())?C(`Invalid Date`):x(e.toISOString()):e instanceof URL?x(e.href):De(e)?e[b]():Te(e);default:throw Error(`BUG: unhandled typeof ${typeof e} - please report an issue at https://github.com/Effect-TS/effect/issues`)}},Te=e=>(we.has(e)||we.set(e,Oe(Math.floor(Math.random()*(2**53-1)))),we.get(e)),S=e=>t=>t*53^e,Ee=e=>e&3221225471|e>>>1&1073741824,De=e=>y(e,b),Oe=e=>{if(e!==e||e===1/0)return 0;let t=e|0;for(t!==e&&(t^=e*4294967295);e>4294967295;)t^=e/=4294967295;return Ee(t)},C=e=>{let t=5381,n=e.length;for(;n;)t=t*33^e.charCodeAt(--n);return Ee(t)},ke=(e,t)=>{let n=12289;for(let r=0;r<t.length;r++)n^=c(C(t[r]),S(x(e[t[r]])));return Ee(n)},Ae=e=>ke(e,Object.keys(e)),je=e=>{let t=6151;for(let n=0;n<e.length;n++)t=c(t,S(x(e[n])));return Ee(t)},w=function(){if(arguments.length===1){let e=arguments[0];return function(t){return Object.defineProperty(e,b,{value(){return t},enumerable:!1}),t}}let e=arguments[0],t=arguments[1];return Object.defineProperty(e,b,{value(){return t},enumerable:!1}),t},T= Symbol.for(`effect/Equal`);function E(){return arguments.length===1?e=>Me(e,arguments[0]):Me(arguments[0],arguments[1])}function Me(e,t){if(e===t)return!0;let n=typeof e;if(n!==typeof t)return!1;if(n===`object`||n===`function`){if(e!==null&&t!==null){if(Ne(e)&&Ne(t))return x(e)===x(t)&&e[T](t)?!0:xe.enabled&&xe.tester?xe.tester(e,t):!1;if(e instanceof Date&&t instanceof Date){let n=e.getTime(),r=t.getTime();return n===r||Number.isNaN(n)&&Number.isNaN(r)}if(e instanceof URL&&t instanceof URL)return e.href===t.href}if(xe.enabled){if(e===null||t===null)return!1;if(Array.isArray(e)&&Array.isArray(t))return e.length===t.length&&e.every((e,n)=>Me(e,t[n]));if(Object.getPrototypeOf(e)===Object.prototype&&Object.getPrototypeOf(t)===Object.prototype){let n=Object.keys(e),r=Object.keys(t);if(n.length===r.length){for(let r of n)if(!(r in t&&Me(e[r],t[r])))return xe.tester?xe.tester(e,t):!1;return!0}}return xe.tester?xe.tester(e,t):!1}}return xe.enabled&&xe.tester?xe.tester(e,t):!1}const Ne=e=>y(e,T),Pe=()=>E,D= Symbol.for(`nodejs.util.inspect.custom`),O=e=>{try{if(y(e,`toJSON`)&&te(e.toJSON)&&e.toJSON.length===0)return e.toJSON();if(Array.isArray(e))return e.map(O)}catch{return{}}return Ke(e)},Fe=`[Circular]`;function Ie(e){try{return e.toISOString()}catch{return`Invalid Date`}}function Le(e){try{let t=e.toString();return typeof t==`string`?t:String(t)}catch{return`[toString threw]`}}function Re(e){return h(e)?JSON.stringify(e):String(e)}function ze(e,t){let n=t?.space??0,r= new WeakSet,i=n?g(n)?` `.repeat(n):n:``,a=e=>i.repeat(e),o=(e,t)=>{let n=e?.constructor;return n&&n!==Object.prototype.constructor&&n.name?`${n.name}(${t})`:t},s=e=>{try{return Reflect.ownKeys(e)}catch{return[`[ownKeys threw]`]}};function c(e,n=0){if(Array.isArray(e)){if(r.has(e))return Fe;if(r.add(e),!i||e.length<=1)return`[${e.map(e=>c(e,n)).join(`,`)}]`;let t=e.map(e=>c(e,n+1)).join(`,
`+a(n+1));return`[\n${a(n+1)}${t}\n${a(n)}]`}if(le(e))return Ie(e);if(!t?.ignoreToString&&y(e,`toString`)&&te(e.toString)&&e.toString!==Object.prototype.toString&&e.toString!==Array.prototype.toString){let t=Le(e);return e instanceof Error&&e.cause?`${t} (cause: ${c(e.cause,n)})`:t}if(h(e))return JSON.stringify(e);if(g(e)||e==null||_(e)||ee(e))return String(e);if(v(e))return String(e)+`n`;if(e instanceof Set||e instanceof Map)return r.has(e)?Fe:(r.add(e),`${e.constructor.name}(${c(Array.from(e),n)})`);if(ae(e)){if(r.has(e))return Fe;r.add(e);let t=s(e);if(!i||t.length<=1){let r=`{${t.map(t=>`${Re(t)}:${c(e[t],n)}`).join(`,`)}}`;return o(e,r)}let l=`{\n${t.map(t=>`${a(n+1)}${Re(t)}: ${c(e[t],n+1)}`).join(`,
`)}\n${a(n)}}`;return o(e,l)}return String(e)}return c(e,0)}const k=e=>JSON.stringify(e,null,2),Be=(e,t=2)=>{if(typeof e==`string`)return e;try{return typeof e==`object`?Ve(e,t):String(e)}catch{return String(e)}},Ve=(e,t)=>{let n=[],r=JSON.stringify(e,(e,t)=>typeof t==`object`&&t?n.includes(t)?void 0:n.push(t)&&(We.fiberRefs!==void 0&&Ue(t)?t[He](We.fiberRefs):t):t,t);return n=void 0,r},He= Symbol.for(`effect/Inspectable/Redactable`),Ue=e=>typeof e==`object`&&!!e&&He in e,We= m(`effect/Inspectable/redactableState`,()=>({fiberRefs:void 0})),Ge=(e,t)=>{let n=We.fiberRefs;We.fiberRefs=e;try{return t()}finally{We.fiberRefs=n}},Ke=e=>Ue(e)&&We.fiberRefs!==void 0?e[He](We.fiberRefs):e,A=(e,t)=>{switch(t.length){case 0:return e;case 1:return t[0](e);case 2:return t[1](t[0](e));case 3:return t[2](t[1](t[0](e)));case 4:return t[3](t[2](t[1](t[0](e))));case 5:return t[4](t[3](t[2](t[1](t[0](e)))));case 6:return t[5](t[4](t[3](t[2](t[1](t[0](e))))));case 7:return t[6](t[5](t[4](t[3](t[2](t[1](t[0](e)))))));case 8:return t[7](t[6](t[5](t[4](t[3](t[2](t[1](t[0](e))))))));case 9:return t[8](t[7](t[6](t[5](t[4](t[3](t[2](t[1](t[0](e)))))))));default:{let n=e;for(let e=0,r=t.length;e<r;e++)n=t[e](n);return n}}},qe=`Async`,Je=`Commit`,Ye=`Failure`,Xe=`OnFailure`,Ze=`OnSuccess`,Qe=`OnSuccessAndFailure`,$e=`Success`,et=`Sync`,tt=`UpdateRuntimeFlags`,nt=`While`,rt=`Iterator`,it=`WithRuntime`,at=`Yield`,ot=`RevertFlags`,st=()=>`3.22.2`,ct= Symbol.for(`effect/Effect`),lt= Symbol.for(`effect/Stream`),ut= Symbol.for(`effect/Sink`),dt= Symbol.for(`effect/Channel`),ft={
_R:e=>e,
_E:e=>e,
_A:e=>e,_V: st()},pt={
_A:e=>e,
_In:e=>e,
_L:e=>e,
_E:e=>e,
_R:e=>e},mt={
_Env:e=>e,
_InErr:e=>e,
_InElem:e=>e,
_InDone:e=>e,
_OutErr:e=>e,
_OutElem:e=>e,
_OutDone:e=>e},ht={[ct]:ft,[lt]:ft,[ut]:pt,[dt]:mt,[T](e){return this===e},[b](){return w(this,Te(this))},[Symbol.iterator](){return new me(new ye(this))},pipe(){return A(this,arguments)}},gt={[b](){return w(this,Ae(this))},[T](e){let t=Object.keys(this),n=Object.keys(e);if(t.length!==n.length)return!1;for(let n of t)if(!(n in e&&E(this[n],e[n])))return!1;return!0}},_t={...ht,_op:Je},vt={..._t,...gt},yt= function(){function e(){}return e.prototype=_t,e}(),bt= Symbol.for(`effect/Option`),xt={...ht,[bt]:{_A:e=>e},[D](){return this.toJSON()},toString(){return k(this.toJSON())}},St= Object.assign( Object.create(xt),{_tag:`Some`,_op:`Some`,[T](e){return Tt(e)&&Dt(e)&&E(this.value,e.value)},[b](){return w(this,S(x(this._tag))(x(this.value)))},toJSON(){return{_id:`Option`,_tag:this._tag,value:O(this.value)}}}),Ct= x(`None`),wt= Object.assign( Object.create(xt),{_tag:`None`,_op:`None`,[T](e){return Tt(e)&&Et(e)},[b](){return Ct},toJSON(){return{_id:`Option`,_tag:this._tag}}}),Tt=e=>y(e,bt),Et=e=>e._tag===`None`,Dt=e=>e._tag===`Some`,Ot= Object.create(wt),kt=e=>{let t=Object.create(St);return t.value=e,t},At= Symbol.for(`effect/Either`),jt={...ht,[At]:{_R:e=>e},[D](){return this.toJSON()},toString(){return k(this.toJSON())}},Mt= Object.assign( Object.create(jt),{_tag:`Right`,_op:`Right`,[T](e){return Pt(e)&&It(e)&&E(this.right,e.right)},[b](){return S(x(this._tag))(x(this.right))},toJSON(){return{_id:`Either`,_tag:this._tag,right:O(this.right)}}}),Nt= Object.assign( Object.create(jt),{_tag:`Left`,_op:`Left`,[T](e){return Pt(e)&&Ft(e)&&E(this.left,e.left)},[b](){return S(x(this._tag))(x(this.left))},toJSON(){return{_id:`Either`,_tag:this._tag,left:O(this.left)}}}),Pt=e=>y(e,At),Ft=e=>e._tag===`Left`,It=e=>e._tag===`Right`,Lt=e=>{let t=Object.create(Nt);return t.left=e,t},j=e=>{let t=Object.create(Mt);return t.right=e,t},M=Lt,Rt=Pt,N=Ft,zt=It,Bt= t(2,(e,t)=>N(e)?M(t(e.left)):j(e.right)),Vt= t(2,(e,t)=>zt(e)?j(t(e.right)):M(e.left)),Ht= t(2,(e,{onLeft:t,onRight:n})=>N(e)?t(e.left):n(e.right)),Ut= Ht({onLeft:n,onRight:n}),Wt= t(2,(e,t)=>{if(zt(e))return e.right;throw t(e.left)}),Gt= Wt(()=> Error(`getOrThrow called on a Left`)),Kt=e=>e.length>0,qt=e=>(t,n)=>t===n?0:e(t,n),Jt= qt((e,t)=>e<t?-1:1),Yt= t(2,(e,t)=>qt((n,r)=>e(t(n),t(r)))),Xt=e=>t(2,(t,n)=>e(t,n)===1),P=()=>Ot,F=kt,I=Et,L=Dt,Zt= t(2,(e,{onNone:t,onSome:n})=>I(e)?t():n(e.value)),R= t(2,(e,t)=>I(e)?t():e.value),Qt= t(2,(e,t)=>I(e)?t():e),$t= t(2,(e,t)=>I(e)?F(t()):e),en=e=>e==null?P():F(e),tn= R(o),nn=e=>(...t)=>{try{return F(e(...t))}catch{return P()}},rn= t(2,(e,t)=>I(e)?P():F(t(e.value))),an= t(2,(e,t)=>I(e)?P():t(e.value)),on= t(2,(e,t)=>I(e)?P():en(t(e.value))),sn= (e=>t(2,(t,n)=>!I(t)&&e(t.value,n)))( Pe()),cn= t(2,(e,t)=>!I(e)&&t(e.value)),ln=(...e)=>e,un=e=>Array(e),dn= t(2,(e,t)=>{let n=Math.max(1,Math.floor(e)),r=Array(n);for(let e=0;e<n;e++)r[e]=t(e);return r}),z=e=>Array.isArray(e)?e:Array.from(e),fn=e=>Array.isArray(e)?e:[e],pn= t(2,(e,{onEmpty:t,onNonEmpty:n})=>B(e)?n(Tn(e),On(e)):t()),mn= t(2,(e,t)=>[t,...e]),hn= t(2,(e,t)=>[...e,t]),gn= t(2,(e,t)=>z(e).concat(z(t))),_n=Array.isArray,vn=e=>e.length===0,yn=Kt,B=Kt,bn=(e,t)=>e<0||e>=t.length,xn=(e,t)=>Math.floor(Math.min(Math.max(0,e),t.length)),Sn= t(2,(e,t)=>{let n=Math.floor(t);return bn(n,e)?P():F(e[n])}),Cn= t(2,(e,t)=>{let n=Math.floor(t);if(bn(n,e))throw Error(`Index ${n} out of bounds`);return e[n]}),wn= Sn(0),Tn= Cn(0),En=e=>B(e)?F(Dn(e)):P(),Dn=e=>e[e.length-1],On=e=>e.slice(1),kn=(e,t)=>{let n=0;for(let r of e){if(!t(r,n))break;n++}return n},An= t(2,(e,t)=>Ln(e,kn(e,t))),jn= t(2,(e,t)=>{let n=z(e);return n.slice(xn(t,n),n.length)}),Mn=e=>Array.from(e).reverse(),Nn= t(2,(e,t)=>{let n=Array.from(e);return n.sort(t),n}),Pn= t(2,(e,t)=>Fn(e,t,ln)),Fn= t(3,(e,t,n)=>{let r=z(e),i=z(t);if(B(r)&&B(i)){let e=[n(Tn(r),Tn(i))],t=Math.min(r.length,i.length);for(let a=1;a<t;a++)e[a]=n(r[a],i[a]);return e}return[]}),In= Pe(),Ln= t(2,(e,t)=>{let n=Array.from(e),r=Math.floor(t);return B(n)?r>=1?Rn(n,r):[[],n]:[n,[]]}),Rn= t(2,(e,t)=>{let n=Math.max(1,Math.floor(t));return n>=e.length?[zn(e),[]]:[mn(e.slice(1,n),Tn(e)),e.slice(n)]}),zn=e=>e.slice(),Bn= t(3,(e,t,n)=>{let r=z(e),i=z(t);return B(r)?B(i)?Zn(n)(gn(r,i)):r:i}),Vn= t(2,(e,t)=>Bn(e,t,In)),Hn=()=>[],Un=e=>[e],Wn= t(2,(e,t)=>e.map(t)),Gn= t(2,(e,t)=>{if(vn(e))return[];let n=[];for(let r=0;r<e.length;r++){let i=t(e[r],r);for(let e=0;e<i.length;e++)n.push(i[e])}return n}),Kn= Gn(n),qn= t(2,(e,t)=>{let n=z(e),r=[];for(let e=0;e<n.length;e++){let i=t(n[e],e);L(i)&&r.push(i.value)}return r}),Jn= t(3,(e,t,n)=>z(e).reduce((e,t,r)=>n(e,t,r),t)),Yn=(e,t)=>{let n=[],r=e,i;for(;L(i=t(r));){let[e,t]=i.value;n.push(e),r=t}return n},Xn=d,Zn= t(2,(e,t)=>{let n=z(e);if(B(n)){let e=[Tn(n)],r=On(n);for(let n of r)e.every(e=>!t(n,e))&&e.push(n);return e}return[]}),Qn=e=>Zn(e,Pe()),$n= t(2,(e,t)=>z(e).join(t)),er= Symbol.for(`effect/BigDecimal`),tr={[er]:er,[b](){let e=cr(this);return c(x(e.value),S(Oe(e.scale)),w(this))},[T](e){return nr(e)&&fr(this,e)},toString(){return`BigDecimal(${pr(this)})`},toJSON(){return{_id:`BigDecimal`,value:String(this.value),scale:this.scale}},[D](){return this.toJSON()},pipe(){return A(this,arguments)}},nr=e=>y(e,er),rr=(e,t)=>{let n=Object.create(tr);return n.value=e,n.scale=t,n},ir=(e,t)=>{if(e!==ar&&e%or===ar)throw RangeError(`Value must be normalized`);let n=rr(e,t);return n.normalized=n,n},ar= BigInt(0),or= BigInt(10),sr= ir(ar,0),cr=e=>{if(e.normalized===void 0){if(e.value===ar)e.normalized=sr;else{let t=`${e.value}`,n=0;for(let e=t.length-1;e>=0&&t[e]===`0`;e--)n++;n===0&&(e.normalized=e);let r=BigInt(t.substring(0,t.length-n)),i=e.scale-n;e.normalized=ir(r,i)}}return e.normalized},lr= t(2,(e,t)=>t>e.scale?rr(e.value*or**BigInt(t-e.scale),t):t<e.scale?rr(e.value/or**BigInt(e.scale-t),t):e),ur=e=>e.value<ar?rr(-e.value,e.scale):e,dr= l((e,t)=>e.scale>t.scale?lr(t,e.scale).value===e.value:e.scale<t.scale?lr(e,t.scale).value===t.value:e.value===t.value),fr= t(2,(e,t)=>dr(e,t)),pr=e=>{let t=cr(e);if(Math.abs(t.scale)>=16)return mr(t);let n=t.value<ar,r=n?`${t.value}`.substring(1):`${t.value}`,i,a;if(t.scale>=r.length)i=`0`,a=`0`.repeat(t.scale-r.length)+r;else{let e=r.length-t.scale;if(e>r.length){let t=e-r.length;i=`${r}${`0`.repeat(t)}`,a=``}else a=r.slice(e),i=r.slice(0,e)}let o=a===``?i:`${i}.${a}`;return n?`-${o}`:o},mr=e=>{if(hr(e))return`0e+0`;let t=cr(e),n=`${ur(t).value}`,r=n.slice(0,1),i=n.slice(1),a=`${gr(t)?`-`:``}${r}`;i!==``&&(a+=`.${i}`);let o=i.length-t.scale;return`${a}e${o>=0?`+`:``}${o}`},hr=e=>e.value===ar,gr=e=>e.value<ar,_r= Symbol.for(`effect/Chunk`);function vr(e,t,n,r,i){for(let a=t;a<Math.min(e.length,t+i);a++)n[r+a-t]=e[a];return n}const yr=[],br= (e=>l((t,n)=>t.length===n.length&&kr(t).every((t,r)=>e(t,Nr(n,r)))))(E),xr={[_r]:{_A:e=>e},toString(){return k(this.toJSON())},toJSON(){return{_id:`Chunk`,values:kr(this).map(O)}},[D](){return this.toJSON()},[T](e){return Sr(e)&&br(this,e)},[b](){return w(this,je(kr(this)))},[Symbol.iterator](){switch(this.backing._tag){case`IArray`:return this.backing.array[Symbol.iterator]();case`IEmpty`:return yr[Symbol.iterator]();default:return kr(this)[Symbol.iterator]()}},pipe(){return A(this,arguments)}},V=e=>{let t=Object.create(xr);switch(t.backing=e,e._tag){case`IEmpty`:t.length=0,t.depth=0,t.left=t,t.right=t;break;case`IConcat`:t.length=e.left.length+e.right.length,t.depth=1+Math.max(e.left.depth,e.right.depth),t.left=e.left,t.right=e.right;break;case`IArray`:t.length=e.array.length,t.depth=0,t.left=Cr,t.right=Cr;break;case`ISingleton`:t.length=1,t.depth=0,t.left=Cr,t.right=Cr;break;case`ISlice`:t.length=e.length,t.depth=e.chunk.depth+1,t.left=Cr,t.right=Cr}return t},Sr=e=>y(e,_r),Cr= V({_tag:`IEmpty`}),wr=()=>Cr,Tr=(...e)=>Mr(e),Er=e=>V({_tag:`ISingleton`,a:e}),Dr=e=>Sr(e)?e:jr(z(e)),Or=(e,t,n)=>{switch(e.backing._tag){case`IArray`:vr(e.backing.array,0,t,n,e.length);break;case`IConcat`:Or(e.left,t,n),Or(e.right,t,n+e.left.length);break;case`ISingleton`:t[n]=e.backing.a;break;case`ISlice`:{let r=0,i=n;for(;r<e.length;)t[i]=Nr(e,r),r+=1,i+=1;break}}},kr=e=>{switch(e.backing._tag){case`IEmpty`:return yr;case`IArray`:return e.backing.array;default:{let t=Array(e.length);return Or(e,t,0),e.backing={_tag:`IArray`,array:t},e.left=Cr,e.right=Cr,e.depth=0,t}}},Ar=e=>{switch(e.backing._tag){case`IEmpty`:case`ISingleton`:return e;case`IArray`:return V({_tag:`IArray`,array:Mn(e.backing.array)});case`IConcat`:return V({_tag:`IConcat`,left:Ar(e.backing.right),right:Ar(e.backing.left)});case`ISlice`:return jr(Mn(kr(e)))}},jr=e=>e.length===0?wr():e.length===1?Er(e[0]):V({_tag:`IArray`,array:e}),Mr=e=>jr(e),Nr= t(2,(e,t)=>{switch(e.backing._tag){case`IEmpty`:throw Error(`Index out of bounds`);case`ISingleton`:if(t!==0)throw Error(`Index out of bounds`);return e.backing.a;case`IArray`:if(t>=e.length||t<0)throw Error(`Index out of bounds`);return e.backing.array[t];case`IConcat`:return t<e.left.length?Nr(e.left,t):Nr(e.right,t-e.left.length);case`ISlice`:return Nr(e.backing.chunk,t+e.backing.offset)}}),Pr= t(2,(e,t)=>Lr(e,Er(t))),Fr= t(2,(e,t)=>Lr(Er(t),e)),Ir= t(2,(e,t)=>{if(t<=0)return e;if(t>=e.length)return Cr;switch(e.backing._tag){case`ISlice`:return V({_tag:`ISlice`,chunk:e.backing.chunk,offset:e.backing.offset+t,length:e.backing.length-t});case`IConcat`:return t>e.left.length?Ir(e.right,t-e.left.length):V({_tag:`IConcat`,left:Ir(e.left,t),right:e.right});default:return V({_tag:`ISlice`,chunk:e,offset:t,length:e.length-t})}}),Lr= t(2,(e,t)=>{if(e.backing._tag===`IEmpty`)return t;if(t.backing._tag===`IEmpty`)return e;let n=t.depth-e.depth;if(Math.abs(n)<=1)return V({_tag:`IConcat`,left:e,right:t});if(n<-1){if(e.left.depth>=e.right.depth){let n=Lr(e.right,t);return V({_tag:`IConcat`,left:e.left,right:n})}{let n=Lr(e.right.right,t);if(n.depth===e.depth-3){let t=V({_tag:`IConcat`,left:e.right.left,right:n});return V({_tag:`IConcat`,left:e.left,right:t})}{let t=V({_tag:`IConcat`,left:e.left,right:e.right.left});return V({_tag:`IConcat`,left:t,right:n})}}}if(t.right.depth>=t.left.depth){let n=Lr(e,t.left);return V({_tag:`IConcat`,left:n,right:t.right})}{let n=Lr(e,t.left.left);if(n.depth===t.depth-3){let e=V({_tag:`IConcat`,left:n,right:t.left.right});return V({_tag:`IConcat`,left:e,right:t.right})}{let e=V({_tag:`IConcat`,left:t.left.right,right:t.right});return V({_tag:`IConcat`,left:n,right:e})}}}),Rr=e=>e.length===0,zr=e=>e.length>0,Br=e=>Nr(e,0),Vr=Br,Hr=e=>Ir(e,1);function Ur(e){return e-=e>>1&1431655765,e=(e&858993459)+(e>>2&858993459),e=e+(e>>4)&252645135,e+=e>>8,e+=e>>16,e&127}function Wr(e,t){return t>>>e&31}function Gr(e){return 1<<e}function Kr(e,t){return Ur(e&t-1)}const qr=(e,t)=>({value:e,previous:t});function Jr(e,t,n,r){let i=r;if(!e){let e=r.length;i=Array(e);for(let t=0;t<e;++t)i[t]=r[t]}return i[t]=n,i}function Yr(e,t,n){let r=n.length-1,i=0,a=0,o=n;if(e)i=a=t;else for(o=Array(r);i<t;)o[a++]=n[i++];for(++i;i<=r;)o[a++]=n[i++];return e&&(o.length=r),o}function Xr(e,t,n,r){let i=r.length;if(e){let e=i;for(;e>=t;)r[e--]=r[e];return r[t]=n,r}let a=0,o=0,s=Array(i+1);for(;a<t;)s[o++]=r[a++];for(s[t]=n;a<i;)s[++o]=r[a++];return s}var Zr=class e{_tag=`EmptyNode`;modify(t,n,r,i,a,o){let s=r(P());return I(s)?new e:(++o.value,new ti(t,i,a,s))}};function Qr(e){return oe(e,`EmptyNode`)}function $r(e){return Qr(e)||e._tag===`LeafNode`||e._tag===`CollisionNode`}function ei(e,t){return!Qr(e)&&t===e.edit}var ti=class e{edit;hash;key;value;_tag=`LeafNode`;constructor(e,t,n,r){this.edit=e,this.hash=t,this.key=n,this.value=r}modify(t,n,r,i,a,o){if(E(a,this.key)){let n=r(this.value);return n===this.value?this:I(n)?(--o.value,new Zr):ei(this,t)?(this.value=n,this):new e(t,i,a,n)}let s=r(P());return I(s)?this:(++o.value,ci(t,n,this.hash,this,i,new e(t,i,a,s)))}},ni=class e{edit;hash;children;_tag=`CollisionNode`;constructor(e,t,n){this.edit=e,this.hash=t,this.children=n}modify(t,n,r,i,a,o){if(i===this.hash){let n=ei(this,t),i=this.updateCollisionList(n,t,this.hash,this.children,r,a,o);return i===this.children?this:i.length>1?new e(t,this.hash,i):i[0]}let s=r(P());return I(s)?this:(++o.value,ci(t,n,this.hash,this,i,new ti(t,i,a,s)))}updateCollisionList(e,t,n,r,i,a,o){let s=r.length;for(let c=0;c<s;++c){let s=r[c];if(`key`in s&&E(a,s.key)){let l=s.value,u=i(l);return u===l?r:I(u)?(--o.value,Yr(e,c,r)):Jr(e,c,new ti(t,n,a,u),r)}}let c=i(P());return I(c)?r:(++o.value,Jr(e,s,new ti(t,n,a,c),r))}},ri=class e{edit;mask;children;_tag=`IndexedNode`;constructor(e,t,n){this.edit=e,this.mask=t,this.children=n}modify(t,n,r,i,a,o){let s=this.mask,c=this.children,l=Wr(n,i),u=Gr(l),d=Kr(s,u),f=s&u,p=ei(this,t);if(!f){let f=new Zr().modify(t,n+5,r,i,a,o);return f?c.length>=16?oi(t,l,f,s,c):new e(t,s|u,Xr(p,d,f,c)):this}let m=c[d],h=m.modify(t,n+5,r,i,a,o);if(m===h)return this;let g=s,_;if(Qr(h)){if(g&=~u,!g)return new Zr;if(c.length<=2&&$r(c[d^1]))return c[d^1];_=Yr(p,d,c)}else _=Jr(p,d,h,c);return p?(this.mask=g,this.children=_,this):new e(t,g,_)}},ii=class e{edit;size;children;_tag=`ArrayNode`;constructor(e,t,n){this.edit=e,this.size=t,this.children=n}modify(t,n,r,i,a,o){let s=this.size,c=this.children,l=Wr(n,i),u=c[l],d=(u||new Zr).modify(t,n+5,r,i,a,o);if(u===d)return this;let f=ei(this,t),p;if(Qr(u)&&!Qr(d))++s,p=Jr(f,l,d,c);else if(!Qr(u)&&Qr(d)){if(--s,s<=8)return ai(t,s,l,c);p=Jr(f,l,new Zr,c)}else p=Jr(f,l,d,c);return f?(this.size=s,this.children=p,this):new e(t,s,p)}};function ai(e,t,n,r){let i=Array(t-1),a=0,o=0;for(let e=0,t=r.length;e<t;++e)if(e!==n){let t=r[e];t&&!Qr(t)&&(i[a++]=t,o|=1<<e)}return new ri(e,o,i)}function oi(e,t,n,r,i){let a=[],o=r,s=0;for(let e=0;o;++e)o&1&&(a[e]=i[s++]),o>>>=1;return a[t]=n,new ii(e,s+1,a)}function si(e,t,n,r,i,a){if(n===i)return new ni(e,n,[a,r]);let o=Wr(t,n),s=Wr(t,i);if(o===s)return t=>new ri(e,Gr(o)|Gr(s),[t]);{let t=o<s?[r,a]:[a,r];return new ri(e,Gr(o)|Gr(s),t)}}function ci(e,t,n,r,i,a){let o,s=t;for(;;){let t=si(e,s,n,r,i,a);if(typeof t==`function`)o=qr(t,o),s+=5;else{let e=t;for(;o!=null;)e=o.value(e),o=o.previous;return e}}}const li=`effect/HashMap`,ui= Symbol.for(li),di={[ui]:ui,[Symbol.iterator](){return new pi(this,(e,t)=>[e,t])},[b](){let e=x(li);for(let t of this)e^=c(x(t[0]),S(x(t[1])));return w(this,e)},[T](e){if(bi(e)){if(e._size!==this._size)return!1;for(let t of this){let n=c(e,Ci(t[0],x(t[0])));if(I(n)||!E(t[1],n.value))return!1}return!0}return!1},toString(){return k(this.toJSON())},toJSON(){return{_id:`HashMap`,values:Array.from(this).map(O)}},[D](){return this.toJSON()},pipe(){return A(this,arguments)}},fi=(e,t,n,r)=>{let i=Object.create(di);return i._editable=e,i._edit=t,i._root=n,i._size=r,i};var pi=class e{map;f;v;constructor(e,t){this.map=e,this.f=t,this.v=hi(this.map._root,this.f,void 0)}next(){if(I(this.v))return{done:!0,value:void 0};let e=this.v.value;return this.v=mi(e.cont),{done:!1,value:e.value}}[Symbol.iterator](){return new e(this.map,this.f)}};const mi=e=>e?gi(e[0],e[1],e[2],e[3],e[4]):P(),hi=(e,t,n=void 0)=>{switch(e._tag){case`LeafNode`:return L(e.value)?F({value:t(e.key,e.value.value),cont:n}):mi(n);case`CollisionNode`:case`ArrayNode`:case`IndexedNode`:{let r=e.children;return gi(r.length,r,0,t,n)}default:return mi(n)}},gi=(e,t,n,r,i)=>{for(;n<e;){let a=t[n++];if(a&&!Qr(a))return hi(a,r,[e,t,n,r,i])}return mi(i)},_i= fi(!1,0, new Zr,0),vi=()=>_i,yi=e=>{let t=ki(vi());for(let n of e)Ti(t,n[0],n[1]);return Ai(t)},bi=e=>y(e,ui),xi=e=>e&&Qr(e._root),Si= t(2,(e,t)=>Ci(e,t,x(t))),Ci= t(3,(e,t,n)=>{let r=e._root,i=0;for(;;)switch(r._tag){case`LeafNode`:return E(t,r.key)?r.value:P();case`CollisionNode`:if(n===r.hash){let e=r.children;for(let n=0,r=e.length;n<r;++n){let r=e[n];if(`key`in r&&E(t,r.key))return r.value}}return P();case`IndexedNode`:{let e=Gr(Wr(i,n));if(r.mask&e){r=r.children[Kr(r.mask,e)],i+=5;break}return P()}case`ArrayNode`:if(r=r.children[Wr(i,n)],r){i+=5;break}return P();default:return P()}}),wi= t(2,(e,t)=>L(Ci(e,t,x(t)))),Ti= t(3,(e,t,n)=>ji(e,t,()=>F(n))),Ei= t(3,(e,t,n)=>e._editable?(e._root=t,e._size=n,e):t===e._root?e:fi(e._editable,e._edit,t,n)),Di=e=>new pi(e,e=>e),Oi=e=>e._size,ki=e=>fi(!0,e._edit+1,e._root,e._size),Ai=e=>(e._editable=!1,e),ji= t(3,(e,t,n)=>Mi(e,t,x(t),n)),Mi= t(4,(e,t,n,r)=>{let i={value:e._size},a=e._root.modify(e._editable?e._edit:NaN,0,r,n,t,i);return c(e,Ei(a,i.value))}),Ni= t(2,(e,t)=>ji(e,t,P)),Pi= t(2,(e,t)=>Ii(e,vi(),(e,n,r)=>Ti(e,r,t(n,r)))),Fi= t(2,(e,t)=>Ii(e,void 0,(e,n,r)=>t(n,r))),Ii= t(3,(e,t,n)=>{let r=e._root;if(r._tag===`LeafNode`)return L(r.value)?n(t,r.value.value,r.key):t;if(r._tag===`EmptyNode`)return t;let i=[r.children],a;for(;a=i.pop();)for(let e=0,r=a.length;e<r;){let r=a[e++];r&&!Qr(r)&&(r._tag===`LeafNode`?L(r.value)&&(t=n(t,r.value.value,r.key)):i.push(r.children))}return t}),Li=`effect/HashSet`,Ri= Symbol.for(Li),zi={[Ri]:Ri,[Symbol.iterator](){return Di(this._keyMap)},[b](){return w(this,S(x(this._keyMap))(x(Li)))},[T](e){return Vi(e)?Oi(this._keyMap)===Oi(e._keyMap)&&E(this._keyMap,e._keyMap):!1},toString(){return k(this.toJSON())},toJSON(){return{_id:`HashSet`,values:Array.from(this).map(O)}},[D](){return this.toJSON()},pipe(){return A(this,arguments)}},Bi=e=>{let t=Object.create(zi);return t._keyMap=e,t},Vi=e=>y(e,Ri),Hi= Bi( vi()),Ui=()=>Hi,Wi=e=>{let t=Ji(Ui());for(let n of e)Zi(t,n);return Yi(t)},Gi=(...e)=>{let t=Ji(Ui());for(let n of e)Zi(t,n);return Yi(t)},Ki= t(2,(e,t)=>wi(e._keyMap,t)),qi=e=>Oi(e._keyMap),Ji=e=>Bi(ki(e._keyMap)),Yi=e=>(e._keyMap._editable=!1,e),Xi= t(2,(e,t)=>{let n=Ji(e);return t(n),Yi(n)}),Zi= t(2,(e,t)=>e._keyMap._editable?(Ti(t,!0)(e._keyMap),e):Bi(Ti(t,!0)(e._keyMap))),Qi= t(2,(e,t)=>e._keyMap._editable?(Ni(t)(e._keyMap),e):Bi(Ni(t)(e._keyMap))),$i= t(2,(e,t)=>Xi(e,e=>{for(let n of t)Qi(e,n)})),ea= t(2,(e,t)=>Xi(Ui(),n=>{ta(e,e=>Zi(n,e));for(let e of t)Zi(n,e)})),ta= t(2,(e,t)=>Fi(e._keyMap,(e,n)=>t(n))),na= t(3,(e,t,n)=>Ii(e._keyMap,t,(e,t,r)=>n(e,r))),ra=Ui,ia=Wi,aa=Gi,oa=Ki,sa=qi,ca=Zi,la=Qi,ua=$i,da=ea,fa=na,pa=`Empty`,ma=`Fail`,ha=`Interrupt`,ga=`Parallel`,_a=`Sequential`,va=`effect/Cause`,ya= Symbol.for(va),ba={
_E:e=>e},xa={[ya]:ba,[b](){return c(x(va),S(x(Ua(this))),w(this))},[T](e){return Oa(e)&&Ha(this,e)},pipe(){return A(this,arguments)},toJSON(){switch(this._tag){case`Empty`:return{_id:`Cause`,_tag:this._tag};case`Die`:return{_id:`Cause`,_tag:this._tag,defect:O(this.defect)};case`Interrupt`:return{_id:`Cause`,_tag:this._tag,fiberId:this.fiberId.toJSON()};case`Fail`:return{_id:`Cause`,_tag:this._tag,failure:O(this.error)};case`Sequential`:case`Parallel`:return{_id:`Cause`,_tag:this._tag,left:O(this.left),right:O(this.right)}}},toString(){return $a(this)},[D](){return this.toJSON()}},Sa= (()=>{let e= Object.create(xa);return e._tag=pa,e})(),Ca=e=>{let t=Object.create(xa);return t._tag=ma,t.error=e,t},wa=e=>{let t=Object.create(xa);return t._tag=`Die`,t.defect=e,t},Ta=e=>{let t=Object.create(xa);return t._tag=ha,t.fiberId=e,t},Ea=(e,t)=>{let n=Object.create(xa);return n._tag=ga,n.left=e,n.right=t,n},Da=(e,t)=>{let n=Object.create(xa);return n._tag=_a,n.left=e,n.right=t,n},Oa=e=>y(e,ya),ka=e=>e._tag===pa,Aa=e=>e._tag===ma,ja=e=>e._tag===`Empty`||Za(e,!0,(e,t)=>{switch(t._tag){case pa:return F(e);case`Die`:case ma:case ha:return F(!1);default:return P()}}),Ma=e=>L(za(e)),Na=e=>Qa(void 0,qa)(e),Pa=e=>Ar(Za(e,wr(),(e,t)=>t._tag===`Fail`?F(c(e,Fr(t.error))):P())),Fa=e=>Ar(Za(e,wr(),(e,t)=>t._tag===`Die`?F(c(e,Fr(t.defect))):P())),Ia=e=>Za(e,ra(),(e,t)=>t._tag===`Interrupt`?F(c(e,ca(t.fiberId))):P()),La=e=>Ga(e,e=>e._tag===`Fail`?F(e.error):P()),Ra=e=>{let t=La(e);switch(t._tag){case`None`:return j(e);case`Some`:return M(t.value)}},za=e=>Ga(e,e=>e._tag===`Interrupt`?F(e.fiberId):P()),Ba=e=>Xa(e,{onEmpty:Sa,onFail:()=>Sa,onDie:wa,onInterrupt:Ta,onSequential:Da,onParallel:Ea}),Va=e=>Xa(e,{onEmpty:Sa,onFail:wa,onDie:wa,onInterrupt:Ta,onSequential:Da,onParallel:Ea}),Ha=(e,t)=>{let n=Er(e),r=Er(t);for(;zr(n)&&zr(r);){let[e,t]=c(Vr(n),Za([ra(),wr()],([e,t],n)=>{let[r,i]=Ka(n);return F([c(e,da(r)),c(t,Lr(i))])})),[i,a]=c(Vr(r),Za([ra(),wr()],([e,t],n)=>{let[r,i]=Ka(n);return F([c(e,da(r)),c(t,Lr(i))])}));if(!E(e,i))return!1;n=t,r=a}return!0},Ua=e=>Wa(Er(e),wr()),Wa=(e,t)=>{for(;;){let[n,r]=c(e,Jn([ra(),wr()],([e,t],n)=>{let[r,i]=Ka(n);return[c(e,da(r)),c(t,Lr(i))]})),i=sa(n)>0?c(t,Fr(n)):t;if(Rr(r))return Ar(i);e=r,t=i}throw Error(pe(`Cause.flattenCauseLoop`))},Ga= t(2,(e,t)=>{let n=[e];for(;n.length>0;){let e=n.pop(),r=t(e);switch(r._tag){case`None`:switch(e._tag){case _a:case ga:n.push(e.right),n.push(e.left)}break;case`Some`:return r}}return P()}),Ka=e=>{let t=e,n=[],r=ra(),i=wr();for(;t!==void 0;)switch(t._tag){case pa:if(n.length===0)return[r,i];t=n.pop();break;case ma:if(r=ca(r,Tr(t._tag,t.error)),n.length===0)return[r,i];t=n.pop();break;case`Die`:if(r=ca(r,Tr(t._tag,t.defect)),n.length===0)return[r,i];t=n.pop();break;case ha:if(r=ca(r,Tr(t._tag,t.fiberId)),n.length===0)return[r,i];t=n.pop();break;case _a:switch(t.left._tag){case pa:t=t.right;break;case _a:t=Da(t.left.left,Da(t.left.right,t.right));break;case ga:t=Ea(Da(t.left.left,t.right),Da(t.left.right,t.right));break;default:i=Fr(i,t.right),t=t.left}break;case ga:n.push(t.right),t=t.left}throw Error(pe(`Cause.evaluateCauseLoop`))},qa={emptyCase:i,failCase:a,dieCase:a,interruptCase:i,sequentialCase:(e,t,n)=>t&&n,parallelCase:(e,t,n)=>t&&n},Ja=`SequentialCase`,Ya=`ParallelCase`,Xa= t(2,(e,{onDie:t,onEmpty:n,onFail:r,onInterrupt:i,onParallel:a,onSequential:o})=>Qa(e,void 0,{emptyCase:()=>n,failCase:(e,t)=>r(t),dieCase:(e,n)=>t(n),interruptCase:(e,t)=>i(t),sequentialCase:(e,t,n)=>o(t,n),parallelCase:(e,t,n)=>a(t,n)})),Za= t(3,(e,t,n)=>{let r=t,i=e,a=[];for(;i!==void 0;){let e=n(r,i);switch(r=L(e)?e.value:r,i._tag){case _a:a.push(i.right),i=i.left;break;case ga:a.push(i.right),i=i.left;break;default:i=void 0}i===void 0&&a.length>0&&(i=a.pop())}return r}),Qa= t(3,(e,t,n)=>{let r=[e],i=[];for(;r.length>0;){let e=r.pop();switch(e._tag){case pa:i.push(j(n.emptyCase(t)));break;case ma:i.push(j(n.failCase(t,e.error)));break;case`Die`:i.push(j(n.dieCase(t,e.defect)));break;case ha:i.push(j(n.interruptCase(t,e.fiberId)));break;case _a:r.push(e.right),r.push(e.left),i.push(M({_tag:Ja}));break;case ga:r.push(e.right),r.push(e.left),i.push(M({_tag:Ya}))}}let a=[];for(;i.length>0;){let e=i.pop();switch(e._tag){case`Left`:switch(e.left._tag){case Ja:{let e=a.pop(),r=a.pop(),i=n.sequentialCase(t,e,r);a.push(i);break}case Ya:{let e=a.pop(),r=a.pop(),i=n.parallelCase(t,e,r);a.push(i);break}}break;case`Right`:a.push(e.right)}}if(a.length===0)throw Error(`BUG: Cause.reduceWithContext - please report an issue at https://github.com/Effect-TS/effect/issues`);return a.pop()}),$a=(e,t)=>Na(e)?`All fibers interrupted without errors.`:so(e).map(function(e){return t?.renderErrorCause!==!0||e.cause===void 0?e.stack:`${e.stack} {\n${eo(e.cause,` `)}\n}`}).join(`
`),eo=(e,t)=>{let n=e.stack.split(`
`),r=`${t}[cause]: ${n[0]}`;for(let e=1,i=n.length;e<i;e++)r+=`\n${t}${n[e]}`;return e.cause&&(r+=` {\n${eo(e.cause,`${t} `)}\n${t}}`),r},to=e=>{let t=typeof e==`object`&&!!e,n=Error.stackTraceLimit;Error.stackTraceLimit=1;let r=Error(no(e),t&&`cause`in e&&e.cause!==void 0?{cause:to(e.cause)}:void 0);return Error.stackTraceLimit=n,r.message===``&&(r.message=`An error has occurred`),Error.stackTraceLimit=n,r.name=e instanceof Error?e.name:`Error`,t&&(oo in e&&(r.span=e[oo]),Object.keys(e).forEach(t=>{t in r||(r[t]=e[t])})),r.stack=ao(`${r.name}: ${r.message}`,e instanceof Error&&e.stack?e.stack:``,r.span),r},no=e=>{if(typeof e==`string`)return e;if(typeof e==`object`&&e&&e instanceof Error)return e.message;try{if(y(e,`toString`)&&te(e.toString)&&e.toString!==Object.prototype.toString&&e.toString!==globalThis.Array.prototype.toString)return e.toString()}catch{}return Ve(e)},ro=/\((.*)\)/g,io= m(`effect/Tracer/spanToTrace`,()=> new WeakMap),ao=(e,t,n)=>{let r=[e],i=t.startsWith(e)?t.slice(e.length).split(`
`):t.split(`
`);for(let e=1;e<i.length;e++){if(i[e].includes(` at new BaseEffectError`)||i[e].includes(` at new YieldableError`)){e++;continue}if(i[e].includes(`Generator.next`)||i[e].includes(`effect_internal_function`))break;r.push(i[e].replace(/at .*effect_instruction_i.*\((.*)\)/,`at $1`).replace(/EffectPrimitive\.\w+/,`<anonymous>`))}if(n){let e=n,t=0;for(;e&&e._tag===`Span`&&t<10;){let n=io.get(e);if(typeof n==`function`){let t=n();if(typeof t==`string`){let n=t.matchAll(ro),i=!1;for(let[,t]of n)i=!0,r.push(` at ${e.name} (${t})`);i||r.push(` at ${e.name} (${t.replace(/^at /,``)})`)}else r.push(` at ${e.name}`)}else r.push(` at ${e.name}`);e=tn(e.parent),t++}}return r.join(`
`)},oo= Symbol.for(`effect/SpanAnnotation`),so=e=>Qa(e,void 0,{emptyCase:()=>[],dieCase:(e,t)=>[to(t)],failCase:(e,t)=>[to(t)],interruptCase:()=>[],parallelCase:(e,t,n)=>[...t,...n],sequentialCase:(e,t,n)=>[...t,...n]}),co= Symbol.for(`effect/Context/Tag`),lo= Symbol.for(`effect/Context/Reference`),uo= Symbol.for(`effect/STM`),fo={...ht,_op:`Tag`,[uo]:ft,[co]:{_Service:e=>e,_Identifier:e=>e},toString(){return k(this.toJSON())},toJSON(){return{_id:`Tag`,key:this.key,stack:this.stack}},[D](){return this.toJSON()},of(e){return e},context(e){return wo(this,e)}},po={...fo,[lo]:lo},mo=e=>{let t=Error.stackTraceLimit;Error.stackTraceLimit=2;let n= Error();Error.stackTraceLimit=t;let r=Object.create(fo);return Object.defineProperty(r,"stack",{get(){return n.stack}}),r.key=e,r},ho=()=>(e,t)=>{let n=Error.stackTraceLimit;Error.stackTraceLimit=2;let r= Error();Error.stackTraceLimit=n;function i(){}return Object.setPrototypeOf(i,po),i.key=e,i.defaultValue=t.defaultValue,Object.defineProperty(i,"stack",{get(){return r.stack}}),i},go= Symbol.for(`effect/Context`),_o={[go]:{_Services:e=>e},[T](e){if(bo(e)&&this.unsafeMap.size===e.unsafeMap.size){for(let t of this.unsafeMap.keys())if(!e.unsafeMap.has(t)||!E(this.unsafeMap.get(t),e.unsafeMap.get(t)))return!1;return!0}return!1},[b](){return w(this,Oe(this.unsafeMap.size))},pipe(){return A(this,arguments)},toString(){return k(this.toJSON())},toJSON(){return{_id:`Context`,services:Array.from(this.unsafeMap).map(O)}},[D](){return this.toJSON()}},vo=e=>{let t=Object.create(_o);return t.unsafeMap=e,t},yo=e=>{let t= Error(`Service not found${e.key?`: ${String(e.key)}`:``}`);if(e.stack){let n=e.stack.split(`
`);if(n.length>2){let e=n[2].match(/at (.*)/);e&&(t.message+=` (defined at ${e[1]})`)}}if(t.stack){let e=t.stack.split(`
`);e.splice(1,3),t.stack=e.join(`
`)}return t},bo=e=>y(e,go),xo=e=>y(e,lo),So= vo( new Map),Co=()=>So,wo=(e,t)=>vo( new Map([[e.key,t]])),To= t(3,(e,t,n)=>{let r=new Map(e.unsafeMap);return r.set(t.key,n),vo(r)}),Eo= m(`effect/Context/defaultValueCache`,()=> new Map),Do=e=>{if(Eo.has(e.key))return Eo.get(e.key);let t=e.defaultValue();return Eo.set(e.key,t),t},Oo=(e,t)=>e.unsafeMap.has(t.key)?e.unsafeMap.get(t.key):Do(t),ko= t(2,(e,t)=>{if(!e.unsafeMap.has(t.key)){if(lo in t)return Do(t);throw yo(t)}return e.unsafeMap.get(t.key)}),Ao=ko,jo= t(2,(e,t)=>e.unsafeMap.has(t.key)?kt(e.unsafeMap.get(t.key)):xo(t)?kt(Do(t)):Ot),Mo= t(2,(e,t)=>{let n=new Map(e.unsafeMap);for(let[e,r]of t.unsafeMap)n.set(e,r);return vo(n)}),No=mo,Po=Co,Fo=wo,Io=To,Lo=Ao,Ro=ko,zo=jo,Bo=Mo,Vo=ho,Ho= Symbol.for(`effect/Duration`),Uo= BigInt(0),Wo= BigInt(24),Go= BigInt(60),Ko= BigInt(1e3),qo= BigInt(1e6),Jo= BigInt(1e9),Yo=/^(-?\d+(?:\.\d+)?)\s+(nanos?|micros?|millis?|seconds?|minutes?|hours?|days?|weeks?)$/,Xo=e=>{if(ts(e))return e;if(g(e))return ss(e);if(v(e))return as(e);if(Array.isArray(e)&&e.length===2&&e.every(g))return e[0]===-1/0||e[1]===-1/0||Number.isNaN(e[0])||Number.isNaN(e[1])?rs:e[0]===1/0||e[1]===1/0?is:as(BigInt(Math.round(e[0]*1e9))+BigInt(Math.round(e[1])));if(h(e)){let t=Yo.exec(e);if(t){let[e,n,r]=t,i=Number(n);switch(r){case`nano`:case`nanos`:return as(BigInt(n));case`micro`:case`micros`:return os(BigInt(n));case`milli`:case`millis`:return ss(i);case`second`:case`seconds`:return cs(i);case`minute`:case`minutes`:return ls(i);case`hour`:case`hours`:return us(i);case`day`:case`days`:return ds(i);case`week`:case`weeks`:return fs(i)}}}throw Error(`Invalid DurationInput`)},Zo={_tag:`Millis`,millis:0},Qo={_tag:`Infinity`},$o={[Ho]:Ho,[b](){return w(this,Ae(this.value))},[T](e){return ts(e)&&xs(this,e)},toString(){return`Duration(${Cs(this)})`},toJSON(){switch(this.value._tag){case`Millis`:return{_id:`Duration`,_tag:`Millis`,millis:this.value.millis};case`Nanos`:return{_id:`Duration`,_tag:`Nanos`,hrtime:hs(this)};case`Infinity`:return{_id:`Duration`,_tag:`Infinity`}}},[D](){return this.toJSON()},pipe(){return A(this,arguments)}},es=e=>{let t=Object.create($o);return t.value=g(e)?isNaN(e)||e<=0?Zo:Number.isFinite(e)?Number.isInteger(e)?{_tag:`Millis`,millis:e}:{_tag:`Nanos`,nanos:BigInt(Math.round(e*1e6))}:Qo:e<=Uo?Zo:{_tag:`Nanos`,nanos:e},t},ts=e=>y(e,Ho),ns=e=>{switch(e.value._tag){case`Millis`:return e.value.millis===0;case`Nanos`:return e.value.nanos===Uo;case`Infinity`:return!1}},rs= es(0),is= es(1/0),as=e=>es(e),os=e=>es(e*Ko),ss=e=>es(e),cs=e=>es(e*1e3),ls=e=>es(e*6e4),us=e=>es(e*36e5),ds=e=>es(e*864e5),fs=e=>es(e*6048e5),ps=e=>gs(e,{onMillis:e=>e,onNanos:e=>Number(e)/1e6}),ms=e=>{let t=Xo(e);switch(t.value._tag){case`Infinity`:throw Error(`Cannot convert infinite duration to nanos`);case`Nanos`:return t.value.nanos;case`Millis`:return BigInt(Math.round(t.value.millis*1e6))}},hs=e=>{let t=Xo(e);switch(t.value._tag){case`Infinity`:return[1/0,0];case`Nanos`:return[Number(t.value.nanos/Jo),Number(t.value.nanos%Jo)];case`Millis`:return[Math.floor(t.value.millis/1e3),Math.round(t.value.millis%1e3*1e6)]}},gs= t(2,(e,t)=>{let n=Xo(e);switch(n.value._tag){case`Nanos`:return t.onNanos(n.value.nanos);case`Infinity`:return t.onMillis(1/0);case`Millis`:return t.onMillis(n.value.millis)}}),_s= t(3,(e,t,n)=>{let r=Xo(e),i=Xo(t);if(r.value._tag===`Infinity`||i.value._tag===`Infinity`)return n.onMillis(ps(r),ps(i));if(r.value._tag===`Nanos`||i.value._tag===`Nanos`){let e=r.value._tag===`Nanos`?r.value.nanos:BigInt(Math.round(r.value.millis*1e6)),t=i.value._tag===`Nanos`?i.value.nanos:BigInt(Math.round(i.value.millis*1e6));return n.onNanos(e,t)}return n.onMillis(r.value.millis,i.value.millis)}),vs=(e,t)=>_s(e,t,{onMillis:(e,t)=>e===t,onNanos:(e,t)=>e===t}),ys= t(2,(e,t)=>_s(e,t,{onMillis:(e,t)=>e<=t,onNanos:(e,t)=>e<=t})),bs= t(2,(e,t)=>_s(e,t,{onMillis:(e,t)=>e>=t,onNanos:(e,t)=>e>=t})),xs= t(2,(e,t)=>vs(Xo(e),Xo(t))),Ss=e=>{let t=Xo(e);if(t.value._tag===`Infinity`)return{days:1/0,hours:1/0,minutes:1/0,seconds:1/0,millis:1/0,nanos:1/0};let n=ms(t),r=n/qo,i=r/Ko,a=i/Go,o=a/Go,s=o/Wo;return{days:Number(s),hours:Number(o%Wo),minutes:Number(a%Go),seconds:Number(i%Go),millis:Number(r%Ko),nanos:Number(n%qo)}},Cs=e=>{let t=Xo(e);if(t.value._tag===`Infinity`)return`Infinity`;if(ns(t))return`0`;let n=Ss(t),r=[];return n.days!==0&&r.push(`${n.days}d`),n.hours!==0&&r.push(`${n.hours}h`),n.minutes!==0&&r.push(`${n.minutes}m`),n.seconds!==0&&r.push(`${n.seconds}s`),n.millis!==0&&r.push(`${n.millis}ms`),n.nanos!==0&&r.push(`${n.nanos}ns`),r.join(` `)},ws= Symbol.for(`effect/MutableRef`),Ts={[ws]:ws,toString(){return k(this.toJSON())},toJSON(){return{_id:`MutableRef`,current:O(this.current)}},[D](){return this.toJSON()},pipe(){return A(this,arguments)}},Es=e=>{let t=Object.create(Ts);return t.current=e,t},Ds=e=>e.current,Os= t(2,(e,t)=>(e.current=t,e)),ks=`effect/FiberId`,As= Symbol.for(ks),js=`None`,Ms=`Runtime`,Ns= C(`${ks}-${js}`);var Ps=class{[As]=As;_tag=js;id=-1;startTimeMillis=-1;[b](){return Ns}[T](e){return Ls(e)&&e._tag===js}toString(){return k(this.toJSON())}toJSON(){return{_id:`FiberId`,_tag:this._tag}}[D](){return this.toJSON()}},Fs=class{id;startTimeMillis;[As]=As;_tag=Ms;constructor(e,t){this.id=e,this.startTimeMillis=t}[b](){return w(this,C(`${ks}-${this._tag}-${this.id}-${this.startTimeMillis}`))}[T](e){return Ls(e)&&e._tag===Ms&&this.id===e.id&&this.startTimeMillis===e.startTimeMillis}toString(){return k(this.toJSON())}toJSON(){return{_id:`FiberId`,_tag:this._tag,id:this.id,startTimeMillis:this.startTimeMillis}}[D](){return this.toJSON()}};const Is= new Ps,Ls=e=>y(e,As),Rs=e=>{switch(e._tag){case js:return ra();case Ms:return aa(e.id);case`Composite`:return c(Rs(e.left),da(Rs(e.right)))}},zs= m( Symbol.for(`effect/Fiber/Id/_fiberCounter`),()=>Es(0)),Bs=e=>Array.from(Rs(e)).map(e=>`#${e}`).join(`,`),Vs=()=>{let e=Ds(zs);return c(zs,Os(e+1)),new Fs(e,Date.now())},Hs=Is,Us=Bs,Ws=Vs,Gs=vi,Ks=yi,qs=xi,Js=Si,Ys=Ti,Xs=Di,Zs=ji,Qs=Pi,$s=Ii,ec= Symbol.for(`effect/List`),tc=e=>z(e),nc= (e=>u(Xn(e),tc))(E),rc={[ec]:ec,_tag:`Cons`,toString(){return k(this.toJSON())},toJSON(){return{_id:`List`,_tag:`Cons`,values:tc(this).map(O)}},[D](){return this.toJSON()},[T](e){return sc(e)&&this._tag===e._tag&&nc(this,e)},[b](){return w(this,je(tc(this)))},[Symbol.iterator](){let e=!1,t=this;return{next(){if(e)return this.return();if(t._tag===`Nil`)return e=!0,this.return();let n=t.head;return t=t.tail,{done:e,value:n}},return(t){return e||=!0,{done:!0,value:t}}}},pipe(){return A(this,arguments)}},ic=(e,t)=>{let n=Object.create(rc);return n.head=e,n.tail=t,n},ac= C(`Nil`),oc= Object.create({[ec]:ec,_tag:`Nil`,toString(){return k(this.toJSON())},toJSON(){return{_id:`List`,_tag:`Nil`}},[D](){return this.toJSON()},[b](){return ac},[T](e){return sc(e)&&this._tag===e._tag},[Symbol.iterator](){return{next(){return{done:!0,value:void 0}}}},pipe(){return A(this,arguments)}}),sc=e=>y(e,ec),cc=e=>e._tag===`Nil`,lc=e=>e._tag===`Cons`,uc=()=>oc,dc=(e,t)=>ic(e,t),fc=uc,pc=e=>ic(e,oc),mc= t(2,(e,t)=>gc(t,e)),hc= t(2,(e,t)=>dc(t,e)),gc= t(2,(e,t)=>{if(cc(e))return t;if(cc(t))return e;{let n=ic(t.head,e),r=n,i=t.tail;for(;!cc(i);){let t=ic(i.head,e);r.tail=t,r=t,i=i.tail}return n}}),_c= t(3,(e,t,n)=>{let r=t,i=e;for(;!cc(i);)r=n(r,i.head),i=i.tail;return r}),vc=e=>{let t=fc(),n=e;for(;!cc(n);)t=hc(t,n.head),n=n.tail;return t};Array.prototype;const yc= function(){function e(e){e&&Object.assign(this,e)}return e.prototype=gt,e}(),bc= Symbol.for(`effect/DifferContextPatch`);function xc(e){return e}const Sc={...yc.prototype,[bc]:{_Value:xc,_Patch:xc}},Cc= Object.create( Object.assign( Object.create(Sc),{_tag:`Empty`})),wc=()=>Cc,Tc= Object.assign( Object.create(Sc),{_tag:`AndThen`}),Ec=(e,t)=>{let n=Object.create(Tc);return n.first=e,n.second=t,n},Dc= Object.assign( Object.create(Sc),{_tag:`AddService`}),Oc=(e,t)=>{let n=Object.create(Dc);return n.key=e,n.service=t,n},kc= Object.assign( Object.create(Sc),{_tag:`RemoveService`}),Ac=e=>{let t=Object.create(kc);return t.key=e,t},jc= Object.assign( Object.create(Sc),{_tag:`UpdateService`}),Mc=(e,t)=>{let n=Object.create(jc);return n.key=e,n.update=t,n},Nc=(e,t)=>{let n=new Map(e.unsafeMap),r=wc();for(let[e,i]of t.unsafeMap.entries())if(n.has(e)){let t=n.get(e);n.delete(e),E(t,i)||(r=Pc(Mc(e,()=>i))(r))}else n.delete(e),r=Pc(Oc(e,i))(r);for(let[e]of n.entries())r=Pc(Ac(e))(r);return r},Pc= t(2,(e,t)=>Ec(e,t)),Fc= t(2,(e,t)=>{if(e._tag===`Empty`)return t;let n=!1,r=Er(e),i=new Map(t.unsafeMap);for(;zr(r);){let e=Vr(r),t=Hr(r);switch(e._tag){case`Empty`:r=t;break;case`AddService`:i.set(e.key,e.service),r=t;break;case`AndThen`:r=Fr(Fr(t,e.second),e.first);break;case`RemoveService`:i.delete(e.key),r=t;break;case`UpdateService`:i.set(e.key,e.update(i.get(e.key))),n=!0,r=t}}if(!n)return vo(i);let a= new Map;for(let[e]of t.unsafeMap)i.has(e)&&(a.set(e,i.get(e)),i.delete(e));for(let[e,t]of i)a.set(e,t);return vo(a)}),Ic= Symbol.for(`effect/DifferHashSetPatch`);function Lc(e){return e}const Rc={...yc.prototype,[Ic]:{_Value:Lc,_Key:Lc,_Patch:Lc}},zc= Object.create( Object.assign( Object.create(Rc),{_tag:`Empty`})),Bc=()=>zc,Vc= Object.assign( Object.create(Rc),{_tag:`AndThen`}),Hc=(e,t)=>{let n=Object.create(Vc);return n.first=e,n.second=t,n},Uc= Object.assign( Object.create(Rc),{_tag:`Add`}),Wc=e=>{let t=Object.create(Uc);return t.value=e,t},Gc= Object.assign( Object.create(Rc),{_tag:`Remove`}),Kc=e=>{let t=Object.create(Gc);return t.value=e,t},qc=(e,t)=>{let[n,r]=fa([e,Bc()],([e,t],n)=>oa(n)(e)?[la(n)(e),t]:[e,Jc(Wc(n))(t)])(t);return fa(r,(e,t)=>Jc(Kc(t))(e))(n)},Jc= t(2,(e,t)=>Hc(e,t)),Yc= t(2,(e,t)=>{if(e._tag===`Empty`)return t;let n=t,r=Er(e);for(;zr(r);){let e=Vr(r),t=Hr(r);switch(e._tag){case`Empty`:r=t;break;case`AndThen`:r=Fr(e.first)(Fr(e.second)(t));break;case`Add`:n=ca(e.value)(n),r=t;break;case`Remove`:n=la(e.value)(n),r=t}}return n}),Xc= Symbol.for(`effect/DifferReadonlyArrayPatch`);function Zc(e){return e}const Qc={...yc.prototype,[Xc]:{_Value:Zc,_Patch:Zc}},$c= Object.create( Object.assign( Object.create(Qc),{_tag:`Empty`})),el=()=>$c,tl= Object.assign( Object.create(Qc),{_tag:`AndThen`}),nl=(e,t)=>{let n=Object.create(tl);return n.first=e,n.second=t,n},rl= Object.assign( Object.create(Qc),{_tag:`Append`}),il=e=>{let t=Object.create(rl);return t.values=e,t},al= Object.assign( Object.create(Qc),{_tag:`Slice`}),ol=(e,t)=>{let n=Object.create(al);return n.from=e,n.until=t,n},sl= Object.assign( Object.create(Qc),{_tag:`Update`}),cl=(e,t)=>{let n=Object.create(sl);return n.index=e,n.patch=t,n},ll=e=>{let t=0,n=el();for(;t<e.oldValue.length&&t<e.newValue.length;){let r=e.oldValue[t],i=e.newValue[t],a=e.differ.diff(r,i);E(a,e.differ.empty)||(n=ul(n,cl(t,a))),t+=1}return t<e.oldValue.length&&(n=ul(n,ol(0,t))),t<e.newValue.length&&(n=ul(n,il(jn(t)(e.newValue)))),n},ul= t(2,(e,t)=>nl(e,t)),dl= t(3,(e,t,n)=>{if(e._tag===`Empty`)return t;let r=t.slice(),i=Un(e);for(;yn(i);){let e=Tn(i),t=On(i);switch(e._tag){case`Empty`:i=t;break;case`AndThen`:t.unshift(e.first,e.second),i=t;break;case`Append`:for(let t of e.values)r.push(t);i=t;break;case`Slice`:r=r.slice(e.from,e.until),i=t;break;case`Update`:r[e.index]=n.patch(e.patch,r[e.index]),i=t}}return r}),fl={[ Symbol.for(`effect/Differ`)]:{_P:n,_V:n},pipe(){return A(this,arguments)}},pl=e=>{let t=Object.create(fl);return t.empty=e.empty,t.diff=e.diff,t.combine=e.combine,t.patch=e.patch,t},ml=()=>pl({empty:wc(),combine:(e,t)=>Pc(t)(e),diff:(e,t)=>Nc(e,t),patch:(e,t)=>Fc(t)(e)}),hl=()=>pl({empty:Bc(),combine:(e,t)=>Jc(t)(e),diff:(e,t)=>qc(e,t),patch:(e,t)=>Yc(t)(e)}),gl=e=>pl({empty:el(),combine:(e,t)=>ul(e,t),diff:(t,n)=>ll({oldValue:t,newValue:n,differ:e}),patch:(t,n)=>dl(t,n,e)}),_l=()=>vl((e,t)=>t),vl=e=>pl({empty:n,combine:(e,t)=>e===n?t:t===n?e:n=>t(e(n)),diff:(e,t)=>E(e,t)?n:r(t),patch:(t,n)=>e(n,t(n))}),yl=e=>e&255,bl=e=>e>>8&255,xl=(e,t)=>(e&255)+((t&e&255)<<8),Sl= xl(0,0),Cl=e=>xl(e,e),wl=e=>xl(e,0),Tl= t(2,(e,t)=>xl(yl(e)&~t,bl(e))),El= t(2,(e,t)=>e|t),Dl=e=>~e>>>0&255,Ol=e=>Ml(e,32),kl= t(2,(e,t)=>e|t),Al=e=>jl(e)&&!Il(e),jl=e=>Ml(e,1),Ml= t(2,(e,t)=>(e&t)!==0),Nl=(...e)=>e.reduce((e,t)=>e|t,0),Pl= Nl(0),Fl=e=>Ml(e,4),Il=e=>Ml(e,16),Ll= t(2,(e,t)=>xl(e^t,t)),Rl= t(2,(e,t)=>e&(Dl(yl(t))|bl(t))|yl(t)&bl(t)),zl= pl({empty:Sl,diff:(e,t)=>Ll(e,t),combine:(e,t)=>El(t)(e),patch:(e,t)=>Rl(t,e)}),Bl=Cl,Vl=wl,Hl=Tl,Ul=(e,t)=>({_tag:`Par`,left:e,right:t}),Wl=(e,t)=>({_tag:`Seq`,left:e,right:t}),Gl=e=>{let t=pc(e),n=fc();for(;;){let[e,r]=_c(t,[Zl(),fc()],([e,t],n)=>{let[r,i]=Kl(n);return[$l(e,r),mc(t,i)]});if(n=ql(n,e),cc(r))return vc(n);t=r}throw Error(`BUG: BlockedRequests.flatten - please report an issue at https://github.com/Effect-TS/effect/issues`)},Kl=e=>{let t=e,n=Zl(),r=fc(),i=fc();for(;;)switch(t._tag){case`Empty`:if(cc(r))return[n,i];t=r.head,r=r.tail;break;case`Par`:r=dc(t.right,r),t=t.left;break;case`Seq`:{let e=t.left,n=t.right;switch(e._tag){case`Empty`:t=n;break;case`Par`:{let r=e.left,i=e.right;t=Ul(Wl(r,n),Wl(i,n));break}case`Seq`:{let r=e.left,i=e.right;t=Wl(r,Wl(i,n));break}case`Single`:t=e,i=dc(n,i)}break}case`Single`:if(n=Ql(n,t),cc(r))return[n,i];t=r.head,r=r.tail}throw Error(`BUG: BlockedRequests.step - please report an issue at https://github.com/Effect-TS/effect/issues`)},ql=(e,t)=>{if(cc(e))return pc(nu(t));if(eu(t))return e;let n=cu(e.head),r=tu(t);return n.length===1&&r.length===1&&E(n[0],r[0])?dc(su(e.head,nu(t)),e.tail):dc(nu(t),e)},Jl= Symbol.for(`effect/RequestBlock/RequestBlockParallel`),Yl={
_R:e=>e};var Xl=class{map;[Jl]=Yl;constructor(e){this.map=e}};const Zl=()=>new Xl(Gs()),Ql=(e,t)=>new Xl(Zs(e.map,t.dataSource,e=>$t(rn(e,Pr(t.blockedRequest)),()=>Er(t.blockedRequest)))),$l=(e,t)=>new Xl($s(e.map,t.map,(e,t,n)=>Ys(e,n,Zt(Js(e,n),{onNone:()=>t,onSome:e=>Lr(t,e)})))),eu=e=>qs(e.map),tu=e=>Array.from(Xs(e.map)),nu=e=>ou(Qs(e.map,e=>Er(e))),ru= Symbol.for(`effect/RequestBlock/RequestBlockSequential`),iu={
_R:e=>e};var au=class{map;[ru]=iu;constructor(e){this.map=e}};const ou=e=>new au(e),su=(e,t)=>new au($s(t.map,e.map,(e,t,n)=>Ys(e,n,Zt(Js(e,n),{onNone:()=>wr(),onSome:e=>Lr(e,t)})))),cu=e=>Array.from(Xs(e.map)),lu=e=>Array.from(e.map),uu=`Pending`,du=`Done`,fu= Symbol.for(`effect/Deferred`),pu={
_E:e=>e,
_A:e=>e},mu=e=>({_tag:uu,joiners:e}),hu=e=>({_tag:du,effect:e});var gu=class e{self;called=!1;constructor(e){this.self=e}next(e){return this.called?{value:e,done:!0}:(this.called=!0,{value:this.self,done:!1})}return(e){return{value:e,done:!0}}throw(e){throw e}[Symbol.iterator](){return new e(this.self)}};const _u=(e,t)=>{let n=new H(`Blocked`);return n.effect_instruction_i0=e,n.effect_instruction_i1=t,n},vu=e=>{let t=new H(`RunBlocked`);return t.effect_instruction_i0=e,t},yu= Symbol.for(`effect/Effect`);var bu=class{patch;op;_op=ot;constructor(e,t){this.patch=e,this.op=t}},H=class{_op;effect_instruction_i0=void 0;effect_instruction_i1=void 0;effect_instruction_i2=void 0;trace=void 0;[yu]=ft;constructor(e){this._op=e}[T](e){return this===e}[b](){return w(this,Te(this))}pipe(){return A(this,arguments)}toJSON(){return{_id:`Effect`,_op:this._op,effect_instruction_i0:O(this.effect_instruction_i0),effect_instruction_i1:O(this.effect_instruction_i1),effect_instruction_i2:O(this.effect_instruction_i2)}}toString(){return k(this.toJSON())}[D](){return this.toJSON()}[Symbol.iterator](){return new gu(new ye(this))}},xu=class{_op;effect_instruction_i0=void 0;effect_instruction_i1=void 0;effect_instruction_i2=void 0;trace=void 0;[yu]=ft;constructor(e){this._op=e,this._tag=e}[T](e){return mf(e)&&e._op===`Failure`&&E(this.effect_instruction_i0,e.effect_instruction_i0)}[b](){return c(C(this._tag),S(x(this.effect_instruction_i0)),w(this))}get cause(){return this.effect_instruction_i0}pipe(){return A(this,arguments)}toJSON(){return{_id:`Exit`,_tag:this._op,cause:this.cause.toJSON()}}toString(){return k(this.toJSON())}[D](){return this.toJSON()}[Symbol.iterator](){return new gu(new ye(this))}},Su=class{_op;effect_instruction_i0=void 0;effect_instruction_i1=void 0;effect_instruction_i2=void 0;trace=void 0;[yu]=ft;constructor(e){this._op=e,this._tag=e}[T](e){return mf(e)&&e._op===`Success`&&E(this.effect_instruction_i0,e.effect_instruction_i0)}[b](){return c(C(this._tag),S(x(this.effect_instruction_i0)),w(this))}get value(){return this.effect_instruction_i0}pipe(){return A(this,arguments)}toJSON(){return{_id:`Exit`,_tag:this._op,value:O(this.value)}}toString(){return k(this.toJSON())}[D](){return this.toJSON()}[Symbol.iterator](){return new gu(new ye(this))}};const Cu=e=>y(e,yu),wu=e=>{let t=new H(it);return t.effect_instruction_i0=e,t},Tu= t(3,(e,t,n)=>sd(r=>U(e,e=>U(Ru(G(()=>r(t(e)))),t=>G(()=>n(e,t)).pipe(Ju({onFailure:e=>{switch(t._tag){case Ye:return Vu(Da(t.effect_instruction_i0,e));case $e:return Vu(e)}},onSuccess:()=>t})))))),Eu= t(2,(e,t)=>U(e,()=>W(t))),Du=e=>Eu(e,void 0),Ou=function(){let e=new H(Je);switch(arguments.length){case 2:e.effect_instruction_i0=arguments[0],e.commit=arguments[1];break;case 3:e.effect_instruction_i0=arguments[0],e.effect_instruction_i1=arguments[1],e.commit=arguments[2];break;case 4:e.effect_instruction_i0=arguments[0],e.effect_instruction_i1=arguments[1],e.effect_instruction_i2=arguments[2],e.commit=arguments[3];break;default:throw Error(pe(`you're not supposed to end up here`))}return e},ku=(e,t=Hs)=>{let n=new H(qe),r;return n.effect_instruction_i0=t=>{r=e(t)},n.effect_instruction_i1=t,rd(n,e=>Cu(r)?r:cd)},Au=(e,t=Hs)=>G(()=>ku(e,t)),ju=(e,t=Hs)=>Ou(e,function(){let e,n;function r(t){e?e(t):n===void 0&&(n=t)}let i=new H(qe);i.effect_instruction_i0=t=>{e=t,n&&t(n)},i.effect_instruction_i1=t;let a,o;return this.effect_instruction_i0.length===1?a=Ce(()=>this.effect_instruction_i0(r)):(o=new AbortController,a=Ce(()=>this.effect_instruction_i0(r,o.signal))),a||o?rd(i,e=>(o&&o.abort(),a??cd)):i}),Mu= t(2,(e,t)=>Yu(e,{onFailure:t,onSuccess:W})),Nu= Symbol.for(`effect/OriginalAnnotation`),Pu=(e,t)=>L(t)?new Proxy(e,{has(e,t){return t===oo||t===Nu||t in e},get(n,r){return r===oo?t.value:r===Nu?e:n[r]}}):e,Fu=e=>ae(e)&&!(oo in e)?wu(t=>Vu(wa(Pu(e,If(t))))):Vu(wa(e)),Iu=e=>Hu(()=>wa(new sf(e))),Lu=e=>Yu(e,{onFailure:e=>W(M(e)),onSuccess:e=>W(j(e))}),Ru=e=>qu(e,{onFailure:q,onSuccess:J}),zu=e=>ae(e)&&!(oo in e)?wu(t=>Vu(Ca(Pu(e,If(t))))):Vu(Ca(e)),Bu=e=>U(K(e),zu),Vu=e=>{let t=new xu(Ye);return t.effect_instruction_i0=e,t},Hu=e=>U(K(e),Vu),Uu= wu(e=>W(e.id())),Wu=e=>wu(t=>e(t.id())),U= t(2,(e,t)=>{let n=new H(Ze);return n.effect_instruction_i0=e,n.effect_instruction_i1=t,n}),Gu=e=>{let t=new H(`OnStep`);return t.effect_instruction_i0=e,t},Ku=e=>U(e,n),qu= t(2,(e,t)=>Ju(e,{onFailure:e=>W(t.onFailure(e)),onSuccess:e=>W(t.onSuccess(e))})),Ju= t(2,(e,t)=>{let n=new H(Qe);return n.effect_instruction_i0=e,n.effect_instruction_i1=t.onFailure,n.effect_instruction_i2=t.onSuccess,n}),Yu= t(2,(e,t)=>Ju(e,{onFailure:e=>{if(Fa(e).length>0)return Vu(Va(e));let n=Pa(e);return n.length>0?t.onFailure(Br(n)):Vu(e)},onSuccess:t.onSuccess})),Xu= t(2,(e,t)=>G(()=>{let n=z(e),r=un(n.length),i=0;return Eu(ud({while:()=>i<n.length,body:()=>t(n[i],i),step:e=>{r[i++]=e}}),r)})),Zu= t(2,(e,t)=>G(()=>{let n=z(e),r=0;return ud({while:()=>r<n.length,body:()=>t(n[r],r),step:()=>{r++}})})),Qu=e=>{let t=new H(tt);return t.effect_instruction_i0=Bl(1),t.effect_instruction_i1=()=>e,t},$u= t(2,(e,t)=>U(e,e=>K(()=>t(e)))),ed= t(2,(e,t)=>Yu(e,{onFailure:e=>Bu(()=>t.onFailure(e)),onSuccess:e=>K(()=>t.onSuccess(e))})),td= t(2,(e,t)=>Ju(e,{onFailure:e=>{let n=Ra(e);switch(n._tag){case`Left`:return Bu(()=>t(n.left));case`Right`:return Vu(n.right)}},onSuccess:W})),nd= t(2,(e,t)=>sd(n=>Ju(n(e),{onFailure:e=>{let n=q(e);return Ju(t(n),{onFailure:t=>q(Da(e,t)),onSuccess:()=>n})},onSuccess:e=>{let n=J(e);return md(t(n),n)}}))),rd= t(2,(e,t)=>nd(e,Cf({onFailure:e=>Na(e)?Du(t(Ia(e))):cd,onSuccess:()=>cd}))),W=e=>{let t=new Su($e);return t.effect_instruction_i0=e,t},G=e=>{let t=new H(Je);return t.commit=e,t},K=e=>{let t=new H(et);return t.effect_instruction_i0=e,t},id= t(e=>e.length===3||e.length===2&&!(ae(e[1])&&`onlyEffect`in e[1]),(e,t)=>U(e,e=>{let n=typeof t==`function`?t(e):t;return Cu(n)?Eu(n,e):fe(n)?ku(t=>{n.then(n=>t(W(e)),e=>t(zu(new pf(e,`An unknown error occurred in Effect.tap`))))}):W(e)})),ad=e=>wu(t=>{let n=c(t.getFiberRef(Xd),R(()=>t.scope()));return e(jd(Xd,F(n)))}),od=e=>{let t=new H(tt);return t.effect_instruction_i0=Vl(1),t.effect_instruction_i1=()=>e,t},sd=e=>Ou(e,function(){let e=new H(tt);return e.effect_instruction_i0=Vl(1),e.effect_instruction_i1=e=>jl(e)?Ce(()=>this.effect_instruction_i0(Qu)):Ce(()=>this.effect_instruction_i0(od)),e}),cd= W(void 0),ld=e=>{let t=new H(tt);return t.effect_instruction_i0=e,t.effect_instruction_i1=void 0,t},ud=e=>{let t=new H(nt);return t.effect_instruction_i0=e.while,t.effect_instruction_i1=e.body,t.effect_instruction_i2=e.step,t},dd=e=>{let t=new H(at);return e?.priority===void 0?t:Wd(t,e.priority)},fd= t(2,(e,t)=>U(e,e=>$u(t,t=>[e,t]))),pd= t(2,(e,t)=>U(e,e=>Eu(t,e))),md= t(2,(e,t)=>U(e,()=>t)),hd=e=>U(Uu,t=>c(e,gd(t))),gd= t(2,(e,t)=>U(e.interruptAsFork(t),()=>e.await)),_d={_tag:`All`,syslog:0,label:`ALL`,ordinal:-(2**53-1),pipe(){return A(this,arguments)}},vd={_tag:`Fatal`,syslog:2,label:`FATAL`,ordinal:5e4,pipe(){return A(this,arguments)}},yd={_tag:`Error`,syslog:3,label:`ERROR`,ordinal:4e4,pipe(){return A(this,arguments)}},bd={_tag:`Warning`,syslog:4,label:`WARN`,ordinal:3e4,pipe(){return A(this,arguments)}},xd={_tag:`Info`,syslog:6,label:`INFO`,ordinal:2e4,pipe(){return A(this,arguments)}},Sd={_tag:`Debug`,syslog:7,label:`DEBUG`,ordinal:1e4,pipe(){return A(this,arguments)}},Cd={_tag:`Trace`,syslog:7,label:`TRACE`,ordinal:0,pipe(){return A(this,arguments)}},wd={_tag:`None`,syslog:7,label:`OFF`,ordinal:2**53-1,pipe(){return A(this,arguments)}},Td= Symbol.for(`effect/FiberRef`),Ed={
_A:e=>e},Dd=e=>wu(t=>J(t.getFiberRef(e))),Od= t(2,(e,t)=>U(Dd(e),t)),kd= t(2,(e,t)=>Ad(e,()=>[void 0,t])),Ad= t(2,(e,t)=>wu(n=>{let[r,i]=t(n.getFiberRef(e));return n.setFiberRef(e,i),W(r)})),jd= t(3,(e,t,n)=>Tu(pd(Dd(t),kd(t,n)),()=>e,e=>kd(t,e))),Md=(e,t)=>Id(e,{differ:_l(),fork:t?.fork??n,join:t?.join}),Nd=e=>{let t=hl();return Id(e,{differ:t,fork:t.empty})},Pd=e=>{let t=gl(_l());return Id(e,{differ:t,fork:t.empty})},Fd=e=>{let t=ml();return Id(e,{differ:t,fork:t.empty})},Id=(e,t)=>({..._t,[Td]:Ed,initial:e,commit(){return Dd(this)},diff:(e,n)=>t.differ.diff(e,n),combine:(e,n)=>t.differ.combine(e,n),patch:e=>n=>t.differ.patch(e,n),fork:t.fork,join:t.join??((e,t)=>t)}),Ld=e=>Id(e,{differ:zl,fork:zl.empty}),Rd= m( Symbol.for(`effect/FiberRef/currentContext`),()=>Fd(Po())),zd= m( Symbol.for(`effect/FiberRef/currentSchedulingPriority`),()=>Md(0)),Bd= m( Symbol.for(`effect/FiberRef/currentMaxOpsBeforeYield`),()=>Md(2048)),Vd= m( Symbol.for(`effect/FiberRef/currentLogAnnotation`),()=>Md(Gs())),Hd= m( Symbol.for(`effect/FiberRef/currentLogLevel`),()=>Md(xd)),Ud= m( Symbol.for(`effect/FiberRef/currentLogSpan`),()=>Md(fc())),Wd= t(2,(e,t)=>jd(e,zd,t)),Gd= m( Symbol.for(`effect/FiberRef/currentConcurrency`),()=>Md(`unbounded`)),Kd= m( Symbol.for(`effect/FiberRef/currentRequestBatching`),()=>Md(!0)),qd= m( Symbol.for(`effect/FiberRef/currentUnhandledErrorLogLevel`),()=>Md(F(Sd))),Jd= m( Symbol.for(`effect/FiberRef/versionMismatchErrorLogLevel`),()=>Md(F(bd))),Yd= m( Symbol.for(`effect/FiberRef/currentMetricLabels`),()=>Pd(Hn())),Xd= m( Symbol.for(`effect/FiberRef/currentForkScopeOverride`),()=>Md(P(),{fork:()=>P(),join:(e,t)=>e})),Zd= m( Symbol.for(`effect/FiberRef/currentInterruptedCause`),()=>Md(Sa,{fork:()=>Sa,join:(e,t)=>e})),Qd= Symbol.for(`effect/Scope`),$d= Symbol.for(`effect/CloseableScope`),ef=(e,t)=>e.addFinalizer(()=>Du(t)),tf=(e,t)=>e.close(t),nf=(e,t)=>e.fork(t),rf= function(){class e extends globalThis.Error{commit(){return zu(this)}toJSON(){let e={...this};return this.message&&(e.message=this.message),this.cause&&(e.cause=this.cause),e}[D](){return this.toString===globalThis.Error.prototype.toString?`Bun`in globalThis?$a(Ca(this),{renderErrorCause:!0}):this:this.stack?`${this.toString()}\n${this.stack.split(`
`).slice(1).join(`
`)}`:this.toString()}}return Object.assign(e.prototype,vt),e}(),af=(e,t)=>{class n extends rf{_tag=t}return Object.assign(n.prototype,e),n.prototype.name=t,n},of= Symbol.for(`effect/Cause/errors/RuntimeException`),sf= af({[of]:of},`RuntimeException`),cf= Symbol.for(`effect/Cause/errors/InterruptedException`),lf=e=>y(e,cf),uf= Symbol.for(`effect/Cause/errors/NoSuchElement`),df= af({[uf]:uf},`NoSuchElementException`),ff= Symbol.for(`effect/Cause/errors/UnknownException`),pf= function(){class e extends rf{_tag=`UnknownException`;error;constructor(e,t){super(t??`An unknown error occurred`,{cause:e}),this.error=e}}return Object.assign(e.prototype,{[ff]:ff,name:`UnknownException`}),e}(),mf=e=>Cu(e)&&`_tag`in e&&(e._tag===`Success`||e._tag===`Failure`),hf=e=>e._tag===`Success`,gf= t(2,(e,t)=>{switch(e._tag){case Ye:return q(e.effect_instruction_i0);case $e:return J(t)}}),_f=e=>gf(e,void 0),vf=(e,t)=>Ef(e,t?.parallel?Ea:Da),yf=e=>q(wa(e)),bf=e=>q(Ca(e)),q=e=>{let t=new xu(Ye);return t.effect_instruction_i0=e,t},xf=e=>q(Ta(e)),Sf= t(2,(e,t)=>{switch(e._tag){case Ye:return q(e.effect_instruction_i0);case $e:return J(t(e.effect_instruction_i0))}}),Cf= t(2,(e,{onFailure:t,onSuccess:n})=>{switch(e._tag){case Ye:return t(e.effect_instruction_i0);case $e:return n(e.effect_instruction_i0)}}),J=e=>{let t=new Su($e);return t.effect_instruction_i0=e,t},wf= J(void 0),Tf= t(3,(e,t,{onFailure:n,onSuccess:r})=>{switch(e._tag){case Ye:switch(t._tag){case $e:return q(e.effect_instruction_i0);case Ye:return q(n(e.effect_instruction_i0,t.effect_instruction_i0))}case $e:switch(t._tag){case $e:return J(r(e.effect_instruction_i0,t.effect_instruction_i0));case Ye:return q(t.effect_instruction_i0)}}}),Ef=(e,t)=>{let n=Dr(e);return zr(n)?c(Hr(n),Jn(c(Vr(n),Sf(Er)),(e,n)=>c(e,Tf(n,{onSuccess:(e,t)=>c(e,Fr(t)),onFailure:t}))),Sf(Ar),Sf(e=>kr(e)),F):P()},Df=e=>({..._t,[fu]:pu,state:Es(mu([])),commit(){return Of(this)},blockingOn:e}),Of=e=>Au(t=>{let n=Ds(e.state);switch(n._tag){case du:return t(n.effect);case uu:return n.joiners.push(t),Af(e,t)}},e.blockingOn),kf=(e,t)=>{let n=Ds(e.state);if(n._tag===`Pending`){Os(e.state,hu(t));for(let e=0,r=n.joiners.length;e<r;e++)n.joiners[e](t)}},Af=(e,t)=>K(()=>{let n=Ds(e.state);if(n._tag===`Pending`){let e=n.joiners.indexOf(t);e>=0&&n.joiners.splice(e,1)}}),jf= wu(e=>J(e.currentContext)),Mf=()=>jf,Nf=e=>U(Mf(),e),Pf= t(2,(e,t)=>jd(Rd,t)(e)),Ff= t(2,(e,t)=>Nf(n=>Pf(e,t(n)))),If=e=>{let t=e.currentSpan;return t!==void 0&&t._tag===`Span`?F(t):P()},Lf=Aa,Rf=$a,zf=`InvalidData`,Bf=`MissingData`,Vf=`SourceUnavailable`,Hf=`Unsupported`,Uf= Symbol.for(`effect/ConfigError`),Wf={_tag:`ConfigError`,[Uf]:Uf},Gf=(e,t)=>{let n=Object.create(Wf);return n._op=`And`,n.left=e,n.right=t,Object.defineProperty(n,"toString",{enumerable:!1,value(){return`${this.left} and ${this.right}`}}),Object.defineProperty(n,"message",{enumerable:!1,get(){return this.toString()}}),n},Kf=(e,t)=>{let n=Object.create(Wf);return n._op=`Or`,n.left=e,n.right=t,Object.defineProperty(n,"toString",{enumerable:!1,value(){return`${this.left} or ${this.right}`}}),Object.defineProperty(n,"message",{enumerable:!1,get(){return this.toString()}}),n},qf=(e,t,n={pathDelim:`.`})=>{let r=Object.create(Wf);return r._op=zf,r.path=e,r.message=t,Object.defineProperty(r,"toString",{enumerable:!1,value(){return`(Invalid data at ${c(this.path,$n(n.pathDelim))}: "${this.message}")`}}),r},Jf=(e,t,n={pathDelim:`.`})=>{let r=Object.create(Wf);return r._op=Bf,r.path=e,r.message=t,Object.defineProperty(r,"toString",{enumerable:!1,value(){return`(Missing data at ${c(this.path,$n(n.pathDelim))}: "${this.message}")`}}),r},Yf=(e,t,n,r={pathDelim:`.`})=>{let i=Object.create(Wf);return i._op=Vf,i.path=e,i.message=t,i.cause=n,Object.defineProperty(i,"toString",{enumerable:!1,value(){return`(Source unavailable at ${c(this.path,$n(r.pathDelim))}: "${this.message}")`}}),i},Xf=(e,t,n={pathDelim:`.`})=>{let r=Object.create(Wf);return r._op=Hf,r.path=e,r.message=t,Object.defineProperty(r,"toString",{enumerable:!1,value(){return`(Unsupported operation at ${c(this.path,$n(n.pathDelim))}: "${this.message}")`}}),r},Zf= t(2,(e,t)=>{switch(e._op){case`And`:return Gf(Zf(e.left,t),Zf(e.right,t));case`Or`:return Kf(Zf(e.left,t),Zf(e.right,t));case zf:return qf([...t,...e.path],e.message);case Bf:return Jf([...t,...e.path],e.message);case Vf:return Yf([...t,...e.path],e.message,e.cause);case Hf:return Xf([...t,...e.path],e.message)}}),Qf= t(3,(e,t,n)=>{let r=[e],i=[];for(;r.length>0;){let e=r.pop();switch(e._op){case`And`:r.push(e.right),r.push(e.left),i.push(M({_op:`AndCase`}));break;case`Or`:r.push(e.right),r.push(e.left),i.push(M({_op:`OrCase`}));break;case zf:i.push(j(n.invalidDataCase(t,e.path,e.message)));break;case Bf:i.push(j(n.missingDataCase(t,e.path,e.message)));break;case Vf:i.push(j(n.sourceUnavailableCase(t,e.path,e.message,e.cause)));break;case Hf:i.push(j(n.unsupportedCase(t,e.path,e.message)))}}let a=[];for(;i.length>0;){let e=i.pop();switch(e._op){case`Left`:switch(e.left._op){case`AndCase`:{let e=a.pop(),r=a.pop(),i=n.andCase(t,e,r);a.push(i);break}case`OrCase`:{let e=a.pop(),r=a.pop(),i=n.orCase(t,e,r);a.push(i);break}}break;case`Right`:a.push(e.right)}}if(a.length===0)throw Error(`BUG: ConfigError.reduceWithContext - please report an issue at https://github.com/Effect-TS/effect/issues`);return a.pop()}),$f= Symbol.for(`effect/Clock`),ep= No(`effect/Clock`),tp=2**31-1,np={unsafeSchedule(e,t){let n=ps(t);if(n>tp)return a;let r=!1,i=setTimeout(()=>{r=!0,e()},n);return()=>(clearTimeout(i),!r)}},rp= function(){let e= BigInt(1e6);if(typeof performance>`u`||typeof performance.now!=`function`)return()=>BigInt(Date.now())*e;let t;return()=>(t===void 0&&(t=BigInt(Date.now())*e-BigInt(Math.round(performance.now()*1e6))),t+BigInt(Math.round(performance.now()*1e6)))}(),ip= function(){let e=typeof process==`object`&&`hrtime`in process&&typeof process.hrtime.bigint==`function`?process.hrtime:void 0;if(!e)return rp;let t= rp()- e.bigint();return()=>t+e.bigint()}();var ap=class{[$f]=$f;unsafeCurrentTimeMillis(){return Date.now()}unsafeCurrentTimeNanos(){return ip()}currentTimeMillis= K(()=>this.unsafeCurrentTimeMillis());currentTimeNanos= K(()=>this.unsafeCurrentTimeNanos());scheduler(){return W(np)}sleep(e){return ju(t=>{let n=np.unsafeSchedule(()=>t(cd),e);return Du(K(n))})}};const op=()=>new ap,sp=Jt,cp=e=>e.replace(/[/\\^$*+?.()|[\]{}]/g,`\\$&`),lp={_tag:`Empty`},up= t(2,(e,t)=>{let n=pc(t),r=e;for(;lc(n);){let e=n.head;switch(e._tag){case`Empty`:n=n.tail;break;case`AndThen`:n=dc(e.first,dc(e.second,n.tail));break;case`MapName`:r=Wn(r,e.f),n=n.tail;break;case`Nested`:r=mn(r,e.name),n=n.tail;break;case`Unnested`:if(c(wn(r),sn(e.name)))r=On(r),n=n.tail;else return M(Jf(r,`Expected ${e.name} to be in path in ConfigProvider#unnested`))}}return j(r)}),dp=(e,t)=>[...e,...t],fp= Symbol.for(`effect/ConfigProvider`),pp= No(`effect/ConfigProvider`),mp= Symbol.for(`effect/ConfigProviderFlat`),hp=e=>({[fp]:fp,pipe(){return A(this,arguments)},...e}),gp=e=>({[mp]:mp,patch:e.patch,load:(t,n,r=!0)=>e.load(t,n,r),enumerateChildren:e.enumerateChildren}),_p=e=>hp({load:t=>U(Cp(e,Hn(),t,!1),e=>Zt(wn(e),{onNone:()=>zu(Jf(Hn(),`Expected a single value having structure: ${t}`)),onSome:W})),flattened:e}),vp=e=>{let{pathDelim:t,seqDelim:n}=Object.assign({},{pathDelim:`_`,seqDelim:`,`},e),r=e=>c(e,$n(t)),i=e=>e.split(t),a=()=>typeof process<`u`&&`env`in process&&typeof process.env==`object`?process.env:{};return _p(gp({load:(e,t,i=!0)=>{let o=r(e),s=a();return c(o in s?F(s[o]):P(),td(()=>Jf(e,`Expected ${o} to exist in the process context`)),U(r=>Ep(r,e,t,n,i)))},enumerateChildren:e=>K(()=>{let t=a(),n=Object.keys(t).map(e=>i(e.toUpperCase())).filter(t=>{for(let n=0;n<e.length;n++){let r=c(e,Cn(n)),i=t[n];if(i===void 0||r!==i)return!1}return!0}).flatMap(t=>t.slice(e.length,e.length+1));return ia(n)}),patch:lp}))},yp=(e,t,n,r)=>{let i=Yn(n.length,t=>t>=r.length?P():F([e(t),t+1])),a=Yn(r.length,e=>e>=n.length?P():F([t(e),e+1]));return[dp(n,i),dp(r,a)]},bp=(e,t)=>{let n=t;if(n._tag===`Nested`){let t=e.slice();for(;n._tag===`Nested`;)t.push(n.name),n=n.config;return t}return e},xp={andCase:(e,t,n)=>Gf(t,n),orCase:(e,t,n)=>Kf(t,n),invalidDataCase:(e,t)=>qf(t,`<redacted>`),missingDataCase:(e,t)=>Jf(t,`<redacted>`),sourceUnavailableCase:(e,t,n,r)=>Yf(t,`<redacted>`,r),unsupportedCase:(e,t)=>Xf(t,`<redacted>`)},Sp=e=>Qf(e,void 0,xp),Cp=(e,t,n,r)=>{let i=n;switch(i._tag){case`Constant`:return W(Un(i.value));case`Described`:return G(()=>Cp(e,t,i.config,r));case`Fail`:return zu(Jf(t,i.message));case`Fallback`:return c(G(()=>Cp(e,t,i.first,r)),Mu(n=>i.condition(n)?c(Cp(e,t,i.second,r),Mu(e=>zu(Kf(n,e)))):zu(n)));case`Lazy`:return G(()=>Cp(e,t,i.config(),r));case`MapOrFail`:return G(()=>c(Cp(e,t,i.original,r),U(Xu(e=>c(i.mapOrFail(e),td(Zf(bp(t,i.original))))))));case`Nested`:return G(()=>Cp(e,dp(t,Un(i.name)),i.config,r));case`Primitive`:return c(up(t,e.patch),U(t=>c(e.load(t,i,r),U(e=>{if(e.length===0){let e=c(En(t),R(()=>`<n/a>`));return zu(Jf([],`Expected ${i.description} with name ${e}`))}return W(e)}))));case`Redacted`:return G(()=>c(Cp(e,t,i.original,r),td(Sp),$u(Wn(i.redact))));case`Sequence`:return c(up(t,e.patch),U(n=>c(e.enumerateChildren(n),U(Op),U(n=>n.length===0?G(()=>$u(Cp(e,t,i.config,!0),Un)):c(Xu(n,n=>Cp(e,hn(t,`[${n}]`),i.config,!0)),$u(e=>{let t=Kn(e);return t.length===0?Un(Hn()):Un(t)}))))));case`HashMap`:return G(()=>c(up(t,e.patch),U(t=>c(e.enumerateChildren(t),U(n=>c(n,Xu(n=>Cp(e,dp(t,Un(n)),i.valueConfig,r)),$u(e=>e.length===0?Un(Gs()):c(Dp(e),Wn(e=>Ks(Pn(z(n),e)))))))))));case`ZipWith`:return G(()=>c(Cp(e,t,i.left,r),Lu,U(n=>c(Cp(e,t,i.right,r),Lu,U(e=>{if(N(n)&&N(e))return zu(Gf(n.left,e.left));if(N(n)&&zt(e))return zu(n.left);if(zt(n)&&N(e))return zu(e.left);if(zt(n)&&zt(e)){let r=c(t,$n(`.`)),a=wp(t,r),[o,s]=yp(a,a,c(n.right,Wn(j)),c(e.right,Wn(j)));return c(o,Pn(s),Xu(([e,t])=>c(fd(e,t),$u(([e,t])=>i.zip(e,t)))))}throw Error(`BUG: ConfigProvider.fromFlatLoop - please report an issue at https://github.com/Effect-TS/effect/issues`)})))))}},wp=(e,t)=>n=>M(Jf(e,`The element at index ${n} in a sequence at path "${t}" was missing`)),Tp=(e,t)=>e.split(RegExp(`\\s*${cp(t)}\\s*`)),Ep=(e,t,n,r,i)=>i?c(Tp(e,r),Xu(e=>n.parse(e.trim())),td(Zf(t))):c(n.parse(e),ed({onFailure:Zf(t),onSuccess:Un})),Dp=e=>Object.keys(e[0]).map(t=>e.map(e=>e[t])),Op=e=>c(Xu(e,Ap),ed({onFailure:()=>Hn(),onSuccess:Nn(sp)}),Lu,$u(Ut)),kp=/^(\[(\d+)\])$/,Ap=e=>{let t=e.match(kp);if(t!==null){let e=t[2];return c(e!==void 0&&e.length>0?F(e):P(),an(jp))}return P()},jp=e=>{let t=Number.parseInt(e);return Number.isNaN(t)?P():F(t)},Mp= Symbol.for(`effect/Console`),Np= No(`effect/Console`),Pp={[Mp]:Mp,assert(e,...t){return K(()=>{console.assert(e,...t)})},clear: K(()=>{console.clear()}),count(e){return K(()=>{console.count(e)})},countReset(e){return K(()=>{console.countReset(e)})},debug(...e){return K(()=>{console.debug(...e)})},dir(e,t){return K(()=>{console.dir(e,t)})},dirxml(...e){return K(()=>{console.dirxml(...e)})},error(...e){return K(()=>{console.error(...e)})},group(e){return e?.collapsed?K(()=>console.groupCollapsed(e?.label)):K(()=>console.group(e?.label))},groupEnd: K(()=>{console.groupEnd()}),info(...e){return K(()=>{console.info(...e)})},log(...e){return K(()=>{console.log(...e)})},table(e,t){return K(()=>{console.table(e,t)})},time(e){return K(()=>console.time(e))},timeEnd(e){return K(()=>console.timeEnd(e))},timeLog(e,...t){return K(()=>{console.timeLog(e,...t)})},trace(...e){return K(()=>{console.trace(...e)})},warn(...e){return K(()=>{console.warn(...e)})},unsafe:console},Fp= Symbol.for(`effect/Random`),Ip= No(`effect/Random`);var Lp=class{seed;[Fp]=Fp;PRNG;constructor(e){this.seed=e,this.PRNG=new he(e)}get next(){return K(()=>this.PRNG.number())}get nextBoolean(){return $u(this.next,e=>e>.5)}get nextInt(){return K(()=>this.PRNG.integer(2**53-1))}nextRange(e,t){return $u(this.next,n=>(t-e)*n+e)}nextIntBetween(e,t){return K(()=>this.PRNG.integer(t-e)+e)}shuffle(e){return Rp(e,e=>this.nextIntBetween(0,e))}};const Rp=(e,t)=>G(()=>c(K(()=>Array.from(e)),U(e=>{let n=[];for(let t=e.length;t>=2;--t)n.push(t);return c(n,Zu(n=>c(t(n),$u(t=>zp(e,n-1,t)))),Eu(Dr(e)))}))),zp=(e,t,n)=>{let r=e[t];return e[t]=e[n],e[n]=r,e},Bp=e=>new Lp(x(e)),Vp= Symbol.for(`effect/Tracer`),Hp=e=>({[Vp]:Vp,...e}),Up= No(`effect/Tracer`),Wp= No(`effect/ParentSpan`),Gp= function(){return function(e){let t=``;for(let n=0;n<e;n++)t+=`abcdef0123456789`.charAt(Math.floor(Math.random()*16));return t}}();var Kp=class{name;parent;context;startTime;kind;_tag=`Span`;spanId;traceId=`native`;sampled=!0;status;attributes;events=[];links;constructor(e,t,n,r,i,a){this.name=e,this.parent=t,this.context=n,this.startTime=i,this.kind=a,this.status={_tag:`Started`,startTime:i},this.attributes= new Map,this.traceId=t._tag===`Some`?t.value.traceId:Gp(32),this.spanId=Gp(16),this.links=Array.from(r)}end(e,t){this.status={_tag:`Ended`,endTime:e,exit:t,startTime:this.status.startTime}}attribute(e,t){this.attributes.set(e,t)}event(e,t,n){this.events.push([e,t,n??{}])}addLinks(e){this.links.push(...e)}};const qp= Hp({span:(e,t,n,r,i,a)=>new Kp(e,t,n,r,i,a),context:e=>e()}),Jp= Vo()(`effect/Tracer/DisablePropagation`,{defaultValue:a}),Yp= c( Po(), Io(ep, op()), Io(Np,Pp), Io(Ip, Bp( Math.random())), Io(pp, vp()), Io(Up,qp)),Xp= m( Symbol.for(`effect/DefaultServices/currentServices`),()=>Fd(Yp)),Zp= function(){let e= Symbol.for(`effect/Data/Error/plainArgs`);return{BaseEffectError:class extends rf{constructor(t){super(t?.message,t?.cause?{cause:t.cause}:void 0),t&&(Object.assign(this,t),Object.defineProperty(this,e,{value:t,enumerable:!1}))}toJSON(){return{...this[e],...this}}}}.BaseEffectError}(),Qp=e=>{let t={BaseEffectError:class extends Zp{_tag=e}};return t.BaseEffectError.prototype.name=e,t.BaseEffectError},$p=ht,em=yt;var tm=class extends em{};const nm=`Sequential`,rm=`Parallel`,im={_tag:nm},am={_tag:rm},om=e=>({_tag:`ParallelN`,parallelism:e}),sm=e=>e._tag===nm,cm=e=>e._tag===rm,lm=im,um=am,dm=om;function fm(e){return new hm(e)}function pm(){return fm( new Map)}const mm= Symbol.for(`effect/FiberRefs`);var hm=class{locals;[mm]=mm;constructor(e){this.locals=e}pipe(){return A(this,arguments)}};const gm=(e,t,n,r=!1)=>{let i=e,a=t,o=n,s=r,c;for(;c===void 0;)if(B(a)&&B(o)){let e=Tn(a)[0],t=On(a),n=Tn(o)[0],r=Tn(o)[1],i=On(o);e.startTimeMillis<n.startTimeMillis?(o=i,s=!0):e.startTimeMillis>n.startTimeMillis?a=t:e.id<n.id?(o=i,s=!0):e.id>n.id?a=t:c=[r,s]}else c=[i.initial,!0];return c},_m= t(3,(e,t,n)=>{let r=new Map(e.locals);return n.locals.forEach((e,n)=>{let i=e[0][1];if(!e[0][0][T](t)){if(!r.has(n)){if(E(i,n.initial))return;r.set(n,[[t,n.join(n.initial,i)]]);return}let a=r.get(n),[o,s]=gm(n,a,e);if(s){let e=n.diff(o,i),s=a[0][1],c=n.join(s,n.patch(e)(s));if(!E(s,c)){let e,i=a[0][0];e=i[T](t)?[[i,c],...a.slice(1)]:[[t,c],...a],r.set(n,e)}}}}),new hm(r)}),vm= t(2,(e,t)=>{let n= new Map;return ym(e,n,t),new hm(n)}),ym=(e,t,n)=>{e.locals.forEach((e,r)=>{let i=e[0][1],a=r.patch(r.fork)(i);E(i,a)?t.set(r,e):t.set(r,[[n,a],...e])})},bm= t(2,(e,t)=>{let n=new Map(e.locals);return n.delete(t),new hm(n)}),xm= t(2,(e,t)=>e.locals.has(t)?F(Tn(e.locals.get(t))[1]):P()),Sm= t(2,(e,t)=>c(xm(e,t),R(()=>t.initial))),Cm= t(2,(e,{fiberId:t,fiberRef:n,value:r})=>{if(e.locals.size===0)return new hm( new Map([[n,[[t,r]]]]));let i=new Map(e.locals);return wm(i,t,n,r),new hm(i)}),wm=(e,t,n,r)=>{let i=e.get(n)??[],a;if(B(i)){let[e,n]=Tn(i);if(e[T](t)){if(E(n,r))return;a=[[t,r],...i.slice(1)]}else a=[[t,r],...i]}else a=[[t,r]];e.set(n,a)},Tm= t(2,(e,{entries:t,forkAs:n})=>{if(e.locals.size===0)return new hm(new Map(t));let r=new Map(e.locals);return n!==void 0&&ym(e,r,n),t.forEach(([e,t])=>{t.length===1?wm(r,t[0][0],e,t[0][1]):t.forEach(([t,n])=>{wm(r,t,e,n)})}),new hm(r)}),Em=Sm,Dm=Tm,Om=pm,km=`Empty`,Am=`Remove`,jm=`Update`,Mm=`AndThen`,Nm={_tag:km},Pm=(e,t)=>{let n=new Map(e.locals),r=Nm;for(let[e,i]of t.locals.entries()){let t=Tn(i)[1],a=n.get(e);if(a!==void 0){let n=Tn(a)[1];E(n,t)||(r=Fm({_tag:jm,fiberRef:e,patch:e.diff(n,t)})(r))}else r=Fm({_tag:`Add`,fiberRef:e,value:t})(r);n.delete(e)}for(let[e]of n.entries())r=Fm({_tag:Am,fiberRef:e})(r);return r},Fm= t(2,(e,t)=>({_tag:Mm,first:e,second:t})),Im= t(3,(e,t,n)=>{let r=n,i=Un(e);for(;B(i);){let e=Tn(i),n=On(i);switch(e._tag){case km:i=n;break;case`Add`:r=Cm(r,{fiberId:t,fiberRef:e.fiberRef,value:e.value}),i=n;break;case Am:r=bm(r,e.fiberRef),i=n;break;case jm:{let a=Sm(r,e.fiberRef);r=Cm(r,{fiberId:t,fiberRef:e.fiberRef,value:e.fiberRef.patch(e.patch)(a)}),i=n;break}case Mm:i=mn(e.first)(mn(e.second)(n))}}return r}),Lm=Pm,Rm=Im,zm=`effect/FiberStatus`,Bm= Symbol.for(zm),Vm=`Done`,Hm= C(`${zm}-${Vm}`);var Um=class{[Bm]=Bm;_tag=Vm;[b](){return Hm}[T](e){return Ym(e)&&e._tag===`Done`}},Wm=class{runtimeFlags;[Bm]=Bm;_tag=`Running`;constructor(e){this.runtimeFlags=e}[b](){return c(x(zm),S(x(this._tag)),S(x(this.runtimeFlags)),w(this))}[T](e){return Ym(e)&&e._tag===`Running`&&this.runtimeFlags===e.runtimeFlags}},Gm=class{runtimeFlags;blockingOn;[Bm]=Bm;_tag=`Suspended`;constructor(e,t){this.runtimeFlags=e,this.blockingOn=t}[b](){return c(x(zm),S(x(this._tag)),S(x(this.runtimeFlags)),S(x(this.blockingOn)),w(this))}[T](e){return Ym(e)&&e._tag===`Suspended`&&this.runtimeFlags===e.runtimeFlags&&E(this.blockingOn,e.blockingOn)}};const Km= new Um,qm=e=>new Wm(e),Jm=(e,t)=>new Gm(e,t),Ym=e=>y(e,Bm),Xm=e=>e._tag===Vm,Zm=Km,Qm=qm,$m=Jm,eh=Xm,th=_d,nh=vd,rh=yd,ih=bd,ah=xd,oh=Sd,sh=Cd,ch=wd,lh= Xt( c(sp, Yt(e=>e.ordinal))),uh=e=>{switch(e){case`All`:return th;case`Debug`:return oh;case`Error`:return rh;case`Fatal`:return nh;case`Info`:return ah;case`Trace`:return sh;case`None`:return ch;case`Warning`:return ih}},dh= Symbol.for(`effect/Micro`),fh= Symbol.for(`effect/Micro/MicroExit`),ph= Symbol.for(`effect/Micro/MicroCause`),mh={_E:n};var hh=class extends globalThis.Error{_tag;traces;[ph];constructor(e,t,n){let r=`MicroCause.${e}`,i,a,o;if(t instanceof globalThis.Error){i=`(${r}) ${t.name}`,a=t.message;let e=a.split(`
`).length;o=t.stack?`(${r}) ${t.stack.split(`
`).slice(0,e+3).join(`
`)}`:`${i}: ${a}`}else i=r,a=Be(t,0),o=`${i}: ${a}`;n.length>0&&(o+=`\n ${n.join(`
`)}`),super(a),this._tag=e,this.traces=n,this[ph]=mh,this.name=i,this.stack=o}pipe(){return A(this,arguments)}toString(){return this.stack}[D](){return this.stack}},gh=class extends hh{defect;constructor(e,t=[]){super(`Die`,e,t),this.defect=e}};const _h=(e,t=[])=>new gh(e,t);var vh=class extends hh{constructor(e=[]){super(`Interrupt`,`interrupted`,e)}};const yh=(e=[])=>new vh(e),bh=e=>e._tag===`Interrupt`,xh= Symbol.for(`effect/Micro/MicroFiber`),Sh={_A:n,_E:n};var Ch=class{context;interruptible;[xh];_stack=[];_observers=[];_exit;_children;currentOpCount=0;constructor(e,t=!0){this.context=e,this.interruptible=t,this[xh]=Sh}getRef(e){return Oo(this.context,e)}addObserver(e){return this._exit?(e(this._exit),s):(this._observers.push(e),()=>{let t=this._observers.indexOf(e);t>=0&&this._observers.splice(t,1)})}_interrupted=!1;unsafeInterrupt(){this._exit||(this._interrupted=!0,this.interruptible&&this.evaluate(qh))}unsafePoll(){return this._exit}evaluate(e){if(this._exit)return;if(this._yielded!==void 0){let e=this._yielded;this._yielded=void 0,e()}let t=this.runLoop(e);if(t===Ah)return;let n=wh.interruptChildren&&wh.interruptChildren(this);if(n!==void 0)return this.evaluate(Hh(n,()=>t));this._exit=t;for(let e=0;e<this._observers.length;e++)this._observers[e](t);this._observers.length=0}runLoop(e){let t=!1,n=e;this.currentOpCount=0;try{for(;;){if(this.currentOpCount++,!t&&this.getRef(tg).shouldYield(this)){t=!0;let e=n;n=Hh(zh,()=>e)}if(n=n[Eh](this),n===Ah){let e=this._yielded;return fh in e?(this._yielded=void 0,e):Ah}}}catch(e){return y(n,Eh)?Jh(e):Jh(`MicroFiber.runLoop: Not a valid effect: ${String(n)}`)}}getCont(e){for(;;){let t=this._stack.pop();if(!t)return;let n=t[kh]&&t[kh](this);if(n)return{[e]:n};if(t[e])return t}}_yielded=void 0;yieldWith(e){return this._yielded=e,Ah}children(){return this._children??= new Set}};const wh= m(`effect/Micro/fiberMiddleware`,()=>({interruptChildren:void 0})),Th= Symbol.for(`effect/Micro/identifier`),Y= Symbol.for(`effect/Micro/args`),Eh= Symbol.for(`effect/Micro/evaluate`),Dh= Symbol.for(`effect/Micro/successCont`),Oh= Symbol.for(`effect/Micro/failureCont`),kh= Symbol.for(`effect/Micro/ensureCont`),Ah= Symbol.for(`effect/Micro/Yield`),jh={_A:n,_E:n,_R:n},Mh={...$p,_op:`Micro`,[dh]:jh,pipe(){return A(this,arguments)},[Symbol.iterator](){return new me(new ye(this))},toJSON(){return{_id:`Micro`,op:this[Th],...Y in this?{args:this[Y]}:void 0}},toString(){return k(this)},[D](){return k(this)}};function Nh(e){return Jh(`Micro.evaluate: Not implemented`)}const Ph=e=>({...Mh,[Th]:e.op,[Eh]:e.eval??Nh,[Dh]:e.contA,[Oh]:e.contE,[kh]:e.ensure}),Fh=e=>{let t=Ph(e);return function(){let n=Object.create(t);return n[Y]=e.single===!1?arguments:arguments[0],n}},Ih=e=>{let t={...Ph(e),[fh]:fh,_tag:e.op,get[e.prop](){return this[Y]},toJSON(){return{_id:`MicroExit`,_tag:e.op,[e.prop]:this[Y]}},[T](t){return Wh(t)&&t._tag===e.op&&E(this[Y],t[Y])},[b](){return w(this,S(C(e.op))(x(this[Y])))}};return function(e){let n=Object.create(t);return n[Y]=e,n[Dh]=void 0,n[Oh]=void 0,n[kh]=void 0,n}},Lh= Ih({op:`Success`,prop:`value`,eval(e){let t=e.getCont(Dh);return t?t[Dh](this[Y],e):e.yieldWith(this)}}),Rh= Ih({op:`Failure`,prop:`cause`,eval(e){let t=e.getCont(Oh);for(;bh(this[Y])&&t&&e.interruptible;)t=e.getCont(Oh);return t?t[Oh](this[Y],e):e.yieldWith(this)}}),zh= ( Fh({op:`Yield`,eval(e){let t=!1;return e.getRef(tg).scheduleTask(()=>{t||e.evaluate(Yh)},this[Y]??0),e.yieldWith(()=>{t=!0})}}))(0),Bh= Lh(void 0),Vh= Fh({op:`WithMicroFiber`,eval(e){return this[Y](e)}}),Hh= t(2,(e,t)=>{let n=Object.create(Uh);return n[Y]=e,n[Dh]=t,n}),Uh= Ph({op:`OnSuccess`,eval(e){return e._stack.push(this),this[Y]}}),Wh=e=>y(e,fh),Gh=Lh,Kh=Rh,qh= Kh( yh()),Jh=e=>Kh(_h(e)),Yh= Gh(void 0),Xh=`setImmediate`in globalThis?globalThis.setImmediate:e=>setTimeout(e,0);var Zh=class{tasks=[];running=!1;scheduleTask(e,t){this.tasks.push(e),this.running||(this.running=!0,Xh(this.afterScheduled))}afterScheduled=()=>{this.running=!1,this.runTasks()};runTasks(){let e=this.tasks;this.tasks=[];for(let t=0,n=e.length;t<n;t++)e[t]()}shouldYield(e){return e.currentOpCount>=e.getRef(eg)}flush(){for(;this.tasks.length>0;)this.runTasks()}};const Qh= t(2,(e,t)=>Vh(n=>{let r=n.context;return n.context=t(r),ig(e,()=>(n.context=r,Bh))})),$h= t(2,(e,t)=>Qh(e,Bo(t)));var eg=class extends ( Vo()(`effect/Micro/currentMaxOpsBeforeYield`,{defaultValue:()=>2048})){},tg=class extends ( Vo()(`effect/Micro/currentScheduler`,{defaultValue:()=>new Zh})){};const ng= t(2,(e,t)=>{let n=Object.create(rg);return n[Y]=e,n[Dh]=t.onSuccess,n[Oh]=t.onFailure,n}),rg= Ph({op:`OnSuccessAndFailure`,eval(e){return e._stack.push(this),this[Y]}}),ig= t(2,(e,t)=>sg(n=>ng(n(e),{onFailure:e=>Hh(t(Kh(e)),()=>Rh(e)),onSuccess:e=>Hh(t(Gh(e)),()=>Lh(e))}))),ag= Fh({op:`SetInterruptible`,ensure(e){if(e.interruptible=this[Y],e._interrupted&&e.interruptible)return()=>qh}}),og=e=>Vh(t=>t.interruptible?e:(t.interruptible=!0,t._stack.push(ag(!1)),t._interrupted?qh:e)),sg=e=>Vh(t=>t.interruptible?(t.interruptible=!1,t._stack.push(ag(!0)),e(og)):e(n)),cg=(e,t)=>{let n=new Ch(tg.context(t?.scheduler??new Zh));if(n.evaluate(e),t?.signal){if(t.signal.aborted)n.unsafeInterrupt();else{let e=()=>n.unsafeInterrupt();t.signal.addEventListener(`abort`,e,{once:!0}),n.addObserver(()=>t.signal.removeEventListener(`abort`,e))}}return n};var lg=class e{scheduleDrain;running=!1;tasks= new ug;constructor(e){this.scheduleDrain=e}starveInternal=e=>{let t=this.tasks.buckets;this.tasks.buckets=[];for(let[e,n]of t)for(let e=0;e<n.length;e++)n[e]();this.tasks.buckets.length===0?this.running=!1:this.starve(e)};starve(e=0){this.scheduleDrain(e,this.starveInternal)}scheduleTask(e,t){this.tasks.scheduleTask(e,t),this.running||(this.running=!0,this.starve())}static cached(t){let n=new e(t),r= new WeakMap;return i=>{if(i===void 0)return n;let a=r.get(i);return a===void 0&&(a=new e(t),r.set(i,a)),a}}},ug=class{buckets=[];scheduleTask(e,t){let n=this.buckets.length,r,i=0;for(;i<n&&this.buckets[i][0]<=t;i++)r=this.buckets[i];r&&r[0]===t?r[1].push(e):i===n?this.buckets.push([t,[e]]):this.buckets.splice(i,0,[t,[e]])}},dg=class{maxNextTickBeforeTimer;getRunner= lg.cached((e,t)=>{e>=this.maxNextTickBeforeTimer?setTimeout(()=>t(0),0):Promise.resolve(void 0).then(()=>t(e+1))});constructor(e){this.maxNextTickBeforeTimer=e}shouldYield(e){return e.currentOpCount>e.getFiberRef(Bd)&&e.getFiberRef(zd)}scheduleTask(e,t,n){this.getRunner(n).scheduleTask(e,t)}};const fg= m( Symbol.for(`effect/Scheduler/defaultScheduler`),()=>new dg(2048));var pg=class{tasks= new ug;deferred=!1;scheduleTask(e,t,n){this.deferred?fg.scheduleTask(e,t,n):this.tasks.scheduleTask(e,t)}shouldYield(e){return e.currentOpCount>e.getFiberRef(Bd)&&e.getFiberRef(zd)}flush(){for(;this.tasks.buckets.length>0;){let e=this.tasks.buckets;this.tasks.buckets=[];for(let[t,n]of e)for(let e=0;e<n.length;e++)n[e]()}this.deferred=!0}};const mg= m( Symbol.for(`effect/FiberRef/currentScheduler`),()=>Md(fg)),hg= m( Symbol.for(`effect/FiberRef/currentRequestMap`),()=>Md( new Map)),gg=(e,t,n,r)=>{switch(e){case void 0:return t();case`unbounded`:return n();case`inherit`:return Od(Gd,e=>e===`unbounded`?n():e>1?r(e):t());default:return e>1?r(e):t()}},_g=e=>e.replace(/[\s="]/g,`_`),vg=e=>t=>`${_g(t.label)}=${e-t.startTime}ms`,yg=`effect/MetricLabel`,bg= Symbol.for(yg);var xg=class{key;value;[bg]=bg;_hash;constructor(e,t){this.key=e,this.value=t,this._hash=C(yg+this.key+this.value)}[b](){return this._hash}[T](e){return Cg(e)&&this.key===e.key&&this.value===e.value}pipe(){return A(this,arguments)}};const Sg=(e,t)=>new xg(e,t),Cg=e=>y(e,bg),wg= an(e=>Lo(e.context,Jp)?e._tag===`Span`?wg(e.parent):P():F(e)),Tg=hf,Eg=`InterruptSignal`,Dg=`Stateful`,Og=`Resume`,kg=`YieldNow`,Ag=e=>({_tag:Eg,cause:e}),jg=e=>({_tag:Dg,onFiber:e}),Mg=e=>({_tag:Og,effect:e}),Ng=()=>({_tag:kg}),Pg= Symbol.for(`effect/FiberScope`);var Fg=class{[Pg]=Pg;fiberId=Hs;roots= new Set;add(e,t){this.roots.add(t),t.addObserver(()=>{this.roots.delete(t)})}},Ig=class{fiberId;parent;[Pg]=Pg;constructor(e,t){this.fiberId=e,this.parent=t}add(e,t){this.parent.tell(jg(e=>{e.addChild(t),t.addObserver(()=>{e.removeChild(t)})}))}};const Lg=e=>new Ig(e.id(),e),Rg= m( Symbol.for(`effect/FiberScope/Global`),()=>new Fg),zg= Symbol.for(`effect/Fiber`),Bg={
_E:e=>e,
_A:e=>e},Vg={[zg]:Bg,pipe(){return A(this,arguments)}},Hg= Symbol.for(`effect/Fiber`),Ug=e=>pd(Ku(e.await),e.inheritAll);({..._t}),{...Vg};const Wg=`effect/FiberCurrent`,Gg= Symbol.for(`effect/Logger`),Kg={
_Message:e=>e,
_Output:e=>e},qg=e=>({[Gg]:Kg,log:e,pipe(){return A(this,arguments)}}),Jg=/^[^\s"=]*$/,Yg= qg( ((e,t)=>({annotations:n,cause:r,date:i,fiberId:a,logLevel:o,message:s,spans:c})=>{let l=t=>t.match(Jg)?t:e(t),u=(e,t)=>`${_g(e)}=${l(t)}`,d=(e,t)=>` `+u(e,t),f=u(`timestamp`,i.toISOString());f+=d(`level`,o.label),f+=d(`fiber`,Bs(a));let p=fn(s);for(let e=0;e<p.length;e++)f+=d(`message`,Be(p[e],t));ka(r)||(f+=d(`cause`,$a(r,{renderErrorCause:!0})));for(let e of c)f+=` `+vg(i.getTime())(e);for(let[e,r]of n)f+=d(e,Be(r,t));return f})(e=>`"${e.replace(/\\([\s\S])|(")/g,`\\$1$2`)}"`)),Xg={bold:`1`,red:`31`,green:`32`,yellow:`33`,blue:`34`,cyan:`36`,white:`37`,gray:`90`,black:`30`,bgBrightRed:`101`};Xg.gray,Xg.blue,Xg.green,Xg.yellow,Xg.red,Xg.bgBrightRed,Xg.black;const Zg=typeof process==`object`&&process!==null&&typeof process.stdout==`object`&&process.stdout!==null;Zg&&process.stdout.isTTY,Zg||`Deno`in globalThis;const Qg=`effect/MetricBoundaries`,$g= Symbol.for(Qg);var e_=class{values;[$g]=$g;constructor(e){this.values=e,this._hash=c(C(Qg),S(je(this.values)))}_hash;[b](){return this._hash}[T](e){return t_(e)&&E(this.values,e.values)}pipe(){return A(this,arguments)}};const t_=e=>y(e,$g),n_=e=>new e_(c(e,gn(Er(1/0)),Qn)),r_=e=>c(dn(e.count-1,t=>e.start*e.factor**+t),jr,n_),i_= Symbol.for(`effect/MetricKeyType`),a_=`effect/MetricKeyType/Counter`,o_= Symbol.for(a_),s_= Symbol.for(`effect/MetricKeyType/Frequency`),c_= Symbol.for(`effect/MetricKeyType/Gauge`),l_=`effect/MetricKeyType/Histogram`,u_= Symbol.for(l_),d_= Symbol.for(`effect/MetricKeyType/Summary`),f_={
_In:e=>e,
_Out:e=>e};var p_=class{incremental;bigint;[i_]=f_;[o_]=o_;constructor(e,t){this.incremental=e,this.bigint=t,this._hash=C(a_)}_hash;[b](){return this._hash}[T](e){return __(e)}pipe(){return A(this,arguments)}},m_=class{boundaries;[i_]=f_;[u_]=u_;constructor(e){this.boundaries=e,this._hash=c(C(l_),S(x(this.boundaries)))}_hash;[b](){return this._hash}[T](e){return b_(e)&&E(this.boundaries,e.boundaries)}pipe(){return A(this,arguments)}};const h_=e=>new p_(e?.incremental??!1,e?.bigint??!1),g_=e=>new m_(e),__=e=>y(e,o_),v_=e=>y(e,s_),y_=e=>y(e,c_),b_=e=>y(e,u_),x_=e=>y(e,d_),S_= Symbol.for(`effect/MetricKey`),C_={
_Type:e=>e},w_= Xn(E);var T_=class{name;keyType;description;tags;[S_]=C_;constructor(e,t,n,r=[]){this.name=e,this.keyType=t,this.description=n,this.tags=r,this._hash=c(C(this.name+this.description),S(x(this.keyType)),S(je(this.tags)))}_hash;[b](){return this._hash}[T](e){return E_(e)&&this.name===e.name&&E(this.keyType,e.keyType)&&E(this.description,e.description)&&w_(this.tags,e.tags)}pipe(){return A(this,arguments)}};const E_=e=>y(e,S_),D_=(e,t)=>new T_(e,h_(t),en(t?.description)),O_=(e,t,n)=>new T_(e,g_(t),en(n)),k_= t(2,(e,t)=>t.length===0?e:new T_(e.name,e.keyType,e.description,Vn(e.tags,t))),A_= Symbol.for(`effect/MutableHashMap`),j_={[A_]:A_,[Symbol.iterator](){return new M_(this)},toString(){return k(this.toJSON())},toJSON(){return{_id:`MutableHashMap`,values:Array.from(this).map(O)}},[D](){return this.toJSON()},pipe(){return A(this,arguments)}};var M_=class e{self;referentialIterator;bucketIterator;constructor(e){this.self=e,this.referentialIterator=e.referential[Symbol.iterator]()}next(){if(this.bucketIterator!==void 0)return this.bucketIterator.next();let e=this.referentialIterator.next();return e.done?(this.bucketIterator=new N_(this.self.buckets.values()),this.next()):e}[Symbol.iterator](){return new e(this.self)}},N_=class{backing;constructor(e){this.backing=e}currentBucket;next(){if(this.currentBucket===void 0){let e=this.backing.next();if(e.done)return e;this.currentBucket=e.value[Symbol.iterator]()}let e=this.currentBucket.next();return e.done?(this.currentBucket=void 0,this.next()):e}};const P_=()=>{let e=Object.create(j_);return e.referential= new Map,e.buckets= new Map,e.bucketsSize=0,e},F_= t(2,(e,t)=>{if(Ne(t)===!1)return e.referential.has(t)?F(e.referential.get(t)):P();let n=t[b](),r=e.buckets.get(n);return r===void 0?P():I_(e,r,t)}),I_=(e,t,n,r=!1)=>{for(let i=0,a=t.length;i<a;i++)if(n[T](t[i][0])){let n=t[i][1];return r&&(t.splice(i,1),e.bucketsSize--),F(n)}return P()},L_= t(2,(e,t)=>L(F_(e,t))),R_= t(3,(e,t,n)=>{if(Ne(t)===!1)return e.referential.set(t,n),e;let r=t[b](),i=e.buckets.get(r);return i===void 0?(e.buckets.set(r,[[t,n]]),e.bucketsSize++,e):(z_(e,i,t),i.push([t,n]),e.bucketsSize++,e)}),z_=(e,t,n)=>{for(let r=0,i=t.length;r<i;r++)if(n[T](t[r][0])){t.splice(r,1),e.bucketsSize--;return}},B_= Symbol.for(`effect/MetricState`),V_=`effect/MetricState/Counter`,H_= Symbol.for(V_),U_=`effect/MetricState/Frequency`,W_= Symbol.for(U_),G_=`effect/MetricState/Gauge`,K_= Symbol.for(G_),q_=`effect/MetricState/Histogram`,J_= Symbol.for(q_),Y_=`effect/MetricState/Summary`,X_= Symbol.for(Y_),Z_={
_A:e=>e};var Q_=class{count;[B_]=Z_;[H_]=H_;constructor(e){this.count=e}[b](){return c(x(V_),S(x(this.count)),w(this))}[T](e){return lv(e)&&this.count===e.count}pipe(){return A(this,arguments)}};const $_= Xn(E);var ev=class{occurrences;[B_]=Z_;[W_]=W_;constructor(e){this.occurrences=e}_hash;[b](){return c(C(U_),S(je(z(this.occurrences.entries()))),w(this))}[T](e){return uv(e)&&$_(z(this.occurrences.entries()),z(e.occurrences.entries()))}pipe(){return A(this,arguments)}},tv=class{value;[B_]=Z_;[K_]=K_;constructor(e){this.value=e}[b](){return c(x(G_),S(x(this.value)),w(this))}[T](e){return dv(e)&&this.value===e.value}pipe(){return A(this,arguments)}},nv=class{buckets;count;min;max;sum;[B_]=Z_;[J_]=J_;constructor(e,t,n,r,i){this.buckets=e,this.count=t,this.min=n,this.max=r,this.sum=i}[b](){return c(x(q_),S(x(this.buckets)),S(x(this.count)),S(x(this.min)),S(x(this.max)),S(x(this.sum)),w(this))}[T](e){return fv(e)&&E(this.buckets,e.buckets)&&this.count===e.count&&this.min===e.min&&this.max===e.max&&this.sum===e.sum}pipe(){return A(this,arguments)}},rv=class{error;quantiles;count;min;max;sum;[B_]=Z_;[X_]=X_;constructor(e,t,n,r,i,a){this.error=e,this.quantiles=t,this.count=n,this.min=r,this.max=i,this.sum=a}[b](){return c(x(Y_),S(x(this.error)),S(x(this.quantiles)),S(x(this.count)),S(x(this.min)),S(x(this.max)),S(x(this.sum)),w(this))}[T](e){return pv(e)&&this.error===e.error&&E(this.quantiles,e.quantiles)&&this.count===e.count&&this.min===e.min&&this.max===e.max&&this.sum===e.sum}pipe(){return A(this,arguments)}};const iv=e=>new Q_(e),av=e=>new ev(e),ov=e=>new tv(e),sv=e=>new nv(e.buckets,e.count,e.min,e.max,e.sum),cv=e=>new rv(e.error,e.quantiles,e.count,e.min,e.max,e.sum),lv=e=>y(e,H_),uv=e=>y(e,W_),dv=e=>y(e,K_),fv=e=>y(e,J_),pv=e=>y(e,X_),mv= Symbol.for(`effect/MetricHook`),hv={
_In:e=>e,
_Out:e=>e},gv=e=>({[mv]:hv,pipe(){return A(this,arguments)},...e}),_v= BigInt(0),vv=e=>{let t=e.keyType.bigint?_v:0,n=e.keyType.incremental?e.keyType.bigint?e=>e>=_v:e=>e>=0:e=>!0,r=e=>{n(e)&&(t+=e)};return gv({get:()=>iv(t),update:r,modify:r})},yv=e=>{let t= new Map;for(let n of e.keyType.preregisteredWords)t.set(n,0);let n=e=>{let n=t.get(e)??0;t.set(e,n+1)};return gv({get:()=>av(t),update:n,modify:n})},bv=(e,t)=>{let n=t;return gv({get:()=>ov(n),update:e=>{n=e},modify:e=>{n+=e}})},xv=e=>{let t=e.keyType.boundaries.values,n=t.length,r=new Uint32Array(n+1),i=new Float64Array(n),a=0,o=0,s=Number.MAX_VALUE,l=Number.MIN_VALUE;c(t,Nn(sp),Wn((e,t)=>{i[t]=e}));let u=e=>{let t=0,c=n;for(;t!==c;){let n=Math.floor(t+(c-t)/2);e<=i[n]?c=n:t=n,c===t+1&&(e<=i[t]?c=t:t=c)}r[t]=r[t]+1,a+=1,o+=e,e<s&&(s=e),e>l&&(l=e)},d=()=>{let e=un(n),t=0;for(let a=0;a<n;a++){let n=i[a],o=r[a];t+=o,e[a]=[n,t]}return e};return gv({get:()=>sv({buckets:d(),count:a,min:s,max:l,sum:o}),update:u,modify:u})},Sv=e=>{let{error:t,maxAge:n,maxSize:r,quantiles:i}=e.keyType,a=c(i,Nn(sp)),o=un(r),s=0,l=0,u=0,d=0,f=0,p=e=>{let i=[],s=0;for(;s!==r-1;){let t=o[s];if(t!=null){let[r,a]=t,o=ss(e-r);bs(o,rs)&&ys(o,n)&&i.push(a)}s+=1}return Cv(t,a,Nn(i,sp))},m=(e,t)=>{if(r>0){s+=1;let n=s%r;o[n]=[t,e]}d=l===0?e:Math.min(d,e),f=l===0?e:Math.max(f,e),l+=1,u+=e};return gv({get:()=>cv({error:t,quantiles:p(Date.now()),count:l,min:d,max:f,sum:u}),update:([e,t])=>m(e,t),modify:([e,t])=>m(e,t)})},Cv=(e,t,n)=>{let r=n.length;if(!B(t))return Hn();let i=t[0],a=t.slice(1),o=wv(e,r,P(),0,i,n),s=Un(o);return a.forEach(t=>{s.push(wv(e,r,o.value,o.consumed,t,o.rest))}),Wn(s,e=>[e.quantile,e.value])},wv=(e,t,n,r,i,a)=>{let o=e,s=t,c=n,l=r,u=i,d=a,f=e,p=t,m=n,h=r,g=i,_=a;for(;;){if(!B(d))return{quantile:u,value:P(),consumed:l,rest:[]};if(u===1)return{quantile:u,value:F(Dn(d)),consumed:l+d.length,rest:[]};let e=Tn(d),t=An(d,t=>t===e),n=u*s,r=o/2*n,i=l+t[0].length,a=Math.abs(i-n);if(i<n-r){f=o,p=s,m=wn(d),h=i,g=u,_=t[1],o=f,s=p,c=m,l=h,u=g,d=_;continue}if(i>n+r){let t=I(c)?F(e):c;return{quantile:u,value:t,consumed:l,rest:d}}switch(c._tag){case`None`:f=o,p=s,m=wn(d),h=i,g=u,_=t[1],o=f,s=p,c=m,l=h,u=g,d=_;continue;case`Some`:if(a<Math.abs(n-c.value)){f=o,p=s,m=wn(d),h=i,g=u,_=t[1],o=f,s=p,c=m,l=h,u=g,d=_;continue}return{quantile:u,value:F(c.value),consumed:l,rest:d}}}throw Error(`BUG: MetricHook.resolveQuantiles - please report an issue at https://github.com/Effect-TS/effect/issues`)},Tv= Symbol.for(`effect/MetricPair`),Ev={
_Type:e=>e},Dv=(e,t)=>({[Tv]:Ev,metricKey:e,metricState:t,pipe(){return A(this,arguments)}}),Ov= Symbol.for(`effect/MetricRegistry`);var kv=class{[Ov]=Ov;map= P_();snapshot(){let e=[];for(let[t,n]of this.map)e.push(Dv(t,n.get()));return e}get(e){let t=c(this.map,F_(e),tn);if(t==null){if(__(e.keyType))return this.getCounter(e);if(y_(e.keyType))return this.getGauge(e);if(v_(e.keyType))return this.getFrequency(e);if(b_(e.keyType))return this.getHistogram(e);if(x_(e.keyType))return this.getSummary(e);throw Error(`BUG: MetricRegistry.get - unknown MetricKeyType - please report an issue at https://github.com/Effect-TS/effect/issues`)}return t}getCounter(e){let t=c(this.map,F_(e),tn);if(t==null){let n=vv(e);c(this.map,L_(e))||c(this.map,R_(e,n)),t=n}return t}getFrequency(e){let t=c(this.map,F_(e),tn);if(t==null){let n=yv(e);c(this.map,L_(e))||c(this.map,R_(e,n)),t=n}return t}getGauge(e){let t=c(this.map,F_(e),tn);if(t==null){let n=bv(e,e.keyType.bigint?BigInt(0):0);c(this.map,L_(e))||c(this.map,R_(e,n)),t=n}return t}getHistogram(e){let t=c(this.map,F_(e),tn);if(t==null){let n=xv(e);c(this.map,L_(e))||c(this.map,R_(e,n)),t=n}return t}getSummary(e){let t=c(this.map,F_(e),tn);if(t==null){let n=Sv(e);c(this.map,L_(e))||c(this.map,R_(e,n)),t=n}return t}};const Av=()=>new kv,jv= Symbol.for(`effect/Metric`),Mv={
_Type:e=>e,
_In:e=>e,
_Out:e=>e},Nv= m( Symbol.for(`effect/Metric/globalMetricRegistry`),()=>Av()),Pv=function(e,t,n,r){let i=Object.assign(e=>id(e,e=>Bv(i,e)),{[jv]:Mv,keyType:e,unsafeUpdate:t,unsafeValue:n,unsafeModify:r,register(){return this.unsafeValue([]),this},pipe(){return A(this,arguments)}});return i},Fv=(e,t)=>Iv(D_(e,t)),Iv=e=>{let t,n= new WeakMap,r=r=>{if(r.length===0)return t===void 0&&(t=Nv.get(e)),t;let i=n.get(r);return i===void 0?(i=Nv.get(k_(e,r)),n.set(r,i),i):i};return Pv(e.keyType,(e,t)=>r(t).update(e),e=>r(e).get(),(e,t)=>r(t).modify(e))},Lv=(e,t,n)=>Iv(O_(e,t,n)),Rv= t(3,(e,t,n)=>zv(e,[Sg(t,n)])),zv= t(2,(e,t)=>Pv(e.keyType,(n,r)=>e.unsafeUpdate(n,Vn(t,r)),n=>e.unsafeValue(Vn(t,n)),(n,r)=>e.unsafeModify(n,Vn(t,r)))),Bv= t(2,(e,t)=>Od(Yd,n=>K(()=>e.unsafeUpdate(t,n))));({...gt});const Vv= t(2,(e,t)=>Od(hg,n=>K(()=>{if(n.has(e)){let r=n.get(e);r.state.completed||(r.state.completed=!0,kf(r.result,t))}}))),Hv= Symbol.for(`effect/Supervisor`),Uv={
_T:e=>e};var Wv=class e{underlying;value0;[Hv]=Uv;constructor(e,t){this.underlying=e,this.value0=t}get value(){return this.value0}onStart(e,t,n,r){this.underlying.onStart(e,t,n,r)}onEnd(e,t){this.underlying.onEnd(e,t)}onEffect(e,t){this.underlying.onEffect(e,t)}onSuspend(e){this.underlying.onSuspend(e)}onResume(e){this.underlying.onResume(e)}map(t){return new e(this,c(this.value,$u(t)))}zip(e){return new Gv(this,e)}},Gv=class e{left;right;_tag=`Zip`;[Hv]=Uv;constructor(e,t){this.left=e,this.right=t}get value(){return fd(this.left.value,this.right.value)}onStart(e,t,n,r){this.left.onStart(e,t,n,r),this.right.onStart(e,t,n,r)}onEnd(e,t){this.left.onEnd(e,t),this.right.onEnd(e,t)}onEffect(e,t){this.left.onEffect(e,t),this.right.onEffect(e,t)}onSuspend(e){this.left.onSuspend(e),this.right.onSuspend(e)}onResume(e){this.left.onResume(e),this.right.onResume(e)}map(e){return new Wv(this,c(this.value,$u(e)))}zip(t){return new e(this,t)}};const Kv=e=>y(e,Hv)&&oe(e,`Zip`);var qv=class{effect;[Hv]=Uv;constructor(e){this.effect=e}get value(){return this.effect}onStart(e,t,n,r){}onEnd(e,t){}onEffect(e,t){}onSuspend(e){}onResume(e){}map(e){return new Wv(this,c(this.value,$u(e)))}zip(e){return new Gv(this,e)}onRun(e,t){return e()}};const Jv=e=>new qv(e),Yv= m(`effect/Supervisor/none`,()=>Jv(cd)),Xv=pl,Zv=`Empty`,Qv=`AddSupervisor`,$v=`RemoveSupervisor`,ey=`AndThen`,ty={_tag:Zv},ny=(e,t)=>({_tag:ey,first:e,second:t}),ry=(e,t)=>iy(t,Er(e)),iy=(e,t)=>{let n=e,r=t;for(;zr(r);){let e=Vr(r);switch(e._tag){case Zv:r=Hr(r);break;case Qv:n=n.zip(e.supervisor),r=Hr(r);break;case $v:n=ay(n,e.supervisor),r=Hr(r);break;case ey:r=Fr(e.first)(Fr(e.second)(Hr(r)))}}return n},ay=(e,t)=>E(e,t)?Yv:Kv(e)?ay(e.left,t).zip(ay(e.right,t)):e,oy=e=>E(e,Yv)?ra():Kv(e)?c(oy(e.left),da(oy(e.right))):aa(e),sy= Xv({empty:ty,patch:ry,combine:ny,diff:(e,t)=>{if(E(e,t))return ty;let n=oy(e),r=oy(t),i=c(r,ua(n),fa(ty,(e,t)=>ny(e,{_tag:Qv,supervisor:t}))),a=c(n,ua(r),fa(ty,(e,t)=>ny(e,{_tag:$v,supervisor:t})));return ny(i,a)}}),cy= Fv(`effect_fiber_started`,{incremental:!0}),ly= Fv(`effect_fiber_active`),uy= Fv(`effect_fiber_successes`,{incremental:!0}),dy= Fv(`effect_fiber_failures`,{incremental:!0}),fy= Rv( Lv(`effect_fiber_lifetimes`, r_({start:.5,factor:2,count:35})),`time_unit`,`milliseconds`),py=`Continue`,my=`Yield`,hy={
_E:e=>e,
_A:e=>e},gy=e=>{throw Error(`BUG: FiberRuntime - ${Be(e)} - please report an issue at https://github.com/Effect-TS/effect/issues`)},_y= Symbol.for(`effect/internal/fiberRuntime/YieldedOp`),vy= m(`effect/internal/fiberRuntime/yieldedOpChannel`,()=>({currentOp:null})),yy={[Ze]:(e,t,n)=>Ce(()=>t.effect_instruction_i1(n)),OnStep:(e,t,n)=>J(J(n)),[Qe]:(e,t,n)=>Ce(()=>t.effect_instruction_i2(n)),[ot]:(e,t,n)=>(e.patchRuntimeFlags(e.currentRuntimeFlags,t.patch),Al(e.currentRuntimeFlags)&&e.isInterrupted()?q(e.getInterruptedCause()):J(n)),[nt]:(e,t,n)=>(Ce(()=>t.effect_instruction_i2(n)),Ce(()=>t.effect_instruction_i0())?(e.pushStack(t),Ce(()=>t.effect_instruction_i1())):cd),[rt]:(e,t,n)=>{for(;;){let r=Ce(()=>t.effect_instruction_i0.next(n));if(r.done)return J(r.value);let i=be(r.value);if(!mf(i))return e.pushStack(t),i;if(i._tag===`Failure`)return i;n=i.value}}},by={[Eg]:(e,t,n,r)=>(e.processNewInterruptSignal(r.cause),Al(t)?q(r.cause):n),[Og]:(e,t,n,r)=>{throw Error(`It is illegal to have multiple concurrent run loops in a single fiber`)},[Dg]:(e,t,n,r)=>(r.onFiber(e,Qm(t)),n),[kg]:(e,t,n,r)=>U(dd(),()=>n)},xy=e=>Zu(Gl(e),e=>jy(lu(e),([e,t])=>{let n= new Map,r=[];for(let e of t){r.push(kr(e));for(let t of e)n.set(t.request,t)}let i=r.flat();return jd(Zy(e.runAll(r),i,()=>i.forEach(e=>{e.listeners.interrupted=!0})),hg,n)},!1,!1)),Sy= st();var Cy=class extends tm{[zg]=Bg;[Hg]=hy;_fiberRefs;_fiberId;_queue=[];_children=null;_observers=[];_running=!1;_stack=[];_asyncInterruptor=null;_asyncBlockingOn=null;_exitValue=null;_steps=[];_isYielding=!1;currentRuntimeFlags;currentOpCount=0;currentSupervisor;currentScheduler;currentTracer;currentSpan;currentContext;currentDefaultServices;constructor(e,t,n){if(super(),this.currentRuntimeFlags=n,this._fiberId=e,this._fiberRefs=t,Fl(n)){let e=this.getFiberRef(Yd);cy.unsafeUpdate(1,e),ly.unsafeUpdate(1,e)}this.refreshRefCache()}commit(){return Ug(this)}id(){return this._fiberId}resume(e){this.tell(Mg(e))}get status(){return this.ask((e,t)=>t)}get runtimeFlags(){return this.ask((e,t)=>eh(t)?e.currentRuntimeFlags:t.runtimeFlags)}scope(){return Lg(this)}get children(){return this.ask(e=>Array.from(e.getChildren()))}getChildren(){return this._children===null&&(this._children= new Set),this._children}getInterruptedCause(){return this.getFiberRef(Zd)}fiberRefs(){return this.ask(e=>e.getFiberRefs())}ask(e){return G(()=>{let t=Df(this._fiberId);return this.tell(jg((n,r)=>{kf(t,K(()=>e(n,r)))})),Of(t)})}tell(e){this._queue.push(e),this._running||(this._running=!0,this.drainQueueLaterOnExecutor())}get await(){return ju(e=>{let t=t=>e(W(t));if(this._exitValue!==null){t(this._exitValue);return}return this.tell(jg((e,n)=>{e._exitValue===null?e.addObserver(t):t(this._exitValue)})),K(()=>this.tell(jg((e,n)=>{e.removeObserver(t)})))},this.id())}get inheritAll(){return wu((e,t)=>{let n=e.id(),r=e.getFiberRefs(),i=t.runtimeFlags,a=this.getFiberRefs(),o=_m(r,n,a);e.setFiberRefs(o);let s=e.getFiberRef(Jy),l=c(Ll(i,s),Hl(1),Hl(16));return ld(l)})}get poll(){return K(()=>en(this._exitValue))}unsafePoll(){return this._exitValue}interruptAsFork(e){return K(()=>this.tell(Ag(Ta(e))))}unsafeInterruptAsFork(e){this.tell(Ag(Ta(e)))}addObserver(e){this._exitValue===null?this._observers.push(e):e(this._exitValue)}removeObserver(e){this._observers=this._observers.filter(t=>t!==e)}getFiberRefs(){return this.setFiberRef(Jy,this.currentRuntimeFlags),this._fiberRefs}unsafeDeleteFiberRef(e){this._fiberRefs=bm(this._fiberRefs,e)}getFiberRef(e){return this._fiberRefs.locals.has(e)?this._fiberRefs.locals.get(e)[0][1]:e.initial}setFiberRef(e,t){this._fiberRefs=Cm(this._fiberRefs,{fiberId:this._fiberId,fiberRef:e,value:t}),this.refreshRefCache()}refreshRefCache(){this.currentDefaultServices=this.getFiberRef(Xp),this.currentTracer=this.currentDefaultServices.unsafeMap.get(Up.key),this.currentSupervisor=this.getFiberRef(Yy),this.currentScheduler=this.getFiberRef(mg),this.currentContext=this.getFiberRef(Rd),this.currentSpan=this.currentContext.unsafeMap.get(Wp.key)}setFiberRefs(e){this._fiberRefs=e,this.refreshRefCache()}addChild(e){this.getChildren().add(e)}removeChild(e){this.getChildren().delete(e)}transferChildren(e){let t=this._children;if(this._children=null,t!==null&&t.size>0)for(let n of t)n._exitValue===null&&e.add(this.currentRuntimeFlags,n)}drainQueueOnCurrentThread(){let e=!0;for(;e;){let t=py,n=globalThis[Wg];globalThis[Wg]=this;try{for(;t===py;)t=this._queue.length===0?`Done`:this.evaluateMessageWhileSuspended(this._queue.splice(0,1)[0])}finally{this._running=!1,globalThis[Wg]=n}this._queue.length>0&&!this._running?(this._running=!0,t===my?(this.drainQueueLaterOnExecutor(),e=!1):e=!0):e=!1}}drainQueueLaterOnExecutor(){this.currentScheduler.scheduleTask(this.run,this.getFiberRef(zd),this)}drainQueueWhileRunning(e,t){let n=t;for(;this._queue.length>0;){let t=this._queue.splice(0,1)[0];n=by[t._tag](this,e,n,t)}return n}isInterrupted(){return!ja(this.getFiberRef(Zd))}addInterruptedCause(e){let t=this.getFiberRef(Zd);this.setFiberRef(Zd,Da(t,e))}processNewInterruptSignal(e){this.addInterruptedCause(e),this.sendInterruptSignalToAllChildren()}sendInterruptSignalToAllChildren(){if(this._children===null||this._children.size===0)return!1;let e=!1;for(let t of this._children)t.tell(Ag(Ta(this.id()))),e=!0;return e}interruptAllChildren(){if(this.sendInterruptSignalToAllChildren()){let e=this._children.values();this._children=null;let t=!1;return ud({while:()=>!t,body:()=>{let n=e.next();return n.done?K(()=>{t=!0}):Du(n.value.await)},step:()=>{}})}return null}reportExitValue(e){if(Fl(this.currentRuntimeFlags)){let t=this.getFiberRef(Yd),n=this.id().startTimeMillis,r=Date.now();switch(fy.unsafeUpdate(r-n,t),ly.unsafeUpdate(-1,t),e._tag){case $e:uy.unsafeUpdate(1,t);break;case Ye:dy.unsafeUpdate(1,t)}}if(e._tag===`Failure`){let t=this.getFiberRef(qd);!Na(e.cause)&&t._tag===`Some`&&this.log(`Fiber terminated with an unhandled error`,e.cause,t)}}setExitValue(e){this._exitValue=e,this.reportExitValue(e);for(let t=this._observers.length-1;t>=0;t--)this._observers[t](e);this._observers=[]}getLoggers(){return this.getFiberRef(Oy)}log(e,t,n){let r=L(n)?n.value:this.getFiberRef(Hd),i=this.getFiberRef(wy);if(lh(i,r))return;let a=this.getFiberRef(Ud),o=this.getFiberRef(Vd),s=this.getLoggers(),c=this.getFiberRefs();if(sa(s)>0){let n=Lo(this.getFiberRef(Xp),ep),i=new Date(n.unsafeCurrentTimeMillis());Ge(c,()=>{for(let n of s)n.log({fiberId:this.id(),logLevel:r,message:e,cause:t,context:c,spans:a,annotations:o,date:i})})}}evaluateMessageWhileSuspended(e){switch(e._tag){case kg:return my;case Eg:return this.processNewInterruptSignal(e.cause),this._asyncInterruptor!==null&&(this._asyncInterruptor(q(e.cause)),this._asyncInterruptor=null),py;case Og:return this._asyncInterruptor=null,this._asyncBlockingOn=null,this.evaluateEffect(e.effect),py;case Dg:return e.onFiber(this,this._exitValue===null?$m(this.currentRuntimeFlags,this._asyncBlockingOn):Zm),py;default:return gy(e)}}evaluateEffect(e){this.currentSupervisor.onResume(this);try{let t=Al(this.currentRuntimeFlags)&&this.isInterrupted()?q(this.getInterruptedCause()):e;for(;t!==null;){let e=t,n=this.runLoop(e);if(n===_y){let e=vy.currentOp;vy.currentOp=null,e._op===`Yield`?Ol(this.currentRuntimeFlags)?(this.tell(Ng()),this.tell(Mg(wf)),t=null):t=wf:e._op===`Async`&&(t=null)}else{this.currentRuntimeFlags=c(this.currentRuntimeFlags,kl(16));let e=this.interruptAllChildren();e===null?(this._queue.length===0?this.setExitValue(n):this.tell(Mg(n)),t=null):t=U(e,()=>n)}}}finally{this.currentSupervisor.onSuspend(this)}}start(e){if(this._running)this.tell(Mg(e));else{this._running=!0;let t=globalThis[Wg];globalThis[Wg]=this;try{this.evaluateEffect(e)}finally{this._running=!1,globalThis[Wg]=t,this._queue.length>0&&this.drainQueueLaterOnExecutor()}}}startFork(e){this.tell(Mg(e))}patchRuntimeFlags(e,t){let n=Rl(e,t);return globalThis[Wg]=this,this.currentRuntimeFlags=n,n}initiateAsync(e,t){let n=!1,r=e=>{n||(n=!0,this.tell(Mg(e)))};Al(e)&&(this._asyncInterruptor=r);try{t(r)}catch(e){r(Vu(wa(e)))}}pushStack(e){this._stack.push(e),e._op===`OnStep`&&this._steps.push({refs:this.getFiberRefs(),flags:this.currentRuntimeFlags})}popStack(){let e=this._stack.pop();if(e)return e._op===`OnStep`&&this._steps.pop(),e}getNextSuccessCont(){let e=this.popStack();for(;e;){if(e._op!==`OnFailure`)return e;e=this.popStack()}}getNextFailCont(){let e=this.popStack();for(;e;){if(e._op!==`OnSuccess`&&e._op!==`While`&&e._op!==`Iterator`)return e;e=this.popStack()}}Tag(e){return K(()=>Ro(this.currentContext,e))}Left(e){return zu(e.left)}None(e){return zu(new df)}Right(e){return J(e.right)}Some(e){return J(e.value)}Micro(e){return ku(t=>{let n=t,r=cg($h(e,this.currentContext));return r.addObserver(e=>{if(e._tag===`Success`)return n(J(e.value));switch(e.cause._tag){case`Interrupt`:return n(q(Ta(Hs)));case`Fail`:return n(zu(e.cause.error));case`Die`:return n(Fu(e.cause.defect))}}),ku(e=>{n=t=>{e(cd)},r.unsafeInterrupt()})})}[et](e){let t=Ce(()=>e.effect_instruction_i0()),n=this.getNextSuccessCont();return n===void 0?(vy.currentOp=J(t),_y):(n._op in yy||gy(n),yy[n._op](this,n,t))}[$e](e){let t=e,n=this.getNextSuccessCont();return n===void 0?(vy.currentOp=t,_y):(n._op in yy||gy(n),yy[n._op](this,n,t.effect_instruction_i0))}[Ye](e){let t=e.effect_instruction_i0,n=this.getNextFailCont();if(n!==void 0)switch(n._op){case Xe:case Qe:return Al(this.currentRuntimeFlags)&&this.isInterrupted()?q(Ba(t)):Ce(()=>n.effect_instruction_i1(t));case`OnStep`:return Al(this.currentRuntimeFlags)&&this.isInterrupted()?q(Ba(t)):J(q(t));case ot:return this.patchRuntimeFlags(this.currentRuntimeFlags,n.patch),Al(this.currentRuntimeFlags)&&this.isInterrupted()?q(Da(t,this.getInterruptedCause())):q(t);default:gy(n)}else return vy.currentOp=q(t),_y}[it](e){return Ce(()=>e.effect_instruction_i0(this,Qm(this.currentRuntimeFlags)))}Blocked(e){let t=this.getFiberRefs(),n=this.currentRuntimeFlags;if(this._steps.length>0){let r=[],i=this._steps[this._steps.length-1],a=this.popStack();for(;a&&a._op!==`OnStep`;)r.push(a),a=this.popStack();this.setFiberRefs(i.refs),this.currentRuntimeFlags=i.flags;let o=Lm(i.refs,t),s=Ll(i.flags,n);return J(_u(e.effect_instruction_i0,wu(t=>{for(;r.length>0;)t.pushStack(r.pop());return t.setFiberRefs(Rm(t.id(),t.getFiberRefs())(o)),t.currentRuntimeFlags=Rl(s)(t.currentRuntimeFlags),e.effect_instruction_i1})))}return sd(t=>U(Ny(vu(e.effect_instruction_i0)),()=>t(e.effect_instruction_i1)))}RunBlocked(e){return xy(e.effect_instruction_i0)}[tt](e){let t=e.effect_instruction_i0,n=this.currentRuntimeFlags,r=Rl(n,t);if(Al(r)&&this.isInterrupted())return q(this.getInterruptedCause());if(this.patchRuntimeFlags(this.currentRuntimeFlags,t),e.effect_instruction_i1){let t=Ll(r,n);return this.pushStack(new bu(t,e)),Ce(()=>e.effect_instruction_i1(n))}return wf}[Ze](e){return this.pushStack(e),e.effect_instruction_i0}OnStep(e){return this.pushStack(e),e.effect_instruction_i0}[Xe](e){return this.pushStack(e),e.effect_instruction_i0}[Qe](e){return this.pushStack(e),e.effect_instruction_i0}[qe](e){return this._asyncBlockingOn=e.effect_instruction_i1,this.initiateAsync(this.currentRuntimeFlags,e.effect_instruction_i0),vy.currentOp=e,_y}[at](e){return this._isYielding=!1,vy.currentOp=e,_y}[nt](e){let t=e.effect_instruction_i0,n=e.effect_instruction_i1;return t()?(this.pushStack(e),n()):wf}[rt](e){return yy[rt](this,e,void 0)}[Je](e){return Ce(()=>e.commit())}runLoop(e){let t=e;for(this.currentOpCount=0;;){if(this.currentRuntimeFlags&2&&this.currentSupervisor.onEffect(this,t),this._queue.length>0&&(t=this.drainQueueWhileRunning(this.currentRuntimeFlags,t)),!this._isYielding){this.currentOpCount+=1;let e=this.currentScheduler.shouldYield(this);if(e!==!1){this._isYielding=!0,this.currentOpCount=0;let n=t;t=U(dd({priority:e}),()=>n)}}try{if(t=this.currentTracer.context(()=>{if(Sy!==t[yu]._V){let e=this.getFiberRef(Jd);if(e._tag===`Some`){let n=t[yu]._V;this.log(`Executing an Effect versioned ${n} with a Runtime of version ${st()}, you may want to dedupe the effect dependencies, you can use the language service plugin to detect this at compile time: https://github.com/Effect-TS/language-service`,Sa,e)}}return this[t._op](t)},this),t===_y){let e=vy.currentOp;return e._op===`Yield`||e._op===`Async`?_y:(vy.currentOp=null,e._op===`Success`||e._op===`Failure`?e:q(wa(e)))}}catch(e){t=t!==_y&&!y(t,`_op`)||!(t._op in this)?Iu(`Not a valid effect: ${Be(t)}`):lf(e)?q(Da(wa(e),Ta(Hs))):Fu(e)}}}run=()=>{this.drainQueueOnCurrentThread()}};const wy= m(`effect/FiberRef/currentMinimumLogLevel`,()=>Md(uh(`Info`))),Ty=e=>qg(t=>{let n=Em(t.context,Xp);Lo(n,Np).unsafe.log(e.log(t))}),Ey= m( Symbol.for(`effect/Logger/defaultLogger`),()=>Ty(Yg)),Dy= m( Symbol.for(`effect/Logger/tracerLogger`),()=>qg(({annotations:e,cause:t,context:n,fiberId:r,logLevel:i,message:a})=>{let o=wg(zo(Sm(n,Rd),Wp));if(o._tag===`None`||o.value._tag===`ExternalSpan`)return;let s=Ro(Sm(n,Xp),ep),c={};for(let[t,n]of e)c[t]=n;c[`effect.fiberId`]=Us(r),c[`effect.logLevel`]=i.label,t!==null&&t._tag!==`Empty`&&(c[`effect.cause`]=$a(t,{renderErrorCause:!0})),o.value.event(Be(Array.isArray(a)&&a.length===1?a[0]:a),s.unsafeCurrentTimeNanos(),c)})),Oy= m( Symbol.for(`effect/FiberRef/currentLoggers`),()=>Nd(aa(Ey,Dy))),ky= t(e=>ue(e[0]),(e,t,n)=>wu(r=>{let i=n?.batching===!0||n?.batching===`inherit`&&r.getFiberRef(Kd);return n?.discard?gg(n.concurrency,()=>By(lm,n?.concurrentFinalizers)(n=>i?jy(e,(e,r)=>n(t(e,r)),!0,!1,1):Zu(e,(e,r)=>n(t(e,r)))),()=>By(um,n?.concurrentFinalizers)(n=>jy(e,(e,r)=>n(t(e,r)),i,!1)),r=>By(dm(r),n?.concurrentFinalizers)(n=>jy(e,(e,r)=>n(t(e,r)),i,!1,r))):gg(n?.concurrency,()=>By(lm,n?.concurrentFinalizers)(n=>i?My(e,1,(e,r)=>n(t(e,r)),!0):Xu(e,(e,r)=>n(t(e,r)))),()=>By(um,n?.concurrentFinalizers)(n=>Ay(e,(e,r)=>n(t(e,r)),i)),r=>By(dm(r),n?.concurrentFinalizers)(n=>My(e,r,(e,r)=>n(t(e,r)),i)))})),Ay=(e,t,n)=>G(()=>{let r=z(e),i=Array(r.length);return md(jy(r,(e,n)=>U(t(e,n),e=>K(()=>i[n]=e)),n,!1),W(i))}),jy=(e,t,n,r,i)=>sd(a=>ad(o=>wu(s=>{let c=Array.from(e).reverse(),l=c.length;if(l===0)return cd;let u=0,d=!1,f=i?Math.min(c.length,i):c.length,p= new Set,m=[],h=()=>p.forEach(e=>{e.currentScheduler.scheduleTask(()=>{e.unsafeInterruptAsFork(s.id())},0,e)}),g=[],_=[],v=[],ee=()=>{let e=m.filter(({exit:e})=>e._tag===`Failure`).sort((e,t)=>e.index<t.index?-1:e.index===t.index?0:1).map(({exit:e})=>e);return e.length===0&&e.push(wf),e},te=(e,t=!1)=>{let n=od(o(e)),r=Fy(n,s,s.currentRuntimeFlags,Rg);return s.currentScheduler.scheduleTask(()=>{t&&r.unsafeInterruptAsFork(s.id()),r.resume(n)},0,r),r},ne=()=>{r||(l-=c.length,c=[]),d=!0,h()},re=n?Gu:Ru,ie=te(ju(e=>{let r=(e,t)=>{e._op===`Blocked`?v.push(e):(m.push({index:t,exit:e}),e._op===`Failure`&&!d&&ne())},o=()=>{if(c.length>0){let f=c.pop(),h=u++,ne=()=>{let e=c.pop();return h=u++,U(dd(),()=>U(re(a(t(e,h))),ie))},ie=e=>c.length>0&&(r(e,h),c.length>0)?ne():W(e),ae=U(re(a(t(f,h))),ie),y=te(ae);g.push(y),p.add(y),d&&y.currentScheduler.scheduleTask(()=>{y.unsafeInterruptAsFork(s.id())},0,y),y.addObserver(t=>{let a;if(a=t._op===`Failure`?t:t.effect_instruction_i0,_.push(y),p.delete(y),r(a,h),m.length===l)e(W(R(vf(ee(),{parallel:!0}),()=>wf)));else if(v.length+m.length===l){let t=ee(),r=v.map(e=>e.effect_instruction_i0).reduce(Ul);e(W(_u(r,jy([R(vf(t,{parallel:!0}),()=>wf),...v.map(e=>e.effect_instruction_i1)],e=>e,n,!0,i))))}else o()})}};for(let e=0;e<f;e++)o()}));return Du(nd(Ku(a(Ug(ie))),Cf({onFailure:e=>{ne();let t=v.length+1,n=Math.min(typeof i==`number`?i:v.length,v.length),r=Array.from(v);return ju(i=>{let a=[],o=0,s=0,c=(n,s)=>c=>{a[n]=c,o++,o===t&&i(J(q(e))),r.length>0&&s&&l()},l=()=>{te(r.pop(),!0).addObserver(c(s,!0)),s++};ie.addObserver(c(s,!1)),s++;for(let e=0;e<n;e++)l()})},onSuccess:()=>Xu(_,e=>e.inheritAll)})))}))),My=(e,t,n,r)=>G(()=>{let i=z(e),a=Array(i.length);return md(jy(i,(e,t)=>$u(n(e,t),e=>a[t]=e),r,!1,t),W(a))}),Ny=e=>Ly(e,Rg),Py=(e,t,n,r=null)=>{let i=Iy(e,t,n,r);return i.resume(e),i},Fy=(e,t,n,r=null)=>Iy(e,t,n,r),Iy=(e,t,n,r=null)=>{let i=Ws(),a=t.getFiberRefs(),o=vm(a,i),s=new Cy(i,o,n),l=Sm(o,Rd),u=s.currentSupervisor;return u.onStart(l,e,F(t),s),s.addObserver(e=>u.onEnd(e,s)),(r===null?c(t.getFiberRef(Xd),R(()=>t.scope())):r).add(n,s),s},Ly=(e,t)=>wu((n,r)=>W(Py(e,n,r.runtimeFlags,t))),Ry=e=>Nf(t=>Zt(zo(t,Hy),{onNone:()=>e,onSome:t=>{switch(t.strategy._tag){case`Parallel`:return e;case`Sequential`:case`ParallelN`:return U(nf(t,um),t=>Ky(e,t))}}})),zy=e=>t=>Nf(n=>Zt(zo(n,Hy),{onNone:()=>t,onSome:n=>n.strategy._tag===`ParallelN`&&n.strategy.parallelism===e?t:U(nf(n,dm(e)),e=>Ky(t,e))})),By=(e,t)=>r=>Nf(i=>Zt(zo(i,Hy),{onNone:()=>r(n),onSome:i=>{if(t===!0){let t=e._tag===`Parallel`?Ry:e._tag===`Sequential`?Vy:zy(e.parallelism);switch(i.strategy._tag){case`Parallel`:return t(r(Ry));case`Sequential`:return t(r(Vy));case`ParallelN`:return t(r(zy(i.strategy.parallelism)))}}else return r(n)}})),Vy=e=>Nf(t=>Zt(zo(t,Hy),{onNone:()=>e,onSome:t=>{switch(t.strategy._tag){case`Sequential`:return e;case`Parallel`:case`ParallelN`:return U(nf(t,lm),t=>Ky(e,t))}}})),Hy= No(`effect/Scope`),Uy=(e,t)=>{e.state._tag===`Open`&&e.state.finalizers.set({},t)},Wy={[Qd]:Qd,[$d]:$d,pipe(){return A(this,arguments)},fork(e){return K(()=>{let t=Gy(e);if(this.state._tag===`Closed`)return t.state=this.state,t;let n={};return this.state.finalizers.set(n,e=>t.close(e)),Uy(t,e=>K(()=>{this.state._tag===`Open`&&this.state.finalizers.delete(n)})),t})},close(e){return G(()=>{if(this.state._tag===`Closed`)return cd;let t=Array.from(this.state.finalizers.values()).reverse();return this.state={_tag:`Closed`,exit:e},t.length===0?cd:sm(this.strategy)?c(Xu(t,t=>Ru(t(e))),U(e=>c(vf(e),rn(_f),R(()=>wf)))):cm(this.strategy)?c(Ay(t,t=>Ru(t(e)),!1),U(e=>c(vf(e,{parallel:!0}),rn(_f),R(()=>wf)))):c(My(t,this.strategy.parallelism,t=>Ru(t(e)),!1),U(e=>c(vf(e,{parallel:!0}),rn(_f),R(()=>wf))))})},addFinalizer(e){return G(()=>this.state._tag===`Closed`?e(this.state.exit):(this.state.finalizers.set({},e),cd))}},Gy=(e=im)=>{let t=Object.create(Wy);return t.strategy=e,t.state={_tag:`Open`,finalizers: new Map},t},Ky= t(2,(e,t)=>Ff(e,Bo(Fo(Hy,t)))),qy=e=>Id(e,{differ:sy,fork:ty}),Jy= Ld(Pl),Yy= qy(Yv),Xy= t(2,(e,t)=>sd(n=>Ju(n(e),{onFailure:e=>Ju(t,{onFailure:t=>Vu(Da(e,t)),onSuccess:()=>Vu(e)}),onSuccess:e=>Eu(t,e)}))),Zy=(e,t,n)=>Wu(r=>Xy(U(Ny(Qu(e)),e=>ju(r=>{let i=t.map(e=>e.listeners.count),a=()=>{i.every(e=>e===0)&&t.every(e=>!!(e.result.state.current._tag===`Pending`||e.result.state.current._tag===`Done`&&mf(e.result.state.current.effect)&&e.result.state.current.effect._tag===`Failure`&&Ma(e.result.state.current.effect.cause)))&&(o.forEach(e=>e()),n?.(),r(hd(e)))};e.addObserver(e=>{o.forEach(e=>e()),r(e)});let o=t.map((e,t)=>{let n=e=>{i[t]=e,a()};return e.listeners.addObserver(n),()=>e.listeners.removeObserver(n)});return a(),K(()=>{o.forEach(e=>e())})})),G(()=>{let e=t.flatMap(e=>e.state.completed?[]:[e]);return Zu(e,e=>Vv(e.request,xf(r)))}))),Qy=tf,$y=nf,eb=e=>function(){if(arguments.length===1){let t=arguments[0];return(n,...r)=>e(t,n,...r)}return e.apply(this,arguments)},tb= eb((e,t,n)=>{let r=Ws(),i=[[Rd,[[r,e.context]]]];n?.scheduler&&i.push([mg,[[r,n.scheduler]]]);let a=Dm(e.fiberRefs,{entries:i,forkAs:r});n?.updateRefs&&(a=n.updateRefs(a,r));let o=new Cy(r,a,e.runtimeFlags),s=t;n?.scope&&(s=U($y(n.scope,im),e=>md(ef(e,Wu(e=>E(e,o.id())?cd:gd(o,e))),nd(t,t=>Qy(e,t)))));let c=o.currentSupervisor;return c!==Yv&&(c.onStart(e.context,s,P(),o),o.addObserver(e=>c.onEnd(e,o))),Rg.add(e.runtimeFlags,o),n?.immediate===!1?o.resume(s):o.start(s),o}),nb= eb((e,t)=>{let n=ub(e)(t);if(n._tag===`Failure`)throw cb(n.effect_instruction_i0);return n.effect_instruction_i0});var rb=class extends Error{fiber;_tag=`AsyncFiberException`;constructor(e){super(`Fiber #${e.id().id} cannot be resolved synchronously. This is caused by using runSync on an effect that performs async work`),this.fiber=e,this.name=this._tag,this.stack=this.message}};const ib=e=>{let t=Error.stackTraceLimit;Error.stackTraceLimit=0;let n=new rb(e);return Error.stackTraceLimit=t,n},ab= Symbol.for(`effect/Runtime/FiberFailure`),ob= Symbol.for(`effect/Runtime/FiberFailure/Cause`);var sb=class extends Error{[ab];[ob];constructor(e){let t=so(e)[0];super(t?.message||`An error has occurred`),this[ab]=ab,this[ob]=e,this.name=t?`(FiberFailure) ${t.name}`:`FiberFailure`,t?.stack&&(this.stack=t.stack)}toJSON(){return{_id:`FiberFailure`,cause:this[ob].toJSON()}}toString(){return`(FiberFailure) `+$a(this[ob],{renderErrorCause:!0})}[D](){return this.toString()}};const cb=e=>{let t=Error.stackTraceLimit;Error.stackTraceLimit=0;let n=new sb(e);return Error.stackTraceLimit=t,n},lb=e=>{let t=e;switch(t._op){case`Failure`:case`Success`:return t;case`Left`:return bf(t.left);case`Right`:return J(t.right);case`Some`:return J(t.value);case`None`:return bf(new df)}},ub= eb((e,t)=>{let n=lb(t);if(n)return n;let r=new pg,i=tb(e)(t,{scheduler:r});return r.flush(),i.unsafePoll()||yf(Pu(ib(i),If(i)))});var db=class{context;runtimeFlags;fiberRefs;constructor(e,t,n){this.context=e,this.runtimeFlags=t,this.fiberRefs=n}pipe(){return A(this,arguments)}};const fb= (e=>new db(e.context,e.runtimeFlags,e.fiberRefs))({context: Po(),runtimeFlags: Nl(1,32,4),fiberRefs: Om()}),pb= tb(fb),mb= nb(fb),hb= Symbol.for(`effect/DateTime`),gb= Symbol.for(`effect/DateTime/TimeZone`),_b={[hb]:hb,pipe(){return A(this,arguments)},[D](){return this.toString()},toJSON(){return yb(this).toJSON()}};({..._b}),{..._b};const vb={[gb]:gb,[D](){return this.toString()}};({...vb}),{...vb};const yb=e=>new Date(e.epochMillis),bb=Cu,xb=ky,Sb=G,Cb=cd,wb=Mu,Tb=$u,Eb=td,Db=Lu,Ob=U,kb=pb,Ab=mb,jb=(e,t)=>{switch(t._tag){case`StringKeyword`:case`TemplateLiteral`:return Object.keys(e);case`SymbolKeyword`:return Object.getOwnPropertySymbols(e);case`Refinement`:return jb(e,t.from)}},Mb=e=>{let t=!1,n;return()=>t?n:(n=e(),t=!0,n)},Nb=e=>Array.isArray(e),Pb=e=>!Array.isArray(e),Fb=e=>`[${Re(e)}]`,Ib=e=>Nb(e)?e.map(Fb).join(``):Fb(e),Lb=(e,t,n,r)=>{let i=e;return n&&B(n)&&(i+=`\nat path: ${Ib(n)}`),t!==void 0&&(i+=`\ndetails: ${t}`),r&&(i+=`\nschema (${r._tag}): ${r}`),i},Rb=e=>Lb(`Unsupported key schema`,void 0,void 0,e),zb=e=>Lb(`Unsupported literal`,`literal value: ${ze(e)}`),Bb=e=>Lb(`Duplicate index signature`,`${e} index signature`),Vb= Lb(`Unsupported index signature parameter`,"An index signature parameter type must be `string`, `symbol`, a template literal type or a refinement of the previous types"),Hb= Lb(`Invalid element`,`A required element cannot follow an optional element. ts(1257)`),Ub=e=>Lb(`Duplicate property signature transformation`,`Duplicate key ${ze(e)}`),Wb=e=>Lb(`Duplicate property signature`,`Duplicate key ${ze(e)}`),Gb= Symbol.for(`effect/SchemaId/GreaterThanOrEqualTo`),Kb= Symbol.for(`effect/SchemaId/LessThanOrEqualTo`),qb= Symbol.for(`effect/SchemaId/MinLength`),Jb= Symbol.for(`effect/SchemaId/MaxLength`),Yb= Symbol.for(`effect/annotation/TypeConstructor`),Xb= Symbol.for(`effect/annotation/Brand`),Zb= Symbol.for(`effect/annotation/SchemaId`),Qb= Symbol.for(`effect/annotation/Message`),$b= Symbol.for(`effect/annotation/MissingMessage`),ex= Symbol.for(`effect/annotation/Identifier`),tx= Symbol.for(`effect/annotation/Title`),nx= Symbol.for(`effect/annotation/AutoTitle`),rx= Symbol.for(`effect/annotation/Description`),ix= Symbol.for(`effect/annotation/Examples`),ax= Symbol.for(`effect/annotation/Default`),ox= Symbol.for(`effect/annotation/JSONSchema`),sx= Symbol.for(`effect/annotation/Arbitrary`),cx= Symbol.for(`effect/annotation/Pretty`),lx= Symbol.for(`effect/annotation/Equivalence`),ux= Symbol.for(`effect/annotation/Documentation`),dx= Symbol.for(`effect/annotation/Concurrency`),fx= Symbol.for(`effect/annotation/Batching`),px= Symbol.for(`effect/annotation/ParseIssueTitle`),mx= Symbol.for(`effect/annotation/ParseOptions`),hx= Symbol.for(`effect/annotation/DecodingFallback`),gx= Symbol.for(`effect/annotation/Surrogate`),_x= Symbol.for(`effect/annotation/StableFilter`),vx= t(2,(e,t)=>Object.prototype.hasOwnProperty.call(e.annotations,t)?F(e.annotations[t]):P()),yx= vx(Xb),bx= vx(Qb),xx= vx($b),Sx= vx(tx),Cx= vx(nx),wx= vx(ex),Tx= vx(rx),Ex= vx(dx),Dx= vx(fx),Ox= vx(px),kx= vx(mx),Ax= vx(hx),jx= vx(gx),Mx= vx(_x),Nx=e=>cn(Mx(e),e=>e===!0),Px= Symbol.for(`effect/annotation/JSONIdentifier`),Fx= vx(Px),Ix=e=>Qt(Fx(e),()=>wx(e));var Lx=class{typeParameters;decodeUnknown;encodeUnknown;annotations;_tag=`Declaration`;constructor(e,t,n,r={}){this.typeParameters=e,this.decodeUnknown=t,this.encodeUnknown=n,this.annotations=r}toString(){return R(zS(this),()=>`<declaration schema>`)}toJSON(){return{_tag:this._tag,typeParameters:this.typeParameters.map(e=>e.toJSON()),annotations:Q(this.annotations)}}};const Rx=e=>t=>t._tag===e;var zx=class{literal;annotations;_tag=`Literal`;constructor(e,t={}){this.literal=e,this.annotations=t}toString(){return R(zS(this),()=>ze(this.literal))}toJSON(){return{_tag:this._tag,literal:v(this.literal)?String(this.literal):this.literal,annotations:Q(this.annotations)}}};const Bx= Rx(`Literal`),Vx= new zx(null);var Hx=class{symbol;annotations;_tag=`UniqueSymbol`;constructor(e,t={}){this.symbol=e,this.annotations=t}toString(){return R(zS(this),()=>ze(this.symbol))}toJSON(){return{_tag:this._tag,symbol:String(this.symbol),annotations:Q(this.annotations)}}};const Ux= new class{annotations;_tag=`NeverKeyword`;constructor(e={}){this.annotations=e}toString(){return IS(this)}toJSON(){return{_tag:this._tag,annotations:Q(this.annotations)}}}({[tx]:`never`}),Wx= new class{annotations;_tag=`UnknownKeyword`;constructor(e={}){this.annotations=e}toString(){return IS(this)}toJSON(){return{_tag:this._tag,annotations:Q(this.annotations)}}}({[tx]:`unknown`}),Gx= new class{annotations;_tag=`AnyKeyword`;constructor(e={}){this.annotations=e}toString(){return IS(this)}toJSON(){return{_tag:this._tag,annotations:Q(this.annotations)}}}({[tx]:`any`}),Kx= new class{annotations;_tag=`StringKeyword`;constructor(e={}){this.annotations=e}toString(){return IS(this)}toJSON(){return{_tag:this._tag,annotations:Q(this.annotations)}}}({[tx]:`string`,[rx]:`a string`}),qx= Rx(`StringKeyword`),Jx= new class{annotations;_tag=`NumberKeyword`;constructor(e={}){this.annotations=e}toString(){return IS(this)}toJSON(){return{_tag:this._tag,annotations:Q(this.annotations)}}}({[tx]:`number`,[rx]:`a number`}),Yx= Rx(`SymbolKeyword`);var Xx=class{type;annotations;constructor(e,t={}){this.type=e,this.annotations=t}toJSON(){return{type:this.type.toJSON(),annotations:Q(this.annotations)}}toString(){return String(this.type)}},Zx=class extends Xx{isOptional;constructor(e,t,n={}){super(e,n),this.isOptional=t}toJSON(){return{type:this.type.toJSON(),isOptional:this.isOptional,annotations:Q(this.annotations)}}toString(){return String(this.type)+(this.isOptional?`?`:``)}};const Qx=e=>e.map(e=>e.type);var $x=class{elements;rest;isReadonly;annotations;_tag=`TupleType`;constructor(e,t,n,r={}){this.elements=e,this.rest=t,this.isReadonly=n,this.annotations=r;let i=!1,a=!1;for(let t of e)if(t.isOptional)i=!0;else if(i){a=!0;break}if(a||i&&t.length>1)throw Error(Hb)}toString(){return R(zS(this),()=>eS(this))}toJSON(){return{_tag:this._tag,elements:this.elements.map(e=>e.toJSON()),rest:this.rest.map(e=>e.toJSON()),isReadonly:this.isReadonly,annotations:Q(this.annotations)}}};const eS=e=>{let t=e.elements.map(String).join(`, `);return pn(e.rest,{onEmpty:()=>`readonly [${t}]`,onNonEmpty:(n,r)=>{let i=String(n),a=i.includes(` | `)?`(${i})`:i;if(r.length>0){let n=r.map(String).join(`, `);return e.elements.length>0?`readonly [${t}, ...${a}[], ${n}]`:`readonly [...${a}[], ${n}]`}return e.elements.length>0?`readonly [${t}, ...${a}[]]`:`ReadonlyArray<${i}>`}})};var X=class extends Zx{name;isReadonly;constructor(e,t,n,r,i){super(t,n,i),this.name=e,this.isReadonly=r}toString(){return(this.isReadonly?`readonly `:``)+String(this.name)+(this.isOptional?`?`:``)+`: `+this.type}toJSON(){return{name:String(this.name),type:this.type.toJSON(),isOptional:this.isOptional,isReadonly:this.isReadonly,annotations:Q(this.annotations)}}};const tS=e=>{switch(e._tag){case`StringKeyword`:case`SymbolKeyword`:case`TemplateLiteral`:return!0;case`Refinement`:return tS(e.from)}return!1};var nS=class{type;isReadonly;parameter;constructor(e,t,n){if(this.type=t,this.isReadonly=n,tS(e))this.parameter=e;else throw Error(Vb)}toString(){return(this.isReadonly?`readonly `:``)+`[x: ${this.parameter}]: ${this.type}`}toJSON(){return{parameter:this.parameter.toJSON(),type:this.type.toJSON(),isReadonly:this.isReadonly}}},rS=class{annotations;_tag=`TypeLiteral`;propertySignatures;indexSignatures;constructor(e,t,n={}){this.annotations=n;let r={};for(let t=0;t<e.length;t++){let n=e[t].name;if(Object.prototype.hasOwnProperty.call(r,n))throw Error(Wb(n));r[n]=null}let i={string:!1,symbol:!1};for(let e=0;e<t.length;e++){let n=FS(t[e].parameter);if(qx(n)){if(i.string)throw Error(Bb(`string`));i.string=!0}else if(Yx(n)){if(i.symbol)throw Error(Bb(`symbol`));i.symbol=!0}}this.propertySignatures=e,this.indexSignatures=t}toString(){return R(zS(this),()=>aS(this))}toJSON(){return{_tag:this._tag,propertySignatures:this.propertySignatures.map(e=>e.toJSON()),indexSignatures:this.indexSignatures.map(e=>e.toJSON()),annotations:Q(this.annotations)}}};const iS=e=>e.map(String).join(`; `),aS=e=>{if(e.propertySignatures.length>0){let t=e.propertySignatures.map(String).join(`; `);return e.indexSignatures.length>0?`{ ${t}; ${iS(e.indexSignatures)} }`:`{ ${t} }`}return e.indexSignatures.length>0?`{ ${iS(e.indexSignatures)} }`:`{}`},oS= Nn( Yt(sp,e=>{switch(e._tag){case`AnyKeyword`:return 0;case`UnknownKeyword`:return 1;case`ObjectKeyword`:return 2;case`StringKeyword`:case`NumberKeyword`:case`BooleanKeyword`:case`BigIntKeyword`:case`SymbolKeyword`:return 3}return 4})),sS={string:`StringKeyword`,number:`NumberKeyword`,boolean:`BooleanKeyword`,bigint:`BigIntKeyword`},cS=e=>Gn(e,e=>pS(e)?cS(e.types):[e]),lS=e=>{let t=oS(e),n=[],r={},i=[];for(let e of t)switch(e._tag){case`NeverKeyword`:break;case`AnyKeyword`:return[Gx];case`UnknownKeyword`:return[Wx];case`ObjectKeyword`:case`UndefinedKeyword`:case`VoidKeyword`:case`StringKeyword`:case`NumberKeyword`:case`BooleanKeyword`:case`BigIntKeyword`:case`SymbolKeyword`:r[e._tag]||(r[e._tag]=e,n.push(e));break;case`Literal`:{let t=typeof e.literal;switch(t){case`string`:case`number`:case`bigint`:case`boolean`:!r[sS[t]]&&!i.includes(e.literal)&&(i.push(e.literal),n.push(e));break;case`object`:i.includes(e.literal)||(i.push(e.literal),n.push(e))}break}case`UniqueSymbol`:!r.SymbolKeyword&&!i.includes(e.symbol)&&(i.push(e.symbol),n.push(e));break;case`TupleType`:r.ObjectKeyword||n.push(e);break;case`TypeLiteral`:e.propertySignatures.length===0&&e.indexSignatures.length===0?r[`{}`]||(r[`{}`]=e,n.push(e)):r.ObjectKeyword||n.push(e);break;default:n.push(e)}return n};var uS=class e{types;annotations;static make=(t,n)=>fS(t)?new e(t,n):t.length===1?t[0]:Ux;static unify=(t,n)=>e.make(lS(cS(t)),n);_tag=`Union`;constructor(e,t={}){this.types=e,this.annotations=t}toString(){return R(zS(this),()=>this.types.map(String).join(` | `))}toJSON(){return{_tag:this._tag,types:this.types.map(e=>e.toJSON()),annotations:Q(this.annotations)}}};const dS=(e,t)=>e.map(t),fS=e=>e.length>1,pS= Rx(`Union`),mS= m( Symbol.for(`effect/Schema/AST/toJSONMemoMap`),()=> new WeakMap);var hS=class{f;annotations;_tag=`Suspend`;constructor(e,t={}){this.f=e,this.annotations=t,this.f=Mb(e)}toString(){return zS(this).pipe(Qt(()=>an(nn(this.f)(),e=>zS(e))),R(()=>`<suspended schema>`))}toJSON(){let e=this.f(),t=mS.get(e);return t||(mS.set(e,{_tag:this._tag}),t={_tag:this._tag,ast:e.toJSON(),annotations:Q(this.annotations)},mS.set(e,t),t)}},gS=class{from;filter;annotations;_tag=`Refinement`;constructor(e,t,n={}){this.from=e,this.filter=t,this.annotations=n}toString(){return wx(this).pipe(R(()=>Zt(RS(this),{onNone:()=>`{ ${this.from} | filter }`,onSome:e=>_S(this.from)?String(this.from)+` & `+e:e})))}toJSON(){return{_tag:this._tag,from:this.from.toJSON(),annotations:Q(this.annotations)}}};const _S= Rx(`Refinement`),vS={};var yS=class{from;to;transformation;annotations;_tag=`Transformation`;constructor(e,t,n,r={}){this.from=e,this.to=t,this.transformation=n,this.annotations=r}toString(){return R(zS(this),()=>`(${String(this.from)} <-> ${String(this.to)})`)}toJSON(){return{_tag:this._tag,from:this.from.toJSON(),to:this.to.toJSON(),annotations:Q(this.annotations)}}},bS=class{from;to;decode;encode;constructor(e,t,n,r){this.from=e,this.to=t,this.decode=n,this.encode=r}},xS=class{propertySignatureTransformations;_tag=`TypeLiteralTransformation`;constructor(e){this.propertySignatureTransformations=e;let t={},n={};for(let r of e){let e=r.from;if(t[e])throw Error(Ub(e));t[e]=!0;let i=r.to;if(n[i])throw Error(Ub(i));n[i]=!0}}};const SS=(e,t)=>{let n=Object.getOwnPropertyDescriptors(e),r={...e.annotations};delete r[ex];let i={...r,...t},a=jx(e);return L(a)&&(i[gx]=SS(a.value,t)),n.annotations.value=i,Object.create(Object.getPrototypeOf(e),n)},CS=(e,t)=>{switch(e._tag){case`Literal`:return cp(String(e.literal));case`StringKeyword`:return`[\\s\\S]*?`;case`NumberKeyword`:return`[+-]?\\d*\\.?\\d+(?:[Ee][+-]?\\d+)?`;case`TemplateLiteral`:return TS(e,t,!1);case`Union`:return e.types.map(e=>CS(e,t)).join(`|`)}},wS=(e,t,n,r)=>{if(pS(e)){if(n&&!r)return`(?:${t})`}else if(!n||!r)return t;return`(${t})`},TS=(e,t,n)=>{let r=``;if(e.head!==``){let i=cp(e.head);r+=t&&n?`(${i})`:i}for(let i of e.spans){let e=CS(i.type,t);if(r+=wS(i.type,e,t,n),i.literal!==``){let e=cp(i.literal);r+=t&&n?`(${e})`:e}}return r},ES=e=>RegExp(`^${TS(e,!1,!0)}$`),DS=(e,t)=>{let n=[],r=[],i=e=>{switch(e._tag){case`NeverKeyword`:break;case`StringKeyword`:case`SymbolKeyword`:case`TemplateLiteral`:case`Refinement`:r.push(new nS(e,t,!0));break;case`Literal`:if(h(e.literal)||g(e.literal))n.push(new X(e.literal,t,!1,!0));else throw Error(zb(e.literal));break;case`Enums`:for(let[r,i]of e.enums)n.push(new X(i,t,!1,!0));break;case`UniqueSymbol`:n.push(new X(e.symbol,t,!1,!0));break;case`Union`:e.types.forEach(i);break;default:throw Error(Rb(e))}};return i(e),{propertySignatures:n,indexSignatures:r}},OS=e=>{switch(e._tag){case`TupleType`:return e.isReadonly===!1?e:new $x(e.elements,e.rest,!1,e.annotations);case`TypeLiteral`:{let t=jS(e.propertySignatures,e=>e.isReadonly===!1?e:new X(e.name,e.type,e.isOptional,!1,e.annotations)),n=jS(e.indexSignatures,e=>e.isReadonly===!1?e:new nS(e.parameter,e.type,!1));return t===e.propertySignatures&&n===e.indexSignatures?e:new rS(t,n,e.annotations)}case`Union`:{let t=jS(e.types,OS);return t===e.types?e:uS.make(t,e.annotations)}case`Suspend`:return new hS(()=>OS(e.f()),e.annotations);case`Refinement`:{let t=OS(e.from);return t===e.from?e:new gS(t,e.filter,e.annotations)}case`Transformation`:{let t=OS(e.from),n=OS(e.to);return t===e.from&&n===e.to?e:new yS(t,n,e.transformation,e.annotations)}}return e},kS=e=>t=>{let n;for(let r of e)Object.prototype.hasOwnProperty.call(t.annotations,r)&&(n===void 0&&(n={}),n[r]=t.annotations[r]);return n},AS= kS([ix,ax,ox,sx,cx,lx]),Z=e=>{switch(e._tag){case`Declaration`:{let t=jS(e.typeParameters,Z);return t===e.typeParameters?e:new Lx(t,e.decodeUnknown,e.encodeUnknown,e.annotations)}case`TupleType`:{let t=jS(e.elements,e=>{let t=Z(e.type);return t===e.type?e:new Zx(t,e.isOptional)}),n=Qx(e.rest),r=jS(n,Z);return t===e.elements&&r===n?e:new $x(t,r.map(e=>new Xx(e)),e.isReadonly,e.annotations)}case`TypeLiteral`:{let t=jS(e.propertySignatures,e=>{let t=Z(e.type);return t===e.type?e:new X(e.name,t,e.isOptional,e.isReadonly)}),n=jS(e.indexSignatures,e=>{let t=Z(e.type);return t===e.type?e:new nS(e.parameter,t,e.isReadonly)});return t===e.propertySignatures&&n===e.indexSignatures?e:new rS(t,n,e.annotations)}case`Union`:{let t=jS(e.types,Z);return t===e.types?e:uS.make(t,e.annotations)}case`Suspend`:return new hS(()=>Z(e.f()),e.annotations);case`Refinement`:{let t=Z(e.from);return t===e.from?e:new gS(t,e.filter,e.annotations)}case`Transformation`:{let t=AS(e);return Z(t===void 0?e.to:SS(e.to,t))}}return e};function jS(e,t){let n=!1,r=un(e.length);for(let i=0;i<e.length;i++){let a=e[i],o=t(a);o!==a&&(n=!0),r[i]=o}return n?r:e}const MS=e=>{switch(e._tag){case`Transformation`:return e.from;case`Refinement`:return MS(e.from);case`Suspend`:return MS(e.f())}},NS=(e,t)=>{switch(e._tag){case`Declaration`:{let n=jS(e.typeParameters,e=>NS(e,t));return n===e.typeParameters?e:new Lx(n,e.decodeUnknown,e.encodeUnknown)}case`TupleType`:{let n=jS(e.elements,e=>{let n=NS(e.type,t);return n===e.type?e:new Zx(n,e.isOptional)}),r=Qx(e.rest),i=jS(r,e=>NS(e,t));return n===e.elements&&i===r?e:new $x(n,i.map(e=>new Xx(e)),e.isReadonly)}case`TypeLiteral`:{let n=jS(e.propertySignatures,e=>{let n=NS(e.type,t);return n===e.type?e:new X(e.name,n,e.isOptional,e.isReadonly)}),r=jS(e.indexSignatures,e=>{let n=NS(e.type,t);return n===e.type?e:new nS(e.parameter,n,e.isReadonly)});return n===e.propertySignatures&&r===e.indexSignatures?e:new rS(n,r)}case`Union`:{let n=jS(e.types,e=>NS(e,t));return n===e.types?e:uS.make(n)}case`Suspend`:{let n,r=Ix(e);if(L(r)){let e=t?`Bound`:``;n={[Px]:`${r.value}Encoded${e}`}}return new hS(()=>NS(e.f(),t),n)}case`Refinement`:{let n=NS(e.from,t);return t?n===e.from?e:MS(e.from)===void 0&&Nx(e)?new gS(n,e.filter,e.annotations):n:n}case`Transformation`:return NS(e.from,t)}return e},PS=e=>NS(e,!1),Q=e=>{let t={};for(let n of Object.getOwnPropertySymbols(e))t[String(n)]=e[n];return t},FS=e=>{switch(e._tag){case`StringKeyword`:case`SymbolKeyword`:case`TemplateLiteral`:return e;case`Refinement`:return FS(e.from)}},IS=e=>R(zS(e),()=>e._tag);function LS(e){return Zt(yx(e),{onNone:()=>``,onSome:e=>e.map(e=>` & Brand<${ze(e)}>`).join(``)})}const RS=e=>Sx(e).pipe(Qt(()=>Tx(e)),Qt(()=>Cx(e)),rn(t=>t+LS(e))),zS=e=>Qt(wx(e),()=>RS(e));var BS=class{path;actual;issue;_tag=`Pointer`;constructor(e,t,n){this.path=e,this.actual=t,this.issue=n}},VS=class{actual;message;_tag=`Unexpected`;constructor(e,t){this.actual=e,this.message=t}},HS=class{ast;message;_tag=`Missing`;actual=void 0;constructor(e,t){this.ast=e,this.message=t}},$=class{ast;actual;issues;output;_tag=`Composite`;constructor(e,t,n,r){this.ast=e,this.actual=t,this.issues=n,this.output=r}},US=class{ast;actual;kind;issue;_tag=`Refinement`;constructor(e,t,n,r){this.ast=e,this.actual=t,this.kind=n,this.issue=r}},WS=class{ast;actual;kind;issue;_tag=`Transformation`;constructor(e,t,n,r){this.ast=e,this.actual=t,this.kind=n,this.issue=r}},GS=class{ast;actual;message;_tag=`Type`;constructor(e,t,n){this.ast=e,this.actual=t,this.message=n}},KS=class{ast;actual;message;_tag=`Forbidden`;constructor(e,t,n){this.ast=e,this.actual=t,this.message=n}};const qS= Symbol.for(`effect/Schema/ParseErrorTypeId`);var JS=class extends ( Qp(`ParseError`)){[qS]=qS;get message(){return this.toString()}toString(){return CC.formatIssueSync(this.issue)}toJSON(){return{_id:`ParseError`,message:this.toString()}}[D](){return this.toJSON()}};const YS=e=>new JS({issue:e}),XS=j,ZS=M,QS=Rt,$S= t(2,(e,t)=>QS(e)?Ht(e,{onLeft:M,onRight:t}):Ob(e,t)),eC= t(2,(e,t)=>QS(e)?Vt(e,t):Tb(e,t)),tC= t(2,(e,t)=>QS(e)?Bt(e,t):Eb(e,t)),nC= t(2,(e,t)=>QS(e)?Ht(e,{onLeft:t,onRight:j}):wb(e,t)),rC=(e,t)=>t===void 0||g(t)?e:e===void 0?t:{...e,...t},iC=(e,t,n)=>{let r=uC(e,t);return(e,t)=>r(e,rC(n,t))},aC=(e,t,n)=>{let r=iC(e,t,n);return(e,t)=>Wt(r(e,t),YS)},oC=(e,t)=>iC(e.ast,!0,t),sC=(e,t)=>aC(Z(e.ast),!0,t),cC= m( Symbol.for(`effect/ParseResult/decodeMemoMap`),()=> new WeakMap),lC= m( Symbol.for(`effect/ParseResult/encodeMemoMap`),()=> new WeakMap),uC=(e,t)=>{let n=t?cC:lC,r=n.get(e);if(r)return r;let i=pC(e,t),a=kx(e),o=L(a)?(e,t)=>i(e,rC(t,a.value)):i,s=Ax(e),c=t&&L(s)?(t,n)=>vC(nC(o(t,n),s.value),e,t,n):o;return n.set(e,c),c},dC=e=>tn(Ex(e)),fC=e=>tn(Dx(e)),pC=(e,t)=>{switch(e._tag){case`Refinement`:if(t){let t=uC(e.from,!0);return(n,r)=>{r??=vS;let i=r?.errors===`all`,a=$S(nC(t(n,r),t=>{let a=new US(e,n,`From`,t);return i&&Nx(e)&&MC(t)?Zt(e.filter(n,r,e),{onNone:()=>M(a),onSome:t=>M(new $(e,n,[a,new US(e,n,`Predicate`,t)]))}):M(a)}),t=>Zt(e.filter(t,r,e),{onNone:()=>j(t),onSome:t=>M(new US(e,n,`Predicate`,t))}));return vC(a,e,n,r)}}{let t=uC(Z(e),!0),n=uC(_C(e.from),!1);return(r,i)=>vC($S(t(r,i),e=>n(e,i)),e,r,i)}case`Transformation`:{let n=xC(e.transformation,t),r=t?uC(e.from,!0):uC(e.to,!1),i=t?uC(e.to,!0):uC(e.from,!1);return(a,o)=>vC($S(tC(r(a,o),n=>new WS(e,a,t?`Encoded`:`Type`,n)),r=>$S(tC(n(r,o??vS,e,a),t=>new WS(e,a,`Transformation`,t)),n=>tC(i(n,o),n=>new WS(e,a,t?`Type`:`Encoded`,n)))),e,a,o)}case`Declaration`:{let n=t?e.decodeUnknown(...e.typeParameters):e.encodeUnknown(...e.typeParameters);return(t,r)=>vC(n(t,r??vS,e),e,t,r)}case`Literal`:return mC(e,t=>t===e.literal);case`UniqueSymbol`:return mC(e,t=>t===e.symbol);case`UndefinedKeyword`:return mC(e,ne);case`NeverKeyword`:return mC(e,re);case`UnknownKeyword`:case`AnyKeyword`:case`VoidKeyword`:return j;case`StringKeyword`:return mC(e,h);case`NumberKeyword`:return mC(e,g);case`BooleanKeyword`:return mC(e,_);case`BigIntKeyword`:return mC(e,v);case`SymbolKeyword`:return mC(e,ee);case`ObjectKeyword`:return mC(e,ae);case`Enums`:return mC(e,t=>e.enums.some(([e,n])=>n===t));case`TemplateLiteral`:{if(e.spans.every(e=>qx(e.type)))return mC(e,t=>{if(!h(t)||!t.startsWith(e.head))return!1;let n=e.head.length;for(let r=0;r<e.spans.length-1;r++){let i=e.spans[r].literal,a=t.indexOf(i,n);if(a===-1)return!1;n=a+i.length}let r=e.spans[e.spans.length-1].literal;return t.endsWith(r)&&t.length-r.length>=n});let t=ES(e);return mC(e,e=>h(e)&&t.test(e))}case`TupleType`:{let n=e.elements.map(e=>uC(e.type,t)),r=e.rest.map(e=>uC(e.type,t)),i=e.elements.filter(e=>!e.isOptional);e.rest.length>0&&(i=i.concat(e.rest.slice(1)));let a=i.length,o=e.elements.length>0?e.elements.map((e,t)=>t).join(` | `):`never`,s=dC(e),c=fC(e);return(t,l)=>{if(!_n(t))return M(new GS(e,t));let u=l?.errors===`all`,d=[],f=0,p=[],m=t.length;for(let n=m;n<=a-1;n++){let r=new BS(n,t,new HS(i[n-m]));if(u){d.push([f++,r]);continue}return M(new $(e,t,r,p))}if(e.rest.length===0)for(let n=e.elements.length;n<=m-1;n++){let r=new BS(n,t,new VS(t[n],`is unexpected, expected: ${o}`));if(u){d.push([f++,r]);continue}return M(new $(e,t,r,p))}let h=0,g;for(;h<n.length;h++)if(m<h+1){if(e.elements[h].isOptional)continue}else{let r=n[h],i=r(t[h],l);if(QS(i)){if(N(i)){let n=new BS(h,t,i.left);if(u){d.push([f++,n]);continue}return M(new $(e,t,n,bC(p)))}p.push([f++,i.right])}else{let n=f++,r=h;g||=[],g.push(({es:a,output:o})=>Ob(Db(i),i=>{if(N(i)){let s=new BS(r,t,i.left);return u?(a.push([n,s]),Cb):M(new $(e,t,s,bC(o)))}return o.push([n,i.right]),Cb}))}}if(B(r)){let[n,...i]=r;for(;h<m-i.length;h++){let r=n(t[h],l);if(QS(r)){if(N(r)){let n=new BS(h,t,r.left);if(u){d.push([f++,n]);continue}return M(new $(e,t,n,bC(p)))}p.push([f++,r.right])}else{let n=f++,i=h;g||=[],g.push(({es:a,output:o})=>Ob(Db(r),r=>{if(N(r)){let s=new BS(i,t,r.left);return u?(a.push([n,s]),Cb):M(new $(e,t,s,bC(o)))}return o.push([n,r.right]),Cb}))}}for(let n=0;n<i.length;n++){let r=h+n;if(!(m<r+1)){let a=i[n](t[r],l);if(QS(a)){if(N(a)){let n=new BS(r,t,a.left);if(u){d.push([f++,n]);continue}return M(new $(e,t,n,bC(p)))}p.push([f++,a.right])}else{let n=f++;g||=[],g.push(({es:i,output:o})=>Ob(Db(a),a=>{if(N(a)){let s=new BS(r,t,a.left);return u?(i.push([n,s]),Cb):M(new $(e,t,s,bC(o)))}return o.push([n,a.right]),Cb}))}}}}let _=({es:n,output:r})=>yn(n)?M(new $(e,t,bC(n),bC(r))):j(bC(r));if(g&&g.length>0){let e=g;return Sb(()=>{let t={es:zn(d),output:zn(p)};return Ob(xb(e,e=>e(t),{concurrency:s,batching:c,discard:!0}),()=>_(t))})}return _({output:p,es:d})}}case`TypeLiteral`:{if(e.propertySignatures.length===0&&e.indexSignatures.length===0)return mC(e,ce);let n=[],r={},i=[];for(let a of e.propertySignatures)n.push([uC(a.type,t),a]),r[a.name]=null,i.push(a.name);let a=e.indexSignatures.map(e=>[uC(e.parameter,t),uC(e.type,t),e.parameter]),o=uS.make(e.indexSignatures.map(e=>e.parameter).concat(i.map(e=>ee(e)?new Hx(e):new zx(e)))),s=uC(o,t),c=dC(e),l=fC(e);return(t,u)=>{if(!de(t))return M(new GS(e,t));let d=u?.errors===`all`,f=[],p=0,m=u?.onExcessProperty===`error`,h=u?.onExcessProperty===`preserve`,g={},_;if(m||h){_=Reflect.ownKeys(t);for(let n of _){let r=s(n,u);if(QS(r)&&N(r)){if(m){let r=new BS(n,t,new VS(t[n],`is unexpected, expected: ${String(o)}`));if(d){f.push([p++,r]);continue}return M(new $(e,t,r,g))}g[n]=t[n]}}}let v,ee=u?.exact===!0;for(let r=0;r<n.length;r++){let i=n[r][1],a=i.name,o=Object.prototype.hasOwnProperty.call(t,a);if(!o){if(i.isOptional)continue;if(ee){let n=new BS(a,t,new HS(i));if(d){f.push([p++,n]);continue}return M(new $(e,t,n,g))}}let s=n[r][0],c=s(t[a],u);if(QS(c)){if(N(c)){let n=new BS(a,t,o?c.left:new HS(i));if(d){f.push([p++,n]);continue}return M(new $(e,t,n,g))}g[a]=c.right}else{let n=p++,r=a;v||=[],v.push(({es:a,output:s})=>Ob(Db(c),c=>{if(N(c)){let l=new BS(r,t,o?c.left:new HS(i));return d?(a.push([n,l]),Cb):M(new $(e,t,l,s))}return s[r]=c.right,Cb}))}}for(let n=0;n<a.length;n++){let i=a[n],o=i[0],s=i[1],c=jb(t,i[2]);for(let n of c){let i=o(n,u);if(QS(i)&&zt(i)){let i=s(t[n],u);if(QS(i)){if(N(i)){let r=new BS(n,t,i.left);if(d){f.push([p++,r]);continue}return M(new $(e,t,r,g))}Object.prototype.hasOwnProperty.call(r,n)||(g[n]=i.right)}else{let a=p++,o=n;v||=[],v.push(({es:s,output:c})=>Ob(Db(i),i=>{if(N(i)){let n=new BS(o,t,i.left);return d?(s.push([a,n]),Cb):M(new $(e,t,n,c))}return Object.prototype.hasOwnProperty.call(r,n)||(c[n]=i.right),Cb}))}}}}let te=({es:n,output:r})=>{if(yn(n))return M(new $(e,t,bC(n),r));if(u?.propertyOrder===`original`){let e=_||Reflect.ownKeys(t);for(let t of i)e.indexOf(t)===-1&&e.push(t);let n={};for(let t of e)Object.prototype.hasOwnProperty.call(r,t)&&(n[t]=r[t]);return j(n)}return j(r)};if(v&&v.length>0){let e=v;return Sb(()=>{let t={es:zn(f),output:Object.assign({},g)};return Ob(xb(e,e=>e(t),{concurrency:c,batching:l,discard:!0}),()=>te(t))})}return te({es:f,output:g})}}case`Union`:{let n=gC(e.types,t),r=Reflect.ownKeys(n.keys),i=r.length,a=e.types.length,o= new Map;for(let n=0;n<a;n++)o.set(e.types[n],uC(e.types[n],t));let s=dC(e)??1,c=fC(e);return(t,l)=>{let u=[],d=0,f=[];if(i>0){if(ie(t))for(let e=0;e<i;e++){let i=r[e],o=n.keys[i].buckets;if(Object.prototype.hasOwnProperty.call(t,i)){let e=String(t[i]);if(Object.prototype.hasOwnProperty.call(o,e))f=f.concat(o[e]);else{let{candidates:e,literals:r}=n.keys[i],o=uS.make(r),s=e.length===a?new rS([new X(i,o,!1,!0)],[]):uS.make(e);u.push([d++,new $(s,t,new BS(i,t,new GS(o,t[i])))])}}else{let{candidates:e,literals:r}=n.keys[i],o=new X(i,uS.make(r),!1,!0),s=e.length===a?new rS([o],[]):uS.make(e);u.push([d++,new $(s,t,new BS(i,t,new HS(o)))])}}else{let r=n.candidates.length===a?e:uS.make(n.candidates);u.push([d++,new GS(r,t)])}}n.otherwise.length>0&&(f=f.concat(n.otherwise));let p;for(let e=0;e<f.length;e++){let n=f[e],r=o.get(n)(t,l);if(QS(r)&&(!p||p.length===0)){if(zt(r))return r;u.push([d++,r.left])}else{let e=d++;p||=[],p.push(t=>Sb(()=>`finalResult`in t?Cb:Ob(Db(r),n=>(zt(n)?t.finalResult=n:t.es.push([e,n.left]),Cb))))}}let m=n=>yn(n)?n.length===1&&n[0][1]._tag===`Type`?M(n[0][1]):M(new $(e,t,bC(n))):M(new GS(e,t));if(p&&p.length>0){let e=p;return Sb(()=>{let t={es:zn(u)};return Ob(xb(e,e=>e(t),{concurrency:s,batching:c,discard:!0}),()=>`finalResult`in t?t.finalResult:m(t.es))})}return m(u)}}case`Suspend`:{let n=Mb(()=>uC(e.f(),t));return(e,t)=>n()(e,t)}}},mC=(e,t)=>n=>t(n)?j(n):M(new GS(e,n)),hC=(e,t)=>{switch(e._tag){case`Declaration`:{let n=jx(e);if(L(n))return hC(n.value,t);break}case`TypeLiteral`:{let n=[];for(let r=0;r<e.propertySignatures.length;r++){let i=e.propertySignatures[r],a=t?PS(i.type):Z(i.type);Bx(a)&&!i.isOptional&&n.push([i.name,a])}return n}case`TupleType`:{let n=[];for(let r=0;r<e.elements.length;r++){let i=e.elements[r],a=t?PS(i.type):Z(i.type);Bx(a)&&!i.isOptional&&n.push([r,a])}return n}case`Refinement`:return hC(e.from,t);case`Suspend`:return hC(e.f(),t);case`Transformation`:return hC(t?e.from:e.to,t)}return[]},gC=(e,t)=>{let n={},r=[],i=[];for(let a=0;a<e.length;a++){let o=e[a],s=hC(o,t);if(s.length>0){i.push(o);for(let e=0;e<s.length;e++){let[t,r]=s[e],i=String(r.literal);n[t]=n[t]||{buckets:{},literals:[],candidates:[]};let a=n[t].buckets;if(Object.prototype.hasOwnProperty.call(a,i)){if(e<s.length-1)continue;a[i].push(o),n[t].literals.push(r),n[t].candidates.push(o)}else{a[i]=[o],n[t].literals.push(r),n[t].candidates.push(o);break}}}else r.push(o)}return{keys:n,otherwise:r,candidates:i}},_C=e=>_S(e)?_C(e.from):e,vC=(e,t,n,r)=>{if(r?.isEffectAllowed===!0||QS(e))return e;let i=new pg,a=kb(e,{scheduler:i});i.flush();let o=a.unsafePoll();if(o){if(Tg(o))return j(o.value);let e=o.cause;return Lf(e)?M(e.error):M(new KS(t,n,Rf(e)))}return M(new KS(t,n,`cannot be be resolved synchronously, this is caused by using runSync on an effect that performs async work`))},yC=([e],[t])=>e>t?1:e<t?-1:0;function bC(e){return e.sort(yC).map(e=>e[1])}const xC=(e,t)=>{switch(e._tag){case`FinalTransformation`:return t?e.decode:e.encode;case`ComposeTransformation`:return j;case`TypeLiteralTransformation`:return n=>{let r=j(n);for(let n of e.propertySignatureTransformations){let[e,i]=t?[n.from,n.to]:[n.to,n.from],a=t?n.decode:n.encode;r=eC(r,t=>{let n=a(Object.prototype.hasOwnProperty.call(t,e)?F(t[e]):P());return delete t[e],L(n)&&(t[i]=n.value),t})}return r}}},SC=(e,t=[])=>({value:e,forest:t}),CC={formatIssue:e=>eC(WC(e),wC),formatIssueSync:e=>{let t=CC.formatIssue(e);return QS(t)?Gt(t):Ab(t)},formatError:e=>CC.formatIssue(e.issue),formatErrorSync:e=>CC.formatIssueSync(e.issue)},wC=e=>e.value+TC(`
`,e.forest),TC=(e,t)=>{let n=``,r=t.length,i;for(let a=0;a<r;a++){i=t[a];let o=a===r-1;n+=e+(o?`└`:`├`)+`─ `+i.value,n+=TC(e+(r>1&&!o?`│ `:` `),i.forest)}return n},EC=e=>{switch(e){case`Encoded`:return`Encoded side transformation failure`;case`Transformation`:return`Transformation process failure`;case`Type`:return`Type side transformation failure`}},DC=e=>{switch(e){case`From`:return`From side refinement failure`;case`Predicate`:return`Predicate refinement failure`}},OC=e=>`ast`in e?F(e.ast):P(),kC= j(void 0),AC=e=>OC(e).pipe(an(bx),Zt({onNone:()=>kC,onSome:t=>{let n=t(e);return h(n)?j({message:n,override:!1}):bb(n)?Tb(n,e=>({message:e,override:!1})):h(n.message)?j({message:n.message,override:n.override}):Tb(n.message,e=>({message:e,override:n.override}))}})),jC=e=>t=>t._tag===e,MC= jC(`Composite`),NC= jC(`Refinement`),PC= jC(`Transformation`),FC=e=>$S(AC(e),t=>t===void 0?kC:!t.override&&(MC(e)||NC(e)&&e.kind===`From`||PC(e)&&e.kind!==`Transformation`)?PC(e)||NC(e)?FC(e.issue):kC:j(t.message)),IC=e=>OC(e).pipe(an(Ox),on(t=>t(e)),tn);function LC(e){return Tx(e).pipe(Qt(()=>Sx(e)),Qt(()=>Cx(e)),Qt(()=>wx(e)),R(()=>`{ ${e.from} | filter }`))}function RC(e){return e.message===void 0?`Expected ${_S(e.ast)?LC(e.ast):String(e.ast)}, actual ${ze(e.actual)}`:e.message}const zC=e=>eC(FC(e),t=>t??IC(e)??RC(e)),BC=e=>IC(e)??String(e.ast),VC=e=>e.message??`is forbidden`,HC=e=>e.message??`is unexpected`,UC=e=>{let t=xx(e.ast);if(L(t)){let e=t.value();return h(e)?j(e):e}return j(e.message??`is missing`)},WC=e=>{switch(e._tag){case`Type`:return eC(zC(e),SC);case`Forbidden`:return j(SC(BC(e),[SC(VC(e))]));case`Unexpected`:return j(SC(HC(e)));case`Missing`:return eC(UC(e),SC);case`Transformation`:return $S(FC(e),t=>t===void 0?eC(WC(e.issue),t=>SC(BC(e),[SC(EC(e.kind),[t])])):j(SC(t)));case`Refinement`:return $S(FC(e),t=>t===void 0?eC(WC(e.issue),t=>SC(BC(e),[SC(DC(e.kind),[t])])):j(SC(t)));case`Pointer`:return eC(WC(e.issue),t=>SC(Ib(e.path),[t]));case`Composite`:return $S(FC(e),t=>{if(t!==void 0)return j(SC(t));let n=BC(e);return Nb(e.issues)?eC(xb(e.issues,WC),e=>SC(n,e)):eC(WC(e.issues),e=>SC(n,[e]))})}},GC= t(e=>ae(e[0]),(e,...t)=>{let n={};for(let r of t)r in e&&(n[r]=e[r]);return n}),KC= t(e=>ae(e[0]),(e,...t)=>{let n={...e};for(let e of t)delete n[e];return n}),qC= Symbol.for(`effect/Schema`);function JC(e){return class{[qC]=YC;static ast=e;static annotations(e){return JC(QC(this.ast,e))}static pipe(){return A(this,arguments)}static toString(){return String(e)}static Type;static Encoded;static Context;static[qC]=YC}}const YC={
_A:e=>e,
_I:e=>e,
_R:e=>e},XC={typeConstructor:Yb,schemaId:Zb,message:Qb,missingMessage:$b,identifier:ex,title:tx,description:rx,examples:ix,default:ax,documentation:ux,jsonSchema:ox,arbitrary:sx,pretty:cx,equivalence:lx,concurrency:dx,batching:fx,parseIssueTitle:px,parseOptions:mx,decodingFallback:hx},ZC=e=>{if(!e)return{};let t={...e};for(let n in XC)if(n in e){let r=XC[n];t[r]=e[n],delete t[n]}return t},QC=(e,t)=>SS(e,ZC(t)),$C=(e,t)=>{let n=oC(e,t);return(e,t)=>Bt(n(e,t),YS)},ew=e=>y(e,qC)&&ae(e[qC]);function tw(e){return fS(e)?uS.make(dS(e,e=>new zx(e))):new zx(e[0])}function nw(e,t=tw(e)){return class extends JC(t){static annotations(e){return nw(this.literals,QC(this.ast,e))}static literals=[...e]}}function rw(...e){return B(e)?nw(e):dw}const iw=(e,t,n)=>ow(e,new Lx(e.map(e=>e.ast),(...e)=>t.decode(...e.map(JC)),(...e)=>t.encode(...e.map(JC)),ZC(n))),aw=(e,t)=>{let n=()=>(t,n,r)=>e(t)?XS(t):ZS(new GS(r,t));return ow([],new Lx([],n,n,ZC(t)))};function ow(e,t){return class extends JC(t){static annotations(e){return ow(this.typeParameters,QC(this.ast,e))}static typeParameters=[...e]}}const sw=function(){if(Array.isArray(arguments[0])){let e=arguments[0],t=arguments[1],n=arguments[2];return iw(e,t,n)}let e=arguments[0],t=arguments[1];return aw(e,t)},cw= Symbol.for(`effect/SchemaId/InstanceOf`),lw=(e,t)=>sw(t=>t instanceof e,{title:e.name,description:`an instance of ${e.name}`,pretty:()=>String,schemaId:cw,[cw]:{constructor:e},...t});var uw=class extends ( JC(Vx)){},dw=class extends ( JC(Ux)){},fw=class extends ( JC(Kx)){},pw=class extends ( JC(Jx)){};const mw=e=>uS.make(e.map(e=>e.ast));function hw(e,t=mw(e)){return class extends JC(t){static annotations(e){return hw(this.members,QC(this.ast,e))}static members=[...e]}}function gw(...e){return fS(e)?hw(e):B(e)?e[0]:dw}const _w=e=>gw(e,uw),vw=(e,t)=>new $x(e.map(e=>ew(e)?new Zx(e.ast,!1):e.ast),t.map(e=>ew(e)?new Xx(e.ast):e.ast),!0);function yw(e,t,n=vw(e,t)){return class extends JC(n){static annotations(e){return yw(this.elements,this.rest,QC(this.ast,e))}static elements=[...e];static rest=[...t]}}function bw(e,t){return class extends yw([],[e],t){static annotations(e){return bw(this.value,QC(this.ast,e))}static value=e}}const xw=e=>bw(e),Sw= Symbol.for(`effect/PropertySignature`),Cw=e=>y(e,Sw),ww= kS([$b]),Tw=(e,t)=>{let n=Reflect.ownKeys(e),r=[];if(n.length>0){let i=[],a=[],o=[];for(let t=0;t<n.length;t++){let s=n[t],c=e[s];if(Cw(c)){let e=c.ast;switch(e._tag){case`PropertySignatureDeclaration`:{let t=e.type,n=e.isOptional,o=e.annotations;i.push(new X(s,t,n,!0,ww(e))),a.push(new X(s,Z(t),n,!0,o)),r.push(new X(s,t,n,!0,o));break}case`PropertySignatureTransformation`:{let t=e.from.fromKey??s;i.push(new X(t,e.from.type,e.from.isOptional,!0,e.from.annotations)),a.push(new X(s,e.to.type,e.to.isOptional,!0,e.to.annotations)),o.push(new bS(t,s,e.decode,e.encode));break}}}else i.push(new X(s,c.ast,!1,!0)),a.push(new X(s,Z(c.ast),!1,!0)),r.push(new X(s,c.ast,!1,!0))}if(B(o)){let e=[],n=[];for(let r of t){let{indexSignatures:t,propertySignatures:o}=DS(r.key.ast,r.value.ast);o.forEach(e=>{i.push(e),a.push(new X(e.name,Z(e.type),e.isOptional,e.isReadonly,e.annotations))}),t.forEach(t=>{e.push(t),n.push(new nS(t.parameter,Z(t.type),t.isReadonly))})}return new yS(new rS(i,e,{[nx]:`Struct (Encoded side)`}),new rS(a,n,{[nx]:`Struct (Type side)`}),new xS(o))}}let i=[];for(let e of t){let{indexSignatures:t,propertySignatures:n}=DS(e.key.ast,e.value.ast);n.forEach(e=>r.push(e)),t.forEach(e=>i.push(e))}return new rS(r,i)},Ew=(e,t)=>{let n=Reflect.ownKeys(e);for(let r of n){let n=e[r];if(t[r]===void 0&&Cw(n)){let e=n.ast,i=e._tag===`PropertySignatureDeclaration`?e.defaultValue:e.to.defaultValue;i!==void 0&&(t[r]=i())}}return t};function Dw(e,t,n=Tw(e,t)){return class extends JC(n){static annotations(e){return Dw(this.fields,this.records,QC(this.ast,e))}static fields={...e};static records=[...t];static make=(t,n)=>{let r=Ew(e,{...t});return Uw(n)?r:sC(this)(r)};static pick(...t){return Ow(GC(e,...t))}static omit(...t){return Ow(KC(e,...t))}}}function Ow(e,...t){return Dw(e,t)}const kw=e=>JC(OS(e.ast)),Aw= Symbol.for(`effect/SchemaId/Refine`);function jw(e,t,n){return class extends JC(n){static annotations(e){return jw(this.from,this.filter,QC(this.ast,e))}static[Aw]=e;static from=e;static filter=t;static make=(e,t)=>Uw(t)?e:sC(this)(e)}}const Mw=(e,t,n)=>{if(_(e))return e?P():F(new GS(t,n));if(h(e))return F(new GS(t,n,e));if(e!==void 0){if(`_tag`in e)return F(e);let r=new GS(t,n,e.message);return F(B(e.path)?new BS(e.path,n,r):r)}return P()},Nw=(e,t,n)=>{if(Pb(e))return Mw(e,t,n);if(B(e)){let r=qn(e,e=>Mw(e,t,n));if(B(r))return F(r.length===1?r[0]:new $(t,n,r))}return P()};function Pw(e,t){return n=>{function r(t,n,r){return Nw(e(t,n,r),r,t)}return jw(n,r,new gS(n.ast,r,ZC(t)))}}const Fw=Jb,Iw=(e,t)=>n=>n.pipe(Pw(t=>t.length<=e,{schemaId:Fw,title:`maxLength(${e})`,description:`a string at most ${e} character(s) long`,jsonSchema:{maxLength:e},...t})),Lw=qb,Rw=(e,t)=>n=>n.pipe(Pw(t=>t.length>=e,{schemaId:Lw,title:`minLength(${e})`,description:`a string at least ${e} character(s) long`,jsonSchema:{minLength:e},...t})),zw=Gb,Bw=(e,t)=>n=>n.pipe(Pw(t=>t>=e,{schemaId:zw,title:`greaterThanOrEqualTo(${e})`,description:e===0?`a non-negative number`:`a number greater than or equal to ${e}`,jsonSchema:{minimum:e},...t})),Vw=Kb,Hw=(e,t)=>n=>n.pipe(Pw(t=>t<=e,{schemaId:Vw,title:`lessThanOrEqualTo(${e})`,description:e===0?`a non-positive number`:`a number less than or equal to ${e}`,jsonSchema:{maximum:e},...t}));function Uw(e){return _(e)?e:e?.disableValidation??!1}const Ww=Ow({id:pw,created:lw(Date),title:fw.pipe(Rw(1),Iw(100)),type:rw(`jpg`,`png`),size:pw,url:fw.pipe(Pw(e=>URL.canParse(e)))}),Gw=Ow({id:pw,stars:pw.pipe(Bw(1),Hw(5)),title:fw.pipe(Rw(1),Iw(100)),text:fw.pipe(Rw(1),Iw(1e3)),images:kw(xw(Ww))});$C(Ow({id:pw,created:lw(Date),title:fw.pipe(Rw(1),Iw(100)),brand:fw.pipe(Rw(1),Iw(30)),description:fw.pipe(Rw(1),Iw(500)),price:pw.pipe(Bw(1),Hw(1e4)),discount:_w(pw.pipe(Bw(1),Hw(100))),quantity:pw.pipe(Bw(0),Hw(10)),tags:kw(xw(fw.pipe(Rw(1),Iw(30)))),images:kw(xw(Ww)),ratings:kw(xw(Gw))}))({});