1function Re(){}function W(e){return typeof e=="object"&&e!==null||typeof e=="function"}const qt=Re;function v(e,r){try{Object.defineProperty(e,"name",{value:r,configurable:!0})}catch{}}const Fr=Promise,Wo=Promise.resolve.bind(Fr),Oo=Promise.prototype.then,Ao=Promise.reject.bind(Fr),ze=Wo;function O(e){return new Fr(e)}function g(e){return O(r=>r(e))}function d(e){return Ao(e)}function Q(e,r,t){return Oo.call(e,r,t)}function I(e,r,t){Q(Q(e,r,t),void 0,qt)}function br(e,r){I(e,r)}function Rr(e,r){I(e,void 0,r)}function H(e,r,t){return Q(e,r,t)}function Ee(e){Q(e,void 0,qt)}let fe=e=>{if(typeof queueMicrotask=="function")fe=queueMicrotask;else{const r=g(void 0);fe=t=>Q(r,t)}return fe(e)};function he(e,r,t){if(typeof e!="function")throw new TypeError("Argument is not a function");return Function.prototype.apply.call(e,r,t)}function G(e,r,t){try{return g(he(e,r,t))}catch(o){return d(o)}}class ${constructor(){this._cursor=0,this._size=0,this._front={_elements:[],_next:void 0},this._back=this._front,this._cursor=0,this._size=0}get length(){return this._size}push(r){const t=this._back;let o=t;t._elements.length===16383&&(o={_elements:[],_next:void 0}),t._elements.push(r),o!==t&&(this._back=o,t._next=o),++this._size}shift(){const r=this._front;let t=r;const o=this._cursor;let a=o+1;const s=r._elements,n=s[o];return a===16384&&(t=r._next,a=0),--this._size,this._cursor=a,r!==t&&(this._front=t),s[o]=void 0,n}forEach(r){let t=this._cursor,o=this._front,a=o._elements;for(;!(t===a.length&&o._next===void 0||t===a.length&&(o=o._next,a=o._elements,t=0,a.length===0));)r(a[t]),++t}peek(){const r=this._front,t=this._cursor;return r._elements[t]}}const Ct=Symbol("[[AbortSteps]]"),Et=Symbol("[[ErrorSteps]]"),Ir=Symbol("[[CancelSteps]]"),Lr=Symbol("[[PullSteps]]"),$r=Symbol("[[CanPullSyncSteps]]"),Mr=Symbol("[[ReleaseSteps]]");function jt(e,r){e._ownerReadableStream=r,r._reader=e,r._state==="readable"?Pr(e):r._state==="closed"?(function(t){Pr(t),Wt(t)})(e):kt(e,r._storedError)}function Dr(e,r){return D(e._ownerReadableStream,r)}function V(e){const r=e._ownerReadableStream;r._state==="readable"?xr(e,new TypeError("Reader was released and can no longer be used to monitor the stream's closedness")):(function(t,o){kt(t,o)})(e,new TypeError("Reader was released and can no longer be used to monitor the stream's closedness")),r._readableStreamController[Mr](),r._reader=void 0,e._ownerReadableStream=void 0}function or(e){return new TypeError("Cannot "+e+" a stream using a released reader")}function Pr(e){e._closedPromise=O((r,t)=>{e._closedPromise_resolve=r,e._closedPromise_reject=t})}function kt(e,r){Pr(e),xr(e,r)}function xr(e,r){e._closedPromise_reject!==void 0&&(Ee(e._closedPromise),e._closedPromise_reject(r),e._closedPromise_resolve=void 0,e._closedPromise_reject=void 0)}function Wt(e){e._closedPromise_resolve!==void 0&&(e._closedPromise_resolve(void 0),e._closedPromise_resolve=void 0,e._closedPromise_reject=void 0)}const at=Number.isFinite||function(e){return typeof e=="number"&&isFinite(e)},zo=Math.trunc||function(e){return e<0?Math.ceil(e):Math.floor(e)};function Y(e,r){if(e!==void 0&&typeof(t=e)!="object"&&typeof t!="function")throw new TypeError(`${r} is not an object.`);var t}function M(e,r){if(typeof e!="function")throw new TypeError(`${r} is not a function.`)}function Ot(e,r){if(!(function(t){return typeof t=="object"&&t!==null||typeof t=="function"})(e))throw new TypeError(`${r} is not an object.`)}function U(e,r,t){if(e===void 0)throw new TypeError(`Parameter ${r} is required in '${t}'.`)}function qr(e,r,t){if(e===void 0)throw new TypeError(`${r} is required in '${t}'.`)}function Nr(e){return Number(e)}function st(e){return e===0?0:e}function Qr(e,r){const t=Number.MAX_SAFE_INTEGER;let o=Number(e);if(o=st(o),!at(o))throw new TypeError(`${r} is not a finite number`);if(o=(function(a){return st(zo(a))})(o),o<0||o>t)throw new TypeError(`${r} is outside the accepted range of 0 to ${t}, inclusive`);return at(o)&&o!==0?o:0}function Yr(e,r){if(!X(e))throw new TypeError(`${r} is not a ReadableStream.`)}function we(e){return new ae(e)}function At(e,r){e._reader._readRequests.push(r)}function Hr(e,r,t){const o=e._reader._readRequests.shift();t?o._closeSteps():o._chunkSteps(r)}function cr(e){return e._reader._readRequests.length}function zt(e){const r=e._reader;return r!==void 0&&!!ee(r)}class ae{constructor(r){if(U(r,1,"ReadableStreamDefaultReader"),Yr(r,"First parameter"),re(r))throw new TypeError("This stream has already been locked for exclusive reading by another reader");
1jt(this,r),this._readRequests=new $}get closed(){return ee(this)?this._closedPromise:d(xe("closed"))}cancel(r=void 0){return ee(this)?this._ownerReadableStream===void 0?d(or("cancel")):Dr(this,r):d(xe("cancel"))}read(){if(!ee(this))return d(xe("read"));if(this._ownerReadableStream===void 0)return d(or("read from"));const r=Bt(this)?new Fo:new Bo;return Pe(this,r),r._promise}releaseLock(){if(!ee(this))throw xe("releaseLock");this._ownerReadableStream!==void 0&&(function(r){V(r);const t=new TypeError("Reader was released");Ft(r,t)})(this)}}Object.defineProperties(ae.prototype,{cancel:{enumerable:!0},read:{enumerable:!0},releaseLock:{enumerable:!0},closed:{enumerable:!0}}),v(ae.prototype.cancel,"cancel"),v(ae.prototype.read,"read"),v(ae.prototype.releaseLock,"releaseLock"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(ae.prototype,Symbol.toStringTag,{value:"ReadableStreamDefaultReader",configurable:!0});class Bo{constructor(){this._promise=O((r,t)=>{this._resolvePromise=r,this._rejectPromise=t})}_chunkSteps(r){this._resolvePromise({value:r,done:!1})}_closeSteps(){this._resolvePromise({value:void 0,done:!0})}_errorSteps(r){this._rejectPromise(r)}}class Fo{constructor(){this._promise=void 0}_chunkSteps(r){this._promise=ze({value:r,done:!1})}_closeSteps(){this._promise=ze({value:void 0,done:!0})}_errorSteps(r){this._promise=d(r)}}function ee(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_readRequests")&&e instanceof ae}function Pe(e,r){const t=e._ownerReadableStream;t._disturbed=!0,t._state==="closed"?r._closeSteps():t._state==="errored"?r._errorSteps(t._storedError):t._readableStreamController[Lr](r)}function Bt(e){const r=e._ownerReadableStream;return r._state==="closed"||r._state==="errored"||r._readableStreamController[$r]()}function Ft(e,r){const t=e._readRequests;e._readRequests=new $,t.forEach(o=>{o._errorSteps(r)})}function xe(e){return new TypeError(`ReadableStreamDefaultReader.prototype.${e} can only be used on a ReadableStreamDefaultReader`)}var mr,pr,yr;function ke(e){return e.slice()}function It(e,r,t,o,a){new Uint8Array(e).set(new Uint8Array(t,o,a),r)}let _e=e=>(_e=typeof e.transfer=="function"?r=>r.transfer():typeof structuredClone=="function"?r=>structuredClone(r,{transfer:[r]}):r=>r,_e(e)),be=e=>(be=typeof e.detached=="boolean"?r=>r.detached:r=>r.byteLength===0,be(e));function Lt(e,r,t){if(e.slice)return e.slice(r,t);const o=t-r,a=new ArrayBuffer(o);return It(a,0,e,r,o),a}function We(e,r){const t=e[r];if(t!=null){if(typeof t!="function")throw new TypeError(`${String(r)} is not a function`);return t}}function lt(e){try{const r=e.done,t=e.value;return Q(ze(t),o=>({done:r,value:o}))}catch(r){return d(r)}}const Me=(yr=(mr=Symbol.asyncIterator)!==null&&mr!==void 0?mr:(pr=Symbol.for)===null||pr===void 0?void 0:pr.call(Symbol,"Symbol.asyncIterator"))!==null&&yr!==void 0?yr:"@@asyncIterator";function $t(e,r="sync",t){if(t===void 0)if(r==="async"){if((t=We(e,Me))===void 0)return(function(a){const s={next(){let n;try{n=Mt(a)}catch(i){return d(i)}return lt(n)},return(n){let i;try{const l=We(a.iterator,"return");if(l===void 0)return g({done:!0,value:n});i=he(l,a.iterator,[n])}catch(l){return d(l)}return W(i)?lt(i):d(new TypeError("The iterator.return() method must return an object"))}};return{iterator:s,nextMethod:s.next,done:!1}})($t(e,"sync",We(e,Symbol.iterator)))}else t=We(e,Symbol.iterator);if(t===void 0)throw new TypeError("The object is not iterable");const o=he(t,e,[]);if(!W(o))throw new TypeError("The iterator method must return an object");return{iterator:o,nextMethod:o.next,done:!1}}function Mt(e){const r=he(e.nextMethod,e.iterator,[]);if(!W(r))throw new TypeError("The iterator.next() method must return an object");return r}class Dt{constructor(r,t){this._ongoingPromise=void 0,this._isFinished=!1,this._reader=r,this._preventCancel=t}next(){const r=()=>this._nextSteps();return this._ongoingPromise=this._ongoingPromise?H(this._ongoingPromise,r,r):r(),this._ongoingPromise}return(r){const t=()=>this._returnSteps(r);return this._ongoingPromise=this._ongoingPromise?H(this._ongoingPromise,t,t):t(),this._ongoingPromise}_nextSteps(){if(this._isFinished)return Promise.resolve({value:void 0,done:!0});const r=this._reader,t=new Io(this);return Pe(r,t),t._promise}_returnSteps(r){if(this._isFinished)return Promise.resolve({value:r,done:!0});this._isFinished=!0;const t=this._reader;if(!this._preventCancel){const o=Dr(t,r);return V(t),H(o,()=>({value:r,done:!0}))}return V(t),g({value:r,done:!0})}}class Io{constructor(r){this._iterator=r,this._promise=O((t,o)=>{this._resolvePromise=t,this._rejectPromise=o})}_chunkSteps(r){this._iterator._ongoingPromise=void 0,fe(()=>this._resolvePromise({value:r,done:!1}))}_closeSteps(){const r=this._iterator;r._ongoingPromise=void 0,r._isFinished=!0,V(r._reader),this._resolvePromise({value:void 0,done:!0})}_errorSteps(r){const t=this._iterator;t._ongoingPromise=void 0,t._isFinished=!0,V(t._reader),this._rejectPromise(r)}}const xt={next(){return ut(this)?this._asyncIteratorImpl.next():d(ct("next"))},return(e){return ut(this)?this._asyncIteratorImpl.return(e):d(ct("return"))},[Me](){return this}};function ut(e){if(!W(e)||!Object.prototype.hasOwnProperty.call(e,"_asyncIteratorImpl"))return!1;try{return e._asyncIteratorImpl instanceof Dt}catch{return!1}}function ct(e){return new TypeError(`ReadableStreamAsyncIterator.${e} can only be used on a ReadableSteamAsyncIterator`)}Object.defineProperty(xt,Me,{enumerable:!1});const Nt=Number.isNaN||function(e){return e!=e};function dt(e){const r=Lt(e.buffer,e.byteOffset,e.byteOffset+e.byteLength);return new Uint8Array(r)}function Cr(e){const r=e._queue.shift();return e._queueTotalSize-=r.size,e._queueTotalSize<0&&(e._queueTotalSize=0),r.value}function Vr(e,r,t){if(typeof(o=t)!="number"||Nt(o)||o<0||t===1/0)throw new RangeError("Size must be a finite, non-NaN, non-negative number.");var o;e._queue.push({value:r,size:t}),e._queueTotalSize+=t}function te(e){e._queue=new $,e._queueTotalSize=0}function Qt(e){return e===DataView}function Yt(e){return Qt(e)?1:e.BYTES_PER_ELEMENT}class ve{constructor(){throw new TypeError("Illegal constructor")}get view(){if(!vr(this))throw gr("view");return this._view}respond(r){if(!vr(this))throw gr("respond");if(U(r,1,"respond"),r=Qr(r,"First parameter"),this._associatedReadableByteStreamController===void 0)throw new TypeError("This BYOB request has been invalidated");if(be(this._view.buffer))throw new TypeError("The BYOB request's buffer has been detached and so cannot be used as a response");Ze(this._associatedReadableByteStreamController,r)}respondWithNewView(r){if(!vr(this))throw gr("respondWithNewView");if(U(r,1,"respondWithNewView"),!ArrayBuffer.isView(r))throw new TypeError("You can only respond with array buffer views");if(this._associatedReadableByteStreamController===void 0)throw new TypeError("This BYOB request has been invalidated");if(be(r.buffer))throw new TypeError("The given view's buffer has been detached and so cannot be used as a response");er(this._associatedReadableByteStreamController,r)}}Object.defineProperties(ve.prototype,{respond:{enumerable:!0},respondWithNewView:{enumerable:!0},view:{enumerable:!0}}),v(ve.prototype.respond,"respond"),v(ve.prototype.respondWithNewView,"respondWithNewView"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(ve.prototype,Symbol.toStringTag,{value:"ReadableStreamBYOBRequest",configurable:!0});class K{constructor(){throw new TypeError("Illegal constructor")}get byobRequest(){if(!se(this))throw je("byobRequest");return jr(this)}get desiredSize(){if(!se(this))throw je("desiredSize");return to(this)}close(){if(!se(this))throw je("close");if(this._closeRequested)throw new TypeError("The stream has already been closed; do not close it again!");const r=this._controlledReadableByteStream._state;if(r!=="readable")throw new TypeError(`The stream (in ${r} state) is not in the readable state and cannot be closed`);Oe(this)}enqueue(r){if(!se(this))throw je("enqueue");if(U(r,1,"enqueue"),!ArrayBuffer.isView(r))throw new TypeError("chunk must be an array buffer view");if(r.byteLength===0)throw new TypeError("chunk must have non-zero byteLength");if(r.buffer.byteLength===0)throw new TypeError("chunk's buffer must have non-zero byteLength");if(this._closeRequested)throw new TypeError("stream is closed or draining");const t=this._controlledReadableByteStream._state;if(t!=="readable")throw new TypeError(`The stream (in ${t} state) is not in the readable state and cannot be enqueued to`);Ke(this,r)}error(r=void 0){if(!se(this))throw je("error");L(this,r)}[Ir](r){Ht(this),te(this);const t=this._cancelAlgorithm(r);return dr(this),t}[Lr](r){const t=this._controlledReadableByteStream;if(this._queueTotalSize>0)return void ro(this,r);const o=this._autoAllocateChunkSize;if(o!==void 0){let a;try{a=new ArrayBuffer(o)}catch(n){return void r._errorSteps(n)}const s={buffer:a,bufferByteLength:o,byteOffset:0,byteLength:o,bytesFilled:0,minimumFill:1,elementSize:1,viewConstructor:Uint8Array,readerType:"default"};this._pendingPullIntos.push(s)}At(t,r),pe(this)}[$r](){return this._queueTotalSize>0}
1[Mr](){if(this._pendingPullIntos.length>0){const r=this._pendingPullIntos.peek();r.readerType="none",this._pendingPullIntos=new $,this._pendingPullIntos.push(r)}}}function se(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_controlledReadableByteStream")&&e instanceof K}function vr(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_associatedReadableByteStreamController")&&e instanceof ve}function pe(e){if((function(t){const o=t._controlledReadableByteStream;return o._state!=="readable"||t._closeRequested||!t._started?!1:!!(zt(o)&&cr(o)>0||Gr(o)&&io(o)>0||to(t)>0)})(e)){if(e._pulling)return void(e._pullAgain=!0);e._pulling=!0,I(e._pullAlgorithm(),()=>(e._pulling=!1,e._pullAgain&&(e._pullAgain=!1,pe(e)),null),t=>(L(e,t),null))}}function Ht(e){Ur(e),e._pendingPullIntos=new $}function Vt(e,r){let t=!1;e._state==="closed"&&(t=!0);const o=Ut(r);r.readerType==="default"?Hr(e,o,t):(function(a,s,n){const i=a._reader,l=i._readIntoRequests.shift();n?l._closeSteps(s):l._chunkSteps(s)})(e,o,t)}function Xe(e,r){for(let t=0;t<r.length;++t)Vt(e,r[t])}function Ut(e){const r=e.bytesFilled,t=e.elementSize;return new e.viewConstructor(e.buffer,e.byteOffset,r/t)}function Je(e,r,t,o){e._queue.push({buffer:r,byteOffset:t,byteLength:o}),e._queueTotalSize+=o}function Gt(e,r,t,o){let a;try{a=Lt(r,t,t+o)}catch(s){throw L(e,s),s}Je(e,a,0,o)}function Xt(e,r){r.bytesFilled>0&&Gt(e,r.buffer,r.byteOffset,r.bytesFilled),Se(e)}function Jt(e,r){const t=Math.min(e._queueTotalSize,r.byteLength-r.bytesFilled),o=r.bytesFilled+t;let a=t,s=!1;const n=o-o%r.elementSize;n>=r.minimumFill&&(a=n-r.bytesFilled,s=!0);const i=e._queue;for(;a>0;){const l=i.peek(),c=Math.min(a,l.byteLength),f=r.byteOffset+r.bytesFilled;It(r.buffer,f,l.buffer,l.byteOffset,c),l.byteLength===c?i.shift():(l.byteOffset+=c,l.byteLength-=c),e._queueTotalSize-=c,Kt(e,c,r),a-=c}return s}function Kt(e,r,t){t.bytesFilled+=r}function Zt(e){e._queueTotalSize===0&&e._closeRequested?(dr(e),De(e._controlledReadableByteStream)):pe(e)}function Ur(e){e._byobRequest!==null&&(e._byobRequest._associatedReadableByteStreamController=void 0,e._byobRequest._view=null,e._byobRequest=null)}function Er(e){const r=[];for(;e._pendingPullIntos.length>0&&e._queueTotalSize!==0;){const t=e._pendingPullIntos.peek();Jt(e,t)&&(Se(e),r.push(t))}return r}function eo(e,r){const t=e._pendingPullIntos.peek();Ur(e),e._controlledReadableByteStream._state==="closed"?(function(o,a){a.readerType==="none"&&Se(o);const s=o._controlledReadableByteStream;if(Gr(s)){const n=[];for(;n.length<io(s);)n.push(Se(o));Xe(s,n)}})(e,t):(function(o,a,s){if(Kt(0,a,s),s.readerType==="none"){Xt(o,s);const l=Er(o);return void Xe(o._controlledReadableByteStream,l)}if(s.bytesFilled<s.minimumFill)return;Se(o);const n=s.bytesFilled%s.elementSize;if(n>0){const l=s.byteOffset+s.bytesFilled;Gt(o,s.buffer,l-n,n)}s.bytesFilled-=n;const i=Er(o);Vt(o._controlledReadableByteStream,s),Xe(o._controlledReadableByteStream,i)})(e,r,t),pe(e)}function Se(e){return e._pendingPullIntos.shift()}function dr(e){e._pullAlgorithm=void 0,e._cancelAlgorithm=void 0}function Oe(e){const r=e._controlledReadableByteStream;if(!e._closeRequested&&r._state==="readable")if(e._queueTotalSize>0)e._closeRequested=!0;else{if(e._pendingPullIntos.length>0){const t=e._pendingPullIntos.peek();if(t.bytesFilled%t.elementSize!==0){const o=new TypeError("Insufficient bytes to fill elements in the given buffer");throw L(e,o),o}}dr(e),De(r)}}function Ke(e,r){const t=e._controlledReadableByteStream;if(e._closeRequested||t._state!=="readable")return;const{buffer:o,byteOffset:a,byteLength:s}=r;if(be(o))throw new TypeError("chunk's buffer is detached and so cannot be enqueued");const n=_e(o);if(e._pendingPullIntos.length>0){const i=e._pendingPullIntos.peek();if(be(i.buffer))throw new TypeError("The BYOB request's buffer has been detached and so cannot be filled with an enqueued chunk");Ur(e),i.buffer=_e(i.buffer),i.readerType==="none"&&Xt(e,i)}zt(t)?((function(i){const l=i._controlledReadableByteStream._reader;for(;l._readRequests.length>0;){if(i._queueTotalSize===0)return;ro(i,l._readRequests.shift())}})(e),cr(t)===0?Je(e,n,a,s):(e._pendingPullIntos.length>0&&Se(e),Hr(t,new Uint8Array(n,a,s),!1))):Gr(t)?(Je(e,n,a,s),Xe(t,Er(e))):Je(e,n,a,s),pe(e)}function L(e,r){const t=e._controlledReadableByteStream;t._state==="readable"&&(Ht(e),te(e),dr(e),Po(t,r))}function ro(e,r){const t=e._queue.shift();e._queueTotalSize-=t.byteLength,Zt(e);const o=new Uint8Array(t.buffer,t.byteOffset,t.byteLength);r._chunkSteps(o)}function jr(e){if(e._byobRequest===null&&e._pendingPullIntos.length>0){const r=e._pendingPullIntos.peek(),t=new Uint8Array(r.buffer,r.byteOffset+r.bytesFilled,r.byteLength-r.bytesFilled),o=Object.create(ve.prototype);(function(a,s,n){a._associatedReadableByteStreamController=s,a._view=n})(o,e,t),e._byobRequest=o}return e._byobRequest}function to(e){const r=e._controlledReadableByteStream._state;return r==="errored"?null:r==="closed"?0:e._strategyHWM-e._queueTotalSize}function Ze(e,r){const t=e._pendingPullIntos.peek();if(e._controlledReadableByteStream._state==="closed"){if(r!==0)throw new TypeError("bytesWritten must be 0 when calling respond() on a closed stream")}else{if(r===0)throw new TypeError("bytesWritten must be greater than 0 when calling respond() on a readable stream");if(t.bytesFilled+r>t.byteLength)throw new RangeError("bytesWritten out of range")}t.buffer=_e(t.buffer),eo(e,r)}function er(e,r){const t=e._pendingPullIntos.peek();if(e._controlledReadableByteStream._state==="closed"){if(r.byteLength!==0)throw new TypeError("The view's length must be 0 when calling respondWithNewView() on a closed stream")}else if(r.byteLength===0)throw new TypeError("The view's length must be greater than 0 when calling respondWithNewView() on a readable stream");if(t.byteOffset+t.bytesFilled!==r.byteOffset)throw new RangeError("The region specified by view does not match byobRequest");
1if(t.bufferByteLength!==r.buffer.byteLength)throw new RangeError("The buffer of view has different capacity than byobRequest");if(t.bytesFilled+r.byteLength>t.byteLength)throw new RangeError("The region specified by view is larger than byobRequest");const o=r.byteLength;t.buffer=_e(r.buffer),eo(e,o)}function oo(e,r,t,o,a,s,n){r._controlledReadableByteStream=e,r._pullAgain=!1,r._pulling=!1,r._byobRequest=null,r._queue=r._queueTotalSize=void 0,te(r),r._closeRequested=!1,r._started=!1,r._strategyHWM=s,r._pullAlgorithm=o,r._cancelAlgorithm=a,r._autoAllocateChunkSize=n,r._pendingPullIntos=new $,e._readableStreamController=r,I(g(t()),()=>(r._started=!0,pe(r),null),i=>(L(r,i),null))}function gr(e){return new TypeError(`ReadableStreamBYOBRequest.prototype.${e} can only be used on a ReadableStreamBYOBRequest`)}function je(e){return new TypeError(`ReadableByteStreamController.prototype.${e} can only be used on a ReadableByteStreamController`)}function Lo(e,r){if((e=`${e}`)!="byob")throw new TypeError(`${r} '${e}' is not a valid enumeration value for ReadableStreamReaderMode`);return e}function no(e){return new le(e)}function ft(e,r){e._reader._readIntoRequests.push(r)}function io(e){return e._reader._readIntoRequests.length}function Gr(e){const r=e._reader;return r!==void 0&&!!de(r)}Object.defineProperties(K.prototype,{close:{enumerable:!0},enqueue:{enumerable:!0},error:{enumerable:!0},byobRequest:{enumerable:!0},desiredSize:{enumerable:!0}}),v(K.prototype.close,"close"),v(K.prototype.enqueue,"enqueue"),v(K.prototype.error,"error"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(K.prototype,Symbol.toStringTag,{value:"ReadableByteStreamController",configurable:!0});class le{constructor(r){if(U(r,1,"ReadableStreamBYOBReader"),Yr(r,"First parameter"),re(r))throw new TypeError("This stream has already been locked for exclusive reading by another reader");if(!se(r._readableStreamController))throw new TypeError("Cannot construct a ReadableStreamBYOBReader for a stream not constructed with a byte source");jt(this,r),this._readIntoRequests=new $}get closed(){return de(this)?this._closedPromise:d(Ne("closed"))}cancel(r=void 0){return de(this)?this._ownerReadableStream===void 0?d(or("cancel")):Dr(this,r):d(Ne("cancel"))}read(r,t={}){if(!de(this))return d(Ne("read"));if(!ArrayBuffer.isView(r))return d(new TypeError("view must be an array buffer view"));if(r.byteLength===0)return d(new TypeError("view must have non-zero byteLength"));if(r.buffer.byteLength===0)return d(new TypeError("view's buffer must have non-zero byteLength"));if(be(r.buffer))return d(new TypeError("view's buffer has been detached"));let o;try{o=(function(n,i){var l;return Y(n,i),{min:Qr((l=n==null?void 0:n.min)!==null&&l!==void 0?l:1,`${i} has member 'min' that`)}})(t,"options")}catch(n){return d(n)}const a=o.min;if(a===0)return d(new TypeError("options.min must be greater than 0"));if((function(n){return Qt(n.constructor)})(r)){if(a>r.byteLength)return d(new RangeError("options.min must be less than or equal to view's byteLength"))}else if(a>r.length)return d(new RangeError("options.min must be less than or equal to view's length"));if(this._ownerReadableStream===void 0)return d(or("read from"));const s=(function(n,i,l){const c=n._ownerReadableStream;return c._state==="errored"||(function(f,b,u){const h=f._controlledReadableByteStream,T=Yt(b.constructor),{byteLength:C}=b,j=u*T;return!(f._pendingPullIntos.length>0)&&(h._state==="closed"||f._queueTotalSize>=j)})(c._readableStreamController,i,l)})(this,r,a)?new Mo:new $o;return ao(this,r,a,s),s._promise}releaseLock(){if(!de(this))throw Ne("releaseLock");this._ownerReadableStream!==void 0&&(function(r){V(r);const t=new TypeError("Reader was released");so(r,t)})(this)}}Object.defineProperties(le.prototype,{cancel:{enumerable:!0},read:{enumerable:!0},releaseLock:{enumerable:!0},closed:{enumerable:!0}}),v(le.prototype.cancel,"cancel"),v(le.prototype.read,"read"),v(le.prototype.releaseLock,"releaseLock"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(le.prototype,Symbol.toStringTag,{value:"ReadableStreamBYOBReader",configurable:!0});class $o{constructor(){this._promise=O((r,t)=>{this._resolvePromise=r,this._rejectPromise=t})}_chunkSteps(r){this._resolvePromise({value:r,done:!1})}_closeSteps(r){this._resolvePromise({value:r,done:!0})}_errorSteps(r){this._rejectPromise(r)}}class Mo{constructor(){this._promise=void 0}_chunkSteps(r){this._promise=ze({value:r,done:!1})}_closeSteps(r){this._promise=ze({value:r,done:!0})}_errorSteps(r){this._promise=d(r)}}function de(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_readIntoRequests")&&e instanceof le}function ao(e,r,t,o){const a=e._ownerReadableStream;a._disturbed=!0,a._state==="errored"?o._errorSteps(a._storedError):(function(s,n,i,l){const c=s._controlledReadableByteStream,f=n.constructor,b=Yt(f),{byteOffset:u,byteLength:h}=n,T=i*b;let C;try{C=_e(n.buffer)}catch(R){return void l._errorSteps(R)}const j={buffer:C,bufferByteLength:C.byteLength,byteOffset:u,byteLength:h,bytesFilled:0,minimumFill:T,elementSize:b,viewConstructor:f,readerType:"byob"};if(s._pendingPullIntos.length>0)return s._pendingPullIntos.push(j),void ft(c,l);if(c._state==="closed"){const R=new f(j.buffer,j.byteOffset,0);return void l._closeSteps(R)}if(s._queueTotalSize>0){if(Jt(s,j)){const R=Ut(j);return Zt(s),void l._chunkSteps(R)}if(s._closeRequested){const R=new TypeError("Insufficient bytes to fill elements in the given buffer");return L(s,R),void l._errorSteps(R)}}s._pendingPullIntos.push(j),ft(c,l),pe(s)})(a._readableStreamController,r,t,o)}function so(e,r){const t=e._readIntoRequests;e._readIntoRequests=new $,t.forEach(o=>{o._errorSteps(r)})}function Ne(e){return new TypeError(`ReadableStreamBYOBReader.prototype.${e} can only be used on a ReadableStreamBYOBReader`)}function Be(e,r){const{highWaterMark:t}=e;if(t===void 0)return r;if(Nt(t)||t<0)throw new RangeError("Invalid highWaterMark");return t}function nr(e){const{size:r}=e;return r||(()=>1)}function ir(e,r){Y(e,r);const t=e==null?void 0:e.highWaterMark,o=e==null?void 0:e.size;return{highWaterMark:t===void 0?void 0:Nr(t),size:o===void 0?void 0:Do(o,`${r} has member 'size' that`)}}function Do(e,r){return M(e,r),t=>Nr(e(t))}function xo(e,r,t){return M(e,t),o=>G(e,r,[o])}function No(e,r,t){return M(e,t),()=>G(e,r,[])}function Qo(e,r,t){return M(e,t),o=>he(e,r,[o])}function Yo(e,r,t){return M(e,t),(o,a)=>G(e,r,[o,a])}function lo(e,r){if(!ge(e))throw new TypeError(`${r} is not a WritableStream.`)}class ue{constructor(r={},t={}){r===void 0?r=null:Ot(r,"First parameter");const o=ir(t,"Second parameter"),a=(function(n,i){Y(n,i);const l=n==null?void 0:n.abort,c=n==null?void 0:n.close,f=n==null?void 0:n.start,b=n==null?void 0:n.type,u=n==null?void 0:n.write;return{abort:l===void 0?void 0:xo(l,n,`${i} has member 'abort' that`),close:c===void 0?void 0:No(c,n,`${i} has member 'close' that`),start:f===void 0?void 0:Qo(f,n,`${i} has member 'start' that`),write:u===void 0?void 0:Yo(u,n,`${i} has member 'write' that`),type:b}})(r,"First parameter");if(co(this),a.type!==void 0)throw new RangeError("Invalid type is specified");const s=nr(o);(function(n,i,l,c){const f=Object.create(Fe.prototype);let b,u,h,T;b=i.start!==void 0?()=>i.start(f):()=>{},u=i.write!==void 0?C=>i.write(C,f):()=>g(void 0),h=i.close!==void 0?()=>i.close():()=>g(void 0),T=i.abort!==void 0?C=>i.abort(C):()=>g(void 0),po(n,f,b,u,h,T,l,c)})(this,a,Be(o,1),s)}get locked(){if(!ge(this))throw Ye("locked");return Te(this)}abort(r=void 0){return ge(this)?Te(this)?d(new TypeError("Cannot abort a stream that already has a writer")):ar(this,r):d(Ye("abort"))}close(){return ge(this)?Te(this)?d(new TypeError("Cannot close a stream that already has a writer")):x(this)?d(new TypeError("Cannot close an already-closing stream")):fo(this):d(Ye("close"))}getWriter(){if(!ge(this))throw Ye("getWriter");return uo(this)}}
1function uo(e){return new J(e)}function co(e){e._state="writable",e._storedError=void 0,e._writer=void 0,e._writableStreamController=void 0,e._writeRequests=new $,e._inFlightWriteRequest=void 0,e._closeRequest=void 0,e._inFlightCloseRequest=void 0,e._pendingAbortRequest=void 0,e._backpressure=!1}function ge(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_writableStreamController")&&e instanceof ue}function Te(e){return e._writer!==void 0}function ar(e,r){var t;if(e._state==="closed"||e._state==="errored")return g(void 0);e._writableStreamController._abortReason=r,(t=e._writableStreamController._abortController)===null||t===void 0||t.abort(r);const o=e._state;if(o==="closed"||o==="errored")return g(void 0);if(e._pendingAbortRequest!==void 0)return e._pendingAbortRequest._promise;let a=!1;o==="erroring"&&(a=!0,r=void 0);const s=O((n,i)=>{e._pendingAbortRequest={_promise:void 0,_resolve:n,_reject:i,_reason:r,_wasAlreadyErroring:a}});return e._pendingAbortRequest._promise=s,a||Xr(e,r),s}function fo(e){const r=e._state;if(r==="closed"||r==="errored")return d(new TypeError(`The stream (in ${r} state) is not in the writable state and cannot be closed`));const t=O((s,n)=>{const i={_resolve:s,_reject:n};e._closeRequest=i}),o=e._writer;var a;return o!==void 0&&e._backpressure&&r==="writable"&&tt(o),Vr(a=e._writableStreamController,mo,0),fr(a),t}function kr(e,r){e._state!=="writable"?Jr(e):Xr(e,r)}function Xr(e,r){const t=e._writableStreamController;e._state="erroring",e._storedError=r;const o=e._writer;o!==void 0&&_o(o,r),!(function(a){return!(a._inFlightWriteRequest===void 0&&a._inFlightCloseRequest===void 0)})(e)&&t._started&&Jr(e)}function Jr(e){e._state="errored",e._writableStreamController[Et]();const r=e._storedError;if(e._writeRequests.forEach(o=>{o._reject(r)}),e._writeRequests=new $,e._pendingAbortRequest===void 0)return void Qe(e);const t=e._pendingAbortRequest;if(e._pendingAbortRequest=void 0,t._wasAlreadyErroring)return t._reject(r),void Qe(e);I(e._writableStreamController[Ct](t._reason),()=>(t._resolve(),Qe(e),null),o=>(t._reject(o),Qe(e),null))}function x(e){return e._closeRequest!==void 0||e._inFlightCloseRequest!==void 0}function Qe(e){e._closeRequest!==void 0&&(e._closeRequest._reject(e._storedError),e._closeRequest=void 0);const r=e._writer;r!==void 0&&rt(r,e._storedError)}function Kr(e,r){const t=e._writer;t!==void 0&&r!==e._backpressure&&(r?(function(o){hr(o)})(t):tt(t)),e._backpressure=r}Object.defineProperties(ue.prototype,{abort:{enumerable:!0},close:{enumerable:!0},getWriter:{enumerable:!0},locked:{enumerable:!0}}),v(ue.prototype.abort,"abort"),v(ue.prototype.close,"close"),v(ue.prototype.getWriter,"getWriter"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(ue.prototype,Symbol.toStringTag,{value:"WritableStream",configurable:!0});class J{constructor(r){if(U(r,1,"WritableStreamDefaultWriter"),lo(r,"First parameter"),Te(r))throw new TypeError("This stream has already been locked for exclusive writing by another writer");this._ownerWritableStream=r,r._writer=this;const t=r._state;if(t==="writable")!x(r)&&r._backpressure?hr(this):ht(this),rr(this);else if(t==="erroring")Wr(this,r._storedError),rr(this);else if(t==="closed")ht(this),rr(o=this),wo(o);else{const a=r._storedError;Wr(this,a),go(this,a)}var o}get closed(){return oe(this)?this._closedPromise:d(ne("closed"))}get desiredSize(){if(!oe(this))throw ne("desiredSize");if(this._ownerWritableStream===void 0)throw Ae("desiredSize");return(function(r){const t=r._ownerWritableStream,o=t._state;return o==="errored"||o==="erroring"?null:o==="closed"?0:yo(t._writableStreamController)})(this)}get ready(){return oe(this)?this._readyPromise:d(ne("ready"))}abort(r=void 0){return oe(this)?this._ownerWritableStream===void 0?d(Ae("abort")):(function(t,o){return ar(t._ownerWritableStream,o)})(this,r):d(ne("abort"))}close(){if(!oe(this))return d(ne("close"));const r=this._ownerWritableStream;return r===void 0?d(Ae("close")):x(r)?d(new TypeError("Cannot close an already-closing stream")):ho(this)}releaseLock(){if(!oe(this))throw ne("releaseLock");this._ownerWritableStream!==void 0&&bo(this)}write(r=void 0){return oe(this)?this._ownerWritableStream===void 0?d(Ae("write to")):Zr(this,r):d(ne("write"))}}function oe(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_ownerWritableStream")&&e instanceof J}function ho(e){return fo(e._ownerWritableStream)}function Ho(e,r){e._closedPromiseState==="pending"?rt(e,r):(function(t,o){go(t,o)})(e,r)}function _o(e,r){e._readyPromiseState==="pending"?So(e,r):(function(t,o){Wr(t,o)})(e,r)}function bo(e){const r=e._ownerWritableStream,t=new TypeError("Writer was released and can no longer be used to monitor the stream's closedness");_o(e,t),Ho(e,t),r._writer=void 0,e._ownerWritableStream=void 0}function Zr(e,r){const t=e._ownerWritableStream,o=t._writableStreamController,a=(function(i,l){if(i._strategySizeAlgorithm===void 0)return 1;try{return i._strategySizeAlgorithm(l)}catch(c){return Ie(i,c),1}})(o,r);if(t!==e._ownerWritableStream)return d(Ae("write to"));const s=t._state;if(s==="errored")return d(t._storedError);if(x(t)||s==="closed")return d(new TypeError("The stream is closing or closed and cannot be written to"));if(s==="erroring")return d(t._storedError);const n=(function(i){return O((l,c)=>{const f={_resolve:l,_reject:c};i._writeRequests.push(f)})})(t);return(function(i,l,c){try{Vr(i,l,c)}catch(b){return void Ie(i,b)}const f=i._controlledWritableStream;!x(f)&&f._state==="writable"&&Kr(f,et(i)),fr(i)})(o,r,a),n}Object.defineProperties(J.prototype,{abort:{enumerable:!0},close:{enumerable:!0},releaseLock:{enumerable:!0},write:{enumerable:!0},closed:{enumerable:!0},desiredSize:{enumerable:!0},ready:{enumerable:!0}}),v(J.prototype.abort,"abort"),v(J.prototype.close,"close"),v(J.prototype.releaseLock,"releaseLock"),v(J.prototype.write,"write"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(J.prototype,Symbol.toStringTag,{value:"WritableStreamDefaultWriter",configurable:!0});const mo={};class Fe{constructor(){throw new TypeError("Illegal constructor")}get abortReason(){if(!wr(this))throw Sr("abortReason");return this._abortReason}get signal(){if(!wr(this))throw Sr("signal");if(this._abortController===void 0)throw new TypeError("WritableStreamDefaultController.prototype.signal is not supported");return this._abortController.signal}error(r=void 0){if(!wr(this))throw Sr("error");this._controlledWritableStream._state==="writable"&&vo(this,r)}[Ct](r){const t=this._abortAlgorithm(r);return sr(this),t}[Et](){te(this)}}function wr(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_controlledWritableStream")&&e instanceof Fe}function po(e,r,t,o,a,s,n,i){r._controlledWritableStream=e,e._writableStreamController=r,r._queue=void 0,r._queueTotalSize=void 0,te(r),r._abortReason=void 0,r._abortController=(function(){if(typeof AbortController=="function")return new AbortController})(),r._started=!1,r._strategySizeAlgorithm=i,r._strategyHWM=n,r._writeAlgorithm=o,r._closeAlgorithm=a,r._abortAlgorithm=s;const l=et(r);Kr(e,l),I(g(t()),()=>
1(r._started=!0,fr(r),null),c=>(r._started=!0,kr(e,c),null))}function sr(e){e._writeAlgorithm=void 0,e._closeAlgorithm=void 0,e._abortAlgorithm=void 0,e._strategySizeAlgorithm=void 0}function yo(e){return e._strategyHWM-e._queueTotalSize}function fr(e){const r=e._controlledWritableStream;if(!e._started||r._inFlightWriteRequest!==void 0)return;if(r._state==="erroring")return void Jr(r);if(e._queue.length===0)return;const t=e._queue.peek().value;t===mo?(function(o){const a=o._controlledWritableStream;(function(n){n._inFlightCloseRequest=n._closeRequest,n._closeRequest=void 0})(a),Cr(o);const s=o._closeAlgorithm();sr(o),I(s,()=>((function(n){n._inFlightCloseRequest._resolve(void 0),n._inFlightCloseRequest=void 0,n._state==="erroring"&&(n._storedError=void 0,n._pendingAbortRequest!==void 0&&(n._pendingAbortRequest._resolve(),n._pendingAbortRequest=void 0)),n._state="closed";const i=n._writer;i!==void 0&&wo(i)})(a),null),n=>((function(i,l){i._inFlightCloseRequest._reject(l),i._inFlightCloseRequest=void 0,i._pendingAbortRequest!==void 0&&(i._pendingAbortRequest._reject(l),i._pendingAbortRequest=void 0),kr(i,l)})(a,n),null))})(e):(function(o,a){const s=o._controlledWritableStream;(function(i){i._inFlightWriteRequest=i._writeRequests.shift()})(s);const n=o._writeAlgorithm(a);I(n,()=>{(function(l){l._inFlightWriteRequest._resolve(void 0),l._inFlightWriteRequest=void 0})(s);const i=s._state;if(Cr(o),!x(s)&&i==="writable"){const l=et(o);Kr(s,l)}return fr(o),null},i=>(s._state==="writable"&&sr(o),(function(l,c){l._inFlightWriteRequest._reject(c),l._inFlightWriteRequest=void 0,kr(l,c)})(s,i),null))})(e,t)}function Ie(e,r){e._controlledWritableStream._state==="writable"&&vo(e,r)}function et(e){return yo(e)<=0}function vo(e,r){const t=e._controlledWritableStream;sr(e),Xr(t,r)}function Ye(e){return new TypeError(`WritableStream.prototype.${e} can only be used on a WritableStream`)}function Sr(e){return new TypeError(`WritableStreamDefaultController.prototype.${e} can only be used on a WritableStreamDefaultController`)}function ne(e){return new TypeError(`WritableStreamDefaultWriter.prototype.${e} can only be used on a WritableStreamDefaultWriter`)}function Ae(e){return new TypeError("Cannot "+e+" a stream using a released writer")}function rr(e){e._closedPromise=O((r,t)=>{e._closedPromise_resolve=r,e._closedPromise_reject=t,e._closedPromiseState="pending"})}function go(e,r){rr(e),rt(e,r)}function rt(e,r){e._closedPromise_reject!==void 0&&(Ee(e._closedPromise),e._closedPromise_reject(r),e._closedPromise_resolve=void 0,e._closedPromise_reject=void 0,e._closedPromiseState="rejected")}function wo(e){e._closedPromise_resolve!==void 0&&(e._closedPromise_resolve(void 0),e._closedPromise_resolve=void 0,e._closedPromise_reject=void 0,e._closedPromiseState="resolved")}function hr(e){e._readyPromise=O((r,t)=>{e._readyPromise_resolve=r,e._readyPromise_reject=t}),e._readyPromiseState="pending"}function Wr(e,r){hr(e),So(e,r)}function ht(e){hr(e),tt(e)}function So(e,r){e._readyPromise_reject!==void 0&&(Ee(e._readyPromise),e._readyPromise_reject(r),e._readyPromise_resolve=void 0,e._readyPromise_reject=void 0,e._readyPromiseState="rejected")}function tt(e){e._readyPromise_resolve!==void 0&&(e._readyPromise_resolve(void 0),e._readyPromise_resolve=void 0,e._readyPromise_reject=void 0,e._readyPromiseState="fulfilled")}Object.defineProperties(Fe.prototype,{abortReason:{enumerable:!0},signal:{enumerable:!0},error:{enumerable:!0}}),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(Fe.prototype,Symbol.toStringTag,{value:"WritableStreamDefaultController",configurable:!0});const _t=typeof globalThis<"u"?globalThis:typeof self<"u"?self:typeof global<"u"?global:void 0,Vo=(function(){const e=_t==null?void 0:_t.DOMException;return(function(r){if(typeof r!="function"&&typeof r!="object"||r.name!=="DOMException")return!1;try{return new r,!0}catch{return!1}})(e)?e:void 0})()||(function(){const e=function(r,t){this.message=r||"",this.name=t||"Error",Error.captureStackTrace&&Error.captureStackTrace(this,this.constructor)};return v(e,"DOMException"),e.prototype=Object.create(Error.prototype),Object.defineProperty(e.prototype,"constructor",{value:e,writable:!0,configurable:!0}),e})();function bt(e,r,t,o,a,s){const n=we(e),i=uo(r);e._disturbed=!0;const l=new Uo(i),c=new Xo(l);return O((f,b)=>{let u;if(s!==void 0){if(u=()=>{const _=s.reason!==void 0?s.reason:new Vo("Aborted","AbortError"),k=[];o||k.push(()=>r._state==="writable"?ar(r,_):g(void 0)),a||k.push(()=>e._state==="readable"?D(e,_):g(void 0)),R(()=>Promise.all(k.map(z=>z())),!0,_)},s.aborted)return void u();s.addEventListener("abort",u)}function h(){for(;!l._shuttingDown&&!r._backpressure&&r._state==="writable"&&!x(r)&&e._state==="readable"&&Bt(n);)Pe(n,c);if(l._shuttingDown)return g(!0);if(r._backpressure)return Q(i._readyPromise,h);const _=new Go(l);return Pe(n,_),_._promise}var T,C,j;if(mt(e,n._closedPromise,_=>(o?y(!0,_):R(()=>ar(r,_),!0,_),null)),mt(r,i._closedPromise,_=>(a?y(!0,_):R(()=>D(e,_),!0,_),null)),T=e,C=n._closedPromise,j=()=>(t?y():R(()=>(function(_){const k=_._ownerWritableStream,z=k._state;return x(k)||z==="closed"?g(void 0):z==="errored"?d(k._storedError):ho(_)})(i)),null),T._state==="closed"?j():br(C,j),x(r)||r._state==="closed"){const _=new TypeError("the destination writable stream closed before all data could be piped to it");a?y(!0,_):R(()=>D(e,_),!0,_)}function R(_,k,z){function P(){return I(_(),()=>S(k,z),w=>S(!0,w)),null}l._shuttingDown||(l._shuttingDown=!0,r._state!=="writable"||x(r)?P():br(l._waitForWritesToFinish(),P))}function y(_,k){l._shuttingDown||(l._shuttingDown=!0,r._state!=="writable"||x(r)?S(_,k):br(l._waitForWritesToFinish(),()=>S(_,k)))}function S(_,k){return bo(i),V(n),s!==void 0&&s.removeEventListener("abort",u),_?b(k):f(void 0),null}Ee(O((_,k)=>{(function z(P){P?_():Q(h(),z,k)})(!1)}))})}class Uo{constructor(r){this._writer=r,this._shuttingDown=!1,this._currentWrite=g(void 0)}_waitForWritesToFinish(){const r=this._currentWrite;return Q(this._currentWrite,()=>r!==this._currentWrite?this._waitForWritesToFinish():void 0)}}class Go{constructor(r){this._state=r,this._promise=O((t,o)=>{this._resolvePromise=t,this._rejectPromise=o})}_chunkSteps(r){this._state._currentWrite=Q(Zr(this._state._writer,r),void 0,Re),this._resolvePromise(!1)}_closeSteps(){this._resolvePromise(!0)}_errorSteps(r){this._rejectPromise(r)}}class Xo{constructor(r){this._state=r}_chunkSteps(r){this._state._currentWrite=Q(Zr(this._state._writer,r),void 0,Re)}_closeSteps(){}_errorSteps(r){}}function mt(e,r,t){e._state==="errored"?t(e._storedError):Rr(r,t)}class Z{constructor(){throw new TypeError("Illegal constructor")}get desiredSize(){if(!He(this))throw Ve("desiredSize");return ot(this)}close(){if(!He(this))throw Ve("close");if(!Ce(this))throw new TypeError("The stream is not in a state that permits close");me(this)}enqueue(r=void 0){if(!He(this))throw Ve("enqueue");if(!Ce(this))throw new TypeError("The stream is not in a state that permits enqueue");return qe(this,r)}error(r=void 0){if(!He(this))throw Ve("error");N(this,r)}[Ir](r){te(this);const t=this._cancelAlgorithm(r);return lr(this),t}[Lr](r){const t=this._controlledReadableStream;if(this._queue.length>0){const o=Cr(this);this._closeRequested&&this._queue.length===0?(lr(this),De(t)):Le(this),r._chunkSteps(o)}else At(t,r),Le(this)}[$r](){return this._queue.length>0}[Mr](){}}function He(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_controlledReadableStream")&&e instanceof Z}function Le(e){if(To(e)){if(e._pulling)return void(e._pullAgain=!0);e._pulling=!0,I(e._pullAlgorithm(),()=>(e._pulling=!1,e._pullAgain&&(e._pullAgain=!1,Le(e)),null),r=>(N(e,r),null))}}function To(e){const r=e._controlledReadableStream;return!Ce(e)||!e._started?!1:re(r)&&cr(r)>0?!0:ot(e)>0}function lr(e){e._pullAlgorithm=void 0,e._cancelAlgorithm=void 0,e._strategySizeAlgorithm=void 0}function me(e){if(!Ce(e))return;const r=e._controlledReadableStream;e._closeRequested=!0,e._queue.length===0&&(lr(e),De(r))}function qe(e,r){if(!Ce(e))return;const t=e._controlledReadableStream;if(re(t)&&cr(t)>0)Hr(t,r,!1);else{let o;try{o=e._strategySizeAlgorithm(r)}catch(a){throw N(e,a),a}try{Vr(e,r,o)}catch(a){throw N(e,a),a}}Le(e)}function N(e,r){const t=e._controlledReadableStream;t._state==="readable"&&(te(e),lr(e),Po(t,r))}function ot(e){const r=e._controlledReadableStream._state;return r==="errored"?null:r==="closed"?0:e._strategyHWM-e._queueTotalSize}function Ce(e){const r=e._controlledReadableStream._state;return!e._closeRequested&&r==="readable"}function Ro(e,r,t,o,a,s,n){r._controlledReadableStream=e,r._queue=void 0,r._queueTotalSize=void 0,te(r),r._started=!1,r._closeRequested=!1,r._pullAgain=!1,r._pulling=!1,r._strategySizeAlgorithm=n,r._strategyHWM=s,r._pullAlgorithm=o,r._cancelAlgorithm=a,e._readableStreamController=r,I(g(t()),()=>(r._started=!0,Le(r),null),i=>(N(r,i),null))}function Ve(e){return new TypeError(`ReadableStreamDefaultController.prototype.${e} can only be used on a ReadableStreamDefaultController`)}function Jo(e,r){return se(e._readableStreamController)?(function(t){let o,a,s,n,i,l=we(t),c=!1,f=!1,b=!1,u=!1,h=!1;const T=O(P=>{i=P});function C(P){Rr(P._closedPromise,w=>(P!==l||(L(s._readableStreamController,w),L(n._readableStreamController,w),u&&h||i(void 0)),null))}function j(){de(l)&&(V(l),l=we(t),C(l)),Pe(l,{_chunkSteps:P=>{fe(()=>{f=!1,b=!1;const w=P;let m=P;if(!u&&!h)try{m=dt(P)}catch(E){return L(s._readableStreamController,E),L(n._readableStreamController,E),void i(D(t,E))}u||Ke(s._readableStreamController,w),h||Ke(n._readableStreamController,m),c=!1,f?y():b&&S()})},_closeSteps:()=>{c=!1,u||Oe(s._readableStreamController),h||Oe(n._readableStreamController),s._readableStreamController._pendingPullIntos.length>0&&Ze(s._readableStreamController,0),n._readableStreamController._pendingPullIntos.length>0&&Ze(n._readableStreamController,0),u&&h||i(void 0)},_errorSteps:()=>{c=!1}})}function R(P,w){ee(l)&&(V(l),l=no(t),C(l));const m=w?n:s,E=w?s:n;ao(l,P,1,{_chunkSteps:p=>{fe(()=>{f=!1,b=!1;const q=w?h:u;if(w?u:h)q||er(m._readableStreamController,p);else{let F;try{F=dt(p)}catch(A){return L(m._readableStreamController,A),L(E._readableStreamController,A),void i(D(t,A))}q||er(m._readableStreamController,p),Ke(E._readableStreamController,F)}c=!1,f?y():b&&S()})},_closeSteps:p=>{c=!1;const q=w?h:u,F=w?u:h;q||Oe(m._readableStreamController),F||Oe(E._readableStreamController),p!==void 0&&(q||er(m._readableStreamController,p),!F&&E._readableStreamController._pendingPullIntos.length>0&&Ze(E._readableStreamController,0)),q&&F||i(void 0)},_errorSteps:()=>{c=!1}})}function y(){if(c)return f=!0,g(void 0);c=!0;const P=jr(s._readableStreamController);return P===null?j():R(P._view,!1),g(void 0)}function S(){if(c)return b=!0,g(void 0);c=!0;const P=jr(n._readableStreamController);return P===null?j():R(P._view,!0),g(void 0)}function _(P){if(u=!0,o=P,h){const w=ke([o,a]),m=D(t,w);i(m)}return T}function k(P){if(h=!0,a=P,u){const w=ke([o,a]),m=D(t,w);i(m)}return T}function z(){}return s=yt(z,y,_),n=yt(z,S,k),C(l),[s,n]})(e):(function(t){const o=we(t);let a,s,n,i,l,c=!1,f=!1,b=!1,u=!1;
1const h=O(y=>{l=y});function T(){return c?(f=!0,g(void 0)):(c=!0,Pe(o,{_chunkSteps:y=>{fe(()=>{f=!1;const S=y,_=y;b||qe(n._readableStreamController,S),u||qe(i._readableStreamController,_),c=!1,f&&T()})},_closeSteps:()=>{c=!1,b||me(n._readableStreamController),u||me(i._readableStreamController),b&&u||l(void 0)},_errorSteps:()=>{c=!1}}),g(void 0))}function C(y){if(b=!0,a=y,u){const S=ke([a,s]),_=D(t,S);l(_)}return h}function j(y){if(u=!0,s=y,b){const S=ke([a,s]),_=D(t,S);l(_)}return h}function R(){}return n=$e(R,T,C),i=$e(R,T,j),Rr(o._closedPromise,y=>(N(n._readableStreamController,y),N(i._readableStreamController,y),b&&u||l(void 0),null)),[n,i]})(e)}function Ko(e){return W(r=e)&&r.getReader!==void 0?(function(t){let o;function a(){let n;try{n=t.read()}catch(i){return d(i)}return H(n,i=>{if(!W(i))throw new TypeError("The promise returned by the reader.read() method must fulfill with an object");if(i.done)me(o._readableStreamController);else{const l=i.value;qe(o._readableStreamController,l)}})}function s(n){try{return g(t.cancel(n))}catch(i){return d(i)}}return o=$e(Re,a,s,0),o})(e.getReader()):(function(t){let o;const a=$t(t,"async");function s(){let i;try{i=Mt(a)}catch(l){return d(l)}return H(g(i),l=>{if(!W(l))throw new TypeError("The promise returned by the iterator.next() method must fulfill with an object");if(l.done)me(o._readableStreamController);else{const c=l.value;qe(o._readableStreamController,c)}})}function n(i){const l=a.iterator;let c;try{c=We(l,"return")}catch(f){return d(f)}return c===void 0?g(void 0):H(G(c,l,[i]),f=>{if(!W(f))throw new TypeError("The promise returned by the iterator.return() method must fulfill with an object")})}return o=$e(Re,s,n,0),o})(e);var r}function Zo(e,r,t){return M(e,t),o=>G(e,r,[o])}function en(e,r,t){return M(e,t),o=>G(e,r,[o])}function rn(e,r,t){return M(e,t),o=>he(e,r,[o])}function tn(e,r){if((e=`${e}`)!="bytes")throw new TypeError(`${r} '${e}' is not a valid enumeration value for ReadableStreamType`);return e}function pt(e,r){Y(e,r);const t=e==null?void 0:e.preventAbort,o=e==null?void 0:e.preventCancel,a=e==null?void 0:e.preventClose,s=e==null?void 0:e.signal;return s!==void 0&&(function(n,i){if(!(function(l){if(typeof l!="object"||l===null)return!1;try{return typeof l.aborted=="boolean"}catch{return!1}})(n))throw new TypeError(`${i} is not an AbortSignal.`)})(s,`${r} has member 'signal' that`),{preventAbort:!!t,preventCancel:!!o,preventClose:!!a,signal:s}}Object.defineProperties(Z.prototype,{close:{enumerable:!0},enqueue:{enumerable:!0},error:{enumerable:!0},desiredSize:{enumerable:!0}}),v(Z.prototype.close,"close"),v(Z.prototype.enqueue,"enqueue"),v(Z.prototype.error,"error"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(Z.prototype,Symbol.toStringTag,{value:"ReadableStreamDefaultController",configurable:!0});class B{constructor(r={},t={}){r===void 0?r=null:Ot(r,"First parameter");const o=ir(t,"Second parameter"),a=(function(s,n){Y(s,n);const i=s,l=i==null?void 0:i.autoAllocateChunkSize,c=i==null?void 0:i.cancel,f=i==null?void 0:i.pull,b=i==null?void 0:i.start,u=i==null?void 0:i.type;return{autoAllocateChunkSize:l===void 0?void 0:Qr(l,`${n} has member 'autoAllocateChunkSize' that`),cancel:c===void 0?void 0:Zo(c,i,`${n} has member 'cancel' that`),pull:f===void 0?void 0:en(f,i,`${n} has member 'pull' that`),start:b===void 0?void 0:rn(b,i,`${n} has member 'start' that`),type:u===void 0?void 0:tn(u,`${n} has member 'type' that`)}})(r,"First parameter");if(nt(this),a.type==="bytes"){if(o.size!==void 0)throw new RangeError("The strategy for a byte stream cannot have a size function");(function(s,n,i){const l=Object.create(K.prototype);let c,f,b;c=n.start!==void 0?()=>n.start(l):()=>{},f=n.pull!==void 0?()=>n.pull(l):()=>g(void 0),b=n.cancel!==void 0?h=>n.cancel(h):()=>g(void 0);const u=n.autoAllocateChunkSize;if(u===0)throw new TypeError("autoAllocateChunkSize must be greater than 0");oo(s,l,c,f,b,i,u)})(this,a,Be(o,0))}else{const s=nr(o);(function(n,i,l,c){const f=Object.create(Z.prototype);let b,u,h;b=i.start!==void 0?()=>i.start(f):()=>{},u=i.pull!==void 0?()=>i.pull(f):()=>g(void 0),h=i.cancel!==void 0?T=>i.cancel(T):()=>g(void 0),Ro(n,f,b,u,h,l,c)})(this,a,Be(o,1),s)}}get locked(){if(!X(this))throw ie("locked");return re(this)}cancel(r=void 0){return X(this)?re(this)?d(new TypeError("Cannot cancel a stream that already has a reader")):D(this,r):d(ie("cancel"))}getReader(r=void 0){if(!X(this))throw ie("getReader");return(function(t,o){Y(t,o);const a=t==null?void 0:t.mode;return{mode:a===void 0?void 0:Lo(a,`${o} has member 'mode' that`)}})(r,"First parameter").mode===void 0?we(this):no(this)}pipeThrough(r,t={}){if(!X(this))throw ie("pipeThrough");U(r,1,"pipeThrough");const o=(function(s,n){Y(s,n);const i=s==null?void 0:s.readable;qr(i,"readable","ReadableWritablePair"),Yr(i,`${n} has member 'readable' that`);const l=s==null?void 0:s.writable;return qr(l,"writable","ReadableWritablePair"),lo(l,`${n} has member 'writable' that`),{readable:i,writable:l}})(r,"First parameter"),a=pt(t,"Second parameter");if(re(this))throw new TypeError("ReadableStream.prototype.pipeThrough cannot be used on a locked ReadableStream");if(Te(o.writable))throw new TypeError("ReadableStream.prototype.pipeThrough cannot be used on a locked WritableStream");return Ee(bt(this,o.writable,a.preventClose,a.preventAbort,a.preventCancel,a.signal)),o.readable}pipeTo(r,t={}){if(!X(this))return d(ie("pipeTo"));if(r===void 0)return d("Parameter 1 is required in 'pipeTo'.");if(!ge(r))return d(new TypeError("ReadableStream.prototype.pipeTo's first argument must be a WritableStream"));let o;try{o=pt(t,"Second parameter")}catch(a){return d(a)}return re(this)?d(new TypeError("ReadableStream.prototype.pipeTo cannot be used on a locked ReadableStream")):Te(r)?d(new TypeError("ReadableStream.prototype.pipeTo cannot be used on a locked WritableStream")):bt(this,r,o.preventClose,o.preventAbort,o.preventCancel,o.signal)}tee(){if(!X(this))throw ie("tee");return ke(Jo(this))}values(r=void 0){if(!X(this))throw ie("values");return(function(t,o){const a=we(t),s=new Dt(a,o),n=Object.create(xt);return n._asyncIteratorImpl=s,n})(this,(function(t,o){return Y(t,o),{preventCancel:!!(t==null?void 0:t.preventCancel)}})(r,"First parameter").preventCancel)}[Me](r){return this.values(r)}static from(r){return Ko(r)}}function $e(e,r,t,o=1,a=()=>1){const s=Object.create(B.prototype);return nt(s),Ro(s,Object.create(Z.prototype),e,r,t,o,a),s}function yt(e,r,t){const o=Object.create(B.prototype);return nt(o),oo(o,Object.create(K.prototype),e,r,t,0,void 0),o}function nt(e){e._state="readable",e._reader=void 0,e._storedError=void 0,e._disturbed=!1}function X(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_readableStreamController")&&e instanceof B}function re(e){return e._reader!==void 0}function D(e,r){if(e._disturbed=!0,e._state==="closed")return g(void 0);if(e._state==="errored")return d(e._storedError);De(e);const t=e._reader;if(t!==void 0&&de(t)){const o=t._readIntoRequests;t._readIntoRequests=new $,o.forEach(a=>{a._closeSteps(void 0)})}return H(e._readableStreamController[Ir](r),Re)}function De(e){e._state="closed";const r=e._reader;if(r!==void 0&&(Wt(r),ee(r))){const t=r._readRequests;r._readRequests=new $,t.forEach(o=>{o._closeSteps()})}}function Po(e,r){e._state="errored",e._storedError=r;const t=e._reader;t!==void 0&&(xr(t,r),ee(t)?Ft(t,r):so(t,r))}function ie(e){return new TypeError(`ReadableStream.prototype.${e} can only be used on a ReadableStream`)}function qo(e,r){Y(e,r);const t=e==null?void 0:e.highWaterMark;return qr(t,"highWaterMark","QueuingStrategyInit"),{highWaterMark:Nr(t)}}Object.defineProperties(B,{from:{enumerable:!0}}),Object.defineProperties(B.prototype,{cancel:{enumerable:!0},getReader:{enumerable:!0},pipeThrough:{enumerable:!0},pipeTo:{enumerable:!0},tee:{enumerable:!0},values:{enumerable:!0},locked:{enumerable:!0}}),v(B.from,"from"),v(B.prototype.cancel,"cancel"),v(B.prototype.getReader,"getReader"),v(B.prototype.pipeThrough,"pipeThrough"),v(B.prototype.pipeTo,"pipeTo"),v(B.prototype.tee,"tee"),v(B.prototype.values,"values"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(B.prototype,Symbol.toStringTag,{value:"ReadableStream",configurable:!0}),Object.defineProperty(B.prototype,Me,{value:B.prototype.values,writable:!0,configurable:!0});const Co=e=>e.byteLength;v(Co,"size");class Or{constructor(r){U(r,1,"ByteLengthQueuingStrategy"),r=qo(r,"First parameter"),this._byteLengthQueuingStrategyHighWaterMark=r.highWaterMark}
1get highWaterMark(){if(!gt(this))throw vt("highWaterMark");return this._byteLengthQueuingStrategyHighWaterMark}get size(){if(!gt(this))throw vt("size");return Co}}function vt(e){return new TypeError(`ByteLengthQueuingStrategy.prototype.${e} can only be used on a ByteLengthQueuingStrategy`)}function gt(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_byteLengthQueuingStrategyHighWaterMark")&&e instanceof Or}Object.defineProperties(Or.prototype,{highWaterMark:{enumerable:!0},size:{enumerable:!0}}),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(Or.prototype,Symbol.toStringTag,{value:"ByteLengthQueuingStrategy",configurable:!0});const Eo=()=>1;v(Eo,"size");class Ar{constructor(r){U(r,1,"CountQueuingStrategy"),r=qo(r,"First parameter"),this._countQueuingStrategyHighWaterMark=r.highWaterMark}get highWaterMark(){if(!St(this))throw wt("highWaterMark");return this._countQueuingStrategyHighWaterMark}get size(){if(!St(this))throw wt("size");return Eo}}function wt(e){return new TypeError(`CountQueuingStrategy.prototype.${e} can only be used on a CountQueuingStrategy`)}function St(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_countQueuingStrategyHighWaterMark")&&e instanceof Ar}function on(e,r,t){return M(e,t),o=>G(e,r,[o])}function nn(e,r,t){return M(e,t),o=>he(e,r,[o])}function an(e,r,t){return M(e,t),(o,a)=>G(e,r,[o,a])}function sn(e,r,t){return M(e,t),o=>G(e,r,[o])}Object.defineProperties(Ar.prototype,{highWaterMark:{enumerable:!0},size:{enumerable:!0}}),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(Ar.prototype,Symbol.toStringTag,{value:"CountQueuingStrategy",configurable:!0});class zr{constructor(r={},t={},o={}){r===void 0&&(r=null);const a=ir(t,"Second parameter"),s=ir(o,"Third parameter"),n=(function(u,h){Y(u,h);const T=u==null?void 0:u.cancel,C=u==null?void 0:u.flush,j=u==null?void 0:u.readableType,R=u==null?void 0:u.start,y=u==null?void 0:u.transform,S=u==null?void 0:u.writableType;return{cancel:T===void 0?void 0:sn(T,u,`${h} has member 'cancel' that`),flush:C===void 0?void 0:on(C,u,`${h} has member 'flush' that`),readableType:j,start:R===void 0?void 0:nn(R,u,`${h} has member 'start' that`),transform:y===void 0?void 0:an(y,u,`${h} has member 'transform' that`),writableType:S}})(r,"First parameter");if(n.readableType!==void 0)throw new RangeError("Invalid readableType specified");if(n.writableType!==void 0)throw new RangeError("Invalid writableType specified");const i=Be(s,0),l=nr(s),c=Be(a,1),f=nr(a);let b;(function(u,h,T,C,j,R){function y(){return h}function S(w){return(function(m,E){const p=m._transformStreamController;return m._backpressure?H(m._backpressureChangePromise,()=>{const q=m._writable;if(q._state==="erroring")throw q._storedError;return Rt(p,E)}):Rt(p,E)})(u,w)}function _(w){return(function(m,E){const p=m._transformStreamController;if(p._finishPromise!==void 0)return p._finishPromise;const q=m._readable;p._finishPromise=O((A,_r)=>{p._finishPromise_resolve=A,p._finishPromise_reject=_r});const F=p._cancelAlgorithm(E);return tr(p),I(F,()=>(q._state==="errored"?ye(p,q._storedError):(N(q._readableStreamController,E),Tr(p)),null),A=>(N(q._readableStreamController,A),ye(p,A),null)),p._finishPromise})(u,w)}function k(){return(function(w){const m=w._transformStreamController;if(m._finishPromise!==void 0)return m._finishPromise;const E=w._readable;m._finishPromise=O((q,F)=>{m._finishPromise_resolve=q,m._finishPromise_reject=F});const p=m._flushAlgorithm();return tr(m),I(p,()=>(E._state==="errored"?ye(m,E._storedError):(me(E._readableStreamController),Tr(m)),null),q=>(N(E._readableStreamController,q),ye(m,q),null)),m._finishPromise})(u)}function z(){return(function(w){return ur(w,!1),w._backpressureChangePromise})(u)}function P(w){return(function(m,E){const p=m._transformStreamController;if(p._finishPromise!==void 0)return p._finishPromise;const q=m._writable;p._finishPromise=O((A,_r)=>{p._finishPromise_resolve=A,p._finishPromise_reject=_r});const F=p._cancelAlgorithm(E);return tr(p),I(F,()=>(q._state==="errored"?ye(p,q._storedError):(Ie(q._writableStreamController,E),Br(m),Tr(p)),null),A=>(Ie(q._writableStreamController,A),Br(m),ye(p,A),null)),p._finishPromise})(u,w)}u._writable=(function(w,m,E,p,q=1,F=()=>1){const A=Object.create(ue.prototype);return co(A),po(A,Object.create(Fe.prototype),w,m,E,p,q,F),A})(y,S,k,_,T,C),u._readable=$e(y,z,P,j,R),u._backpressure=void 0,u._backpressureChangePromise=void 0,u._backpressureChangePromise_resolve=void 0,ur(u,!0),u._transformStreamController=void 0})(this,O(u=>{b=u}),c,f,i,l),(function(u,h){const T=Object.create(ce.prototype);let C,j,R;C=h.transform!==void 0?y=>h.transform(y,T):y=>{try{return ko(T,y),g(void 0)}catch(S){return d(S)}},j=h.flush!==void 0?()=>h.flush(T):()=>g(void 0),R=h.cancel!==void 0?y=>h.cancel(y):()=>g(void 0),(function(y,S,_,k,z){S._controlledTransformStream=y,y._transformStreamController=S,S._transformAlgorithm=_,S._flushAlgorithm=k,S._cancelAlgorithm=z,S._finishPromise=void 0,S._finishPromise_resolve=void 0,S._finishPromise_reject=void 0})(u,T,C,j,R)})(this,n),n.start!==void 0?b(n.start(this._transformStreamController)):b(void 0)}get readable(){if(!Tt(this))throw Pt("readable");return this._readable}get writable(){if(!Tt(this))throw Pt("writable");return this._writable}}function Tt(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_transformStreamController")&&e instanceof zr}function jo(e,r){N(e._readable._readableStreamController,r),it(e,r)}function it(e,r){tr(e._transformStreamController),Ie(e._writable._writableStreamController,r),Br(e)}function Br(e){e._backpressure&&ur(e,!1)}function ur(e,r){e._backpressureChangePromise!==void 0&&e._backpressureChangePromise_resolve(),e._backpressureChangePromise=O(t=>{e._backpressureChangePromise_resolve=t}),e._backpressure=r}Object.defineProperties(zr.prototype,{readable:{enumerable:!0},writable:{enumerable:!0}}),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(zr.prototype,Symbol.toStringTag,{value:"TransformStream",configurable:!0});class ce{constructor(){throw new TypeError("Illegal constructor")}get desiredSize(){if(!Ue(this))throw Ge("desiredSize");return ot(this._controlledTransformStream._readable._readableStreamController)}enqueue(r=void 0){if(!Ue(this))throw Ge("enqueue");ko(this,r)}error(r=void 0){if(!Ue(this))throw Ge("error");var t;t=r,jo(this._controlledTransformStream,t)}terminate(){if(!Ue(this))throw Ge("terminate");(function(r){const t=r._controlledTransformStream;me(t._readable._readableStreamController);const o=new TypeError("TransformStream terminated");it(t,o)})(this)}}function Ue(e){return!!W(e)&&!!Object.prototype.hasOwnProperty.call(e,"_controlledTransformStream")&&e instanceof ce}function tr(e){e._transformAlgorithm=void 0,e._flushAlgorithm=void 0,e._cancelAlgorithm=void 0}function ko(e,r){const t=e._controlledTransformStream,o=t._readable._readableStreamController;if(!Ce(o))throw new TypeError("Readable side is not in a state that permits enqueue");try{qe(o,r)}catch(s){throw it(t,s),t._readable._storedError}(function(s){return!To(s)})(o)!==t._backpressure&&ur(t,!0)}function Rt(e,r){return H(e._transformAlgorithm(r),void 0,t=>{throw jo(e._controlledTransformStream,t),t})}function Ge(e){return new TypeError(`TransformStreamDefaultController.prototype.${e} can only be used on a TransformStreamDefaultController`)}function Tr(e){e._finishPromise_resolve!==void 0&&(e._finishPromise_resolve(),e._finishPromise_resolve=void 0,e._finishPromise_reject=void 0)}function ye(e,r){e._finishPromise_reject!==void 0&&(Ee(e._finishPromise),e._finishPromise_reject(r),e._finishPromise_resolve=void 0,e._finishPromise_reject=void 0)}function Pt(e){return new TypeError(`TransformStream.prototype.${e} can only be used on a TransformStream`)}Object.defineProperties(ce.prototype,{enqueue:{enumerable:!0},error:{enumerable:!0},terminate:{enumerable:!0},desiredSize:{enumerable:!0}}),v(ce.prototype.enqueue,"enqueue"),v(ce.prototype.error,"error"),v(ce.prototype.terminate,"terminate"),typeof Symbol.toStringTag=="symbol"&&Object.defineProperty(ce.prototype,Symbol.toStringTag,{value:"TransformStreamDefaultController",configurable:!0});export{Or as ByteLengthQueuingStrategy,Ar as CountQueuingStrategy,K as ReadableByteStreamController,B as ReadableStream,le as ReadableStreamBYOBReader,ve as ReadableStreamBYOBRequest,Z as ReadableStreamDefaultController,ae as ReadableStreamDefaultReader,zr as TransformStream,ce as TransformStreamDefaultController,ue as WritableStream,Fe as WritableStreamDefaultController,J as WritableStreamDefaultWriter};
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.