https://istories.media/464-9b068d2555d4b64eeac8.js

1/*! For license information please see 464-9b068d2555d4b64eeac8.js.LICENSE.txt */
2"use strict";(self.webpackChunkistories=self.webpackChunkistories||[]).push([[464],{8464:function(e,t,r){r.r(t),r.d(t,{ByteLengthQueuingStrategy:function(){return hr},CountQueuingStrategy:function(){return mr},ReadableByteStreamController:function(){return be},ReadableStream:function(){return rr},ReadableStreamBYOBReader:function(){return Ie},ReadableStreamBYOBRequest:function(){return _e},ReadableStreamDefaultController:function(){return Lt},ReadableStreamDefaultReader:function(){return Z},TransformStream:function(){return Rr},TransformStreamDefaultController:function(){return Cr},WritableStream:function(){return Ge},WritableStreamDefaultController:function(){return bt},WritableStreamDefaultWriter:function(){return lt}}),"undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof self&&self;const o="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?Symbol:e=>`Symbol(${e})`;function n(){}const i="undefined"!=typeof self?self:"undefined"!=typeof window?window:"undefined"!=typeof global?global:void 0;function a(e){return"object"==typeof e&&null!==e||"function"==typeof e}const s=n,l=Promise,u=Promise.prototype.then,c=Promise.resolve.bind(l),d=Promise.reject.bind(l);function f(e){return new l(e)}function h(e){return c(e)}function _(e){return d(e)}function b(e,t,r){return u.call(e,t,r)}function p(e,t,r){b(b(e,t,r),void 0,s)}function m(e,t){p(e,t)}function y(e,t){p(e,void 0,t)}function g(e,t,r){return b(e,t,r)}function w(e){b(e,void 0,s)}const v=(()=>{const e=i&&i.queueMicrotask;if("function"==typeof e)return e;const t=h(void 0);return e=>b(t,e)})();function S(e,t,r){if("function"!=typeof e)throw new TypeError("Argument is not a function");return Function.prototype.apply.call(e,t,r)}function R(e,t,r){try{return h(S(e,t,r))}catch(e){return _(e)}}class T{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(e){const t=this._back;let r=t;16383===t._elements.length&&(r={_elements:[],_next:void 0}),t._elements.push(e),r!==t&&(this._back=r,t._next=r),++this._size}shift(){const e=this._front;let t=e;const r=this._cursor;let o=r+1;const n=e._elements,i=n[r];return 16384===o&&(t=e._next,o=0),--this._size,this._cursor=o,e!==t&&(this._front=t),n[r]=void 0,i}forEach(e){let t=this._cursor,r=this._front,o=r._elements;for(;!(t===o.length&&void 0===r._next||t===o.length&&(r=r._next,o=r._elements,t=0,0===o.length));)e(o[t]),++t}peek(){const e=this._front,t=this._cursor;return e._elements[t]}}function P(e,t){e._ownerReadableStream=t,t._reader=e,"readable"===t._state?k(e):"closed"===t._state?function(e){k(e),j(e)}(e):O(e,t._storedError)}function q(e,t){return sr(e._ownerReadableStream,t)}function E(e){"readable"===e._ownerReadableStream._state?W(e,new TypeError("Reader was released and can no longer be used to monitor the stream's closedness")):function(e,t){O(e,new TypeError("Reader was released and can no longer be used to monitor the stream's closedness"))}(e),e._ownerReadableStream._reader=void 0,e._ownerReadableStream=void 0}function C(e){return new TypeError("Cannot "+e+" a stream using a released reader")}function k(e){e._closedPromise=f(((t,r)=>{e._closedPromise_resolve=t,e._closedPromise_reject=r}))}function O(e,t){k(e),W(e,t)}function W(e,t){void 0!==e._closedPromise_reject&&(w(e._closedPromise),e._closedPromise_reject(t),e._closedPromise_resolve=void 0,e._closedPromise_reject=void 0)}function j(e){void 0!==e._closedPromise_resolve&&(e._closedPromise_resolve(void 0),e._closedPromise_resolve=void 0,e._closedPromise_reject=void 0)}const A=o("[[AbortSteps]]"),z=o("[[ErrorSteps]]"),B=o("[[CancelSteps]]"),F=o("[[PullSteps]]"),I=Number.isFinite||function(e){return"number"==typeof e&&isFinite(e)},L=Math.trunc||function(e){return e<0?Math.ceil(e):Math.floor(e)};function M(e,t){if(void 0!==e&&"object"!=typeof(r=e)&&"function"!=typeof r)throw new TypeError(t+" is not an object.");var r}function $(e,t){if("function"!=typeof e)throw new TypeError(t+" is not a function.")}function D(e,t){if(!function(e){return"object"==typeof e&&null!==e||"function"==typeof e}(e))throw new TypeError(t+" is not an object.")}function x(e,t,r){if(void 0===e)throw new TypeError(`Parameter ${t} is required in '${r}'.`)}function N(e,t,r){if(void 0===e)throw new TypeError(`${t} is required in '${r}'.`)}function Q(e){return Number(e)}function Y(e){return 0===e?0:e}function H(e,t){const r=Number.MAX_SAFE_INTEGER;let o=Number(e);if(o=Y(o),!I(o))throw new TypeError(t+" is not a finite number");if(o=function(e){return Y(L(e))}(o),o<0||o>r)throw new TypeError(`${t} is outside the accepted range of 0 to ${r}, inclusive`);return I(o)&&0!==o?o:0}function V(e,t){if(!ir(e))throw new TypeError(t+" is not a ReadableStream.")}function U(e){return new Z(e)}function G(e,t){e._reader._readRequests.push(t)}function X(e,t,r){const o=e._reader._readRequests.shift();r?o._closeSteps():o._chunkSteps(t)}function J(e){return e._reader._readRequests.length}function K(e){const t=e._reader;return void 0!==t&&!!ee(t)}class Z{constructor(e){if(x(e,1,"ReadableStreamDefaultReader"),V(e,"First parameter"),ar(e))throw new TypeError("This stream has already been locked for exclusive reading by another reader");P(this,e),this._readRequests=new T}

2get closed(){return ee(this)?this._closedPromise:_(re("closed"))}cancel(e){return ee(this)?void 0===this._ownerReadableStream?_(C("cancel")):q(this,e):_(re("cancel"))}read(){if(!ee(this))return _(re("read"));if(void 0===this._ownerReadableStream)return _(C("read from"));let e,t;const r=f(((r,o)=>{e=r,t=o}));return te(this,{_chunkSteps:t=>e({value:t,done:!1}),_closeSteps:()=>e({value:void 0,done:!0}),_errorSteps:e=>t(e)}),r}releaseLock(){if(!ee(this))throw re("releaseLock");if(void 0!==this._ownerReadableStream){if(this._readRequests.length>0)throw new TypeError("Tried to release a reader lock when that reader has pending read() calls un-settled");E(this)}}}function ee(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_readRequests")}function te(e,t){const r=e._ownerReadableStream;r._disturbed=!0,"closed"===r._state?t._closeSteps():"errored"===r._state?t._errorSteps(r._storedError):r._readableStreamController[F](t)}function re(e){return new TypeError(`ReadableStreamDefaultReader.prototype.${e} can only be used on a ReadableStreamDefaultReader`)}let oe;Object.defineProperties(Z.prototype,{cancel:{enumerable:!0},read:{enumerable:!0},releaseLock:{enumerable:!0},closed:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(Z.prototype,o.toStringTag,{value:"ReadableStreamDefaultReader",configurable:!0}),"symbol"==typeof o.asyncIterator&&(oe={[o.asyncIterator](){return this}},Object.defineProperty(oe,o.asyncIterator,{enumerable:!1}));class ne{constructor(e,t){this._ongoingPromise=void 0,this._isFinished=!1,this._reader=e,this._preventCancel=t}next(){const e=()=>this._nextSteps();return this._ongoingPromise=this._ongoingPromise?g(this._ongoingPromise,e,e):e(),this._ongoingPromise}return(e){const t=()=>this._returnSteps(e);return this._ongoingPromise?g(this._ongoingPromise,t,t):t()}_nextSteps(){if(this._isFinished)return Promise.resolve({value:void 0,done:!0});const e=this._reader;if(void 0===e._ownerReadableStream)return _(C("iterate"));let t,r;const o=f(((e,o)=>{t=e,r=o}));return te(e,{_chunkSteps:e=>{this._ongoingPromise=void 0,v((()=>t({value:e,done:!1})))},_closeSteps:()=>{this._ongoingPromise=void 0,this._isFinished=!0,E(e),t({value:void 0,done:!0})},_errorSteps:t=>{this._ongoingPromise=void 0,this._isFinished=!0,E(e),r(t)}}),o}_returnSteps(e){if(this._isFinished)return Promise.resolve({value:e,done:!0});this._isFinished=!0;const t=this._reader;if(void 0===t._ownerReadableStream)return _(C("finish iterating"));if(!this._preventCancel){const r=q(t,e);return E(t),g(r,(()=>({value:e,done:!0})))}return E(t),h({value:e,done:!0})}}const ie={next(){return ae(this)?this._asyncIteratorImpl.next():_(se("next"))},return(e){return ae(this)?this._asyncIteratorImpl.return(e):_(se("return"))}};function ae(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_asyncIteratorImpl")}function se(e){return new TypeError(`ReadableStreamAsyncIterator.${e} can only be used on a ReadableSteamAsyncIterator`)}void 0!==oe&&Object.setPrototypeOf(ie,oe);const le=Number.isNaN||function(e){return e!=e};function ue(e){return!!function(e){return"number"==typeof e&&(!le(e)&&!(e<0))}(e)&&e!==1/0}function ce(e){const t=e._queue.shift();return e._queueTotalSize-=t.size,e._queueTotalSize<0&&(e._queueTotalSize=0),t.value}function de(e,t,r){if(!ue(r=Number(r)))throw new RangeError("Size must be a finite, non-NaN, non-negative number.");e._queue.push({value:t,size:r}),e._queueTotalSize+=r}function fe(e){e._queue=new T,e._queueTotalSize=0}function he(e){return e.slice()}class _e{constructor(){throw new TypeError("Illegal constructor")}get view(){if(!me(this))throw je("view");return this._view}respond(e){if(!me(this))throw je("respond");if(x(e,1,"respond"),e=H(e,"First parameter"),void 0===this._associatedReadableByteStreamController)throw new TypeError("This BYOB request has been invalidated");this._view.buffer,function(e,t){if(!ue(t=Number(t)))throw new RangeError("bytesWritten must be a finite");Ee(e,t)}(this._associatedReadableByteStreamController,e)}respondWithNewView(e){if(!me(this))throw je("respondWithNewView");if(x(e,1,"respondWithNewView"),!ArrayBuffer.isView(e))throw new TypeError("You can only respond with array buffer views");if(0===e.byteLength)throw new TypeError("chunk must have non-zero byteLength");if(0===e.buffer.byteLength)throw new TypeError("chunk's buffer must have non-zero byteLength");if(void 0===this._associatedReadableByteStreamController)throw new TypeError("This BYOB request has been invalidated");!function(e,t){const r=e._pendingPullIntos.peek();if(r.byteOffset+r.bytesFilled!==t.byteOffset)throw new RangeError("The region specified by view does not match byobRequest");

2if(r.byteLength!==t.byteLength)throw new RangeError("The buffer of view has different capacity than byobRequest");r.buffer=t.buffer,Ee(e,t.byteLength)}(this._associatedReadableByteStreamController,e)}}Object.defineProperties(_e.prototype,{respond:{enumerable:!0},respondWithNewView:{enumerable:!0},view:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(_e.prototype,o.toStringTag,{value:"ReadableStreamBYOBRequest",configurable:!0});class be{constructor(){throw new TypeError("Illegal constructor")}get byobRequest(){if(!pe(this))throw Ae("byobRequest");if(null===this._byobRequest&&this._pendingPullIntos.length>0){const e=this._pendingPullIntos.peek(),t=new Uint8Array(e.buffer,e.byteOffset+e.bytesFilled,e.byteLength-e.bytesFilled),r=Object.create(_e.prototype);!function(e,t,r){e._associatedReadableByteStreamController=t,e._view=r}(r,this,t),this._byobRequest=r}return this._byobRequest}get desiredSize(){if(!pe(this))throw Ae("desiredSize");return We(this)}close(){if(!pe(this))throw Ae("close");if(this._closeRequested)throw new TypeError("The stream has already been closed; do not close it again!");const e=this._controlledReadableByteStream._state;if("readable"!==e)throw new TypeError(`The stream (in ${e} state) is not in the readable state and cannot be closed`);!function(e){const t=e._controlledReadableByteStream;if(!e._closeRequested&&"readable"===t._state)if(e._queueTotalSize>0)e._closeRequested=!0;else{if(e._pendingPullIntos.length>0&&e._pendingPullIntos.peek().bytesFilled>0){const t=new TypeError("Insufficient bytes to fill elements in the given buffer");throw Oe(e,t),t}ke(e),lr(t)}}(this)}enqueue(e){if(!pe(this))throw Ae("enqueue");if(x(e,1,"enqueue"),!ArrayBuffer.isView(e))throw new TypeError("chunk must be an array buffer view");if(0===e.byteLength)throw new TypeError("chunk must have non-zero byteLength");if(0===e.buffer.byteLength)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("readable"!==t)throw new TypeError(`The stream (in ${t} state) is not in the readable state and cannot be enqueued to`);!function(e,t){const r=e._controlledReadableByteStream;if(e._closeRequested||"readable"!==r._state)return;const o=t.buffer,n=t.byteOffset,i=t.byteLength,a=o;K(r)?0===J(r)?ve(e,a,n,i):X(r,new Uint8Array(a,n,i),!1):Fe(r)?(ve(e,a,n,i),qe(e)):ve(e,a,n,i),ye(e)}(this,e)}error(e){if(!pe(this))throw Ae("error");Oe(this,e)}[B](e){this._pendingPullIntos.length>0&&(this._pendingPullIntos.peek().bytesFilled=0),fe(this);const t=this._cancelAlgorithm(e);return ke(this),t}[F](e){const t=this._controlledReadableByteStream;if(this._queueTotalSize>0){const t=this._queue.shift();this._queueTotalSize-=t.byteLength,Te(this);const r=new Uint8Array(t.buffer,t.byteOffset,t.byteLength);return void e._chunkSteps(r)}const r=this._autoAllocateChunkSize;if(void 0!==r){let o;try{o=new ArrayBuffer(r)}catch(t){return void e._errorSteps(t)}const n={buffer:o,byteOffset:0,byteLength:r,bytesFilled:0,elementSize:1,viewConstructor:Uint8Array,readerType:"default"};this._pendingPullIntos.push(n)}G(t,e),ye(this)}}function pe(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_controlledReadableByteStream")}function me(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_associatedReadableByteStreamController")}function ye(e){(function(e){const t=e._controlledReadableByteStream;return"readable"===t._state&&(!e._closeRequested&&(!!e._started&&(!!(K(t)&&J(t)>0)||(!!(Fe(t)&&Be(t)>0)||We(e)>0))))})(e)&&(e._pulling?e._pullAgain=!0:(e._pulling=!0,p(e._pullAlgorithm(),(()=>{e._pulling=!1,e._pullAgain&&(e._pullAgain=!1,ye(e))}),(t=>{Oe(e,t)}))))}function ge(e,t){let r=!1;"closed"===e._state&&(r=!0);const o=we(t);"default"===t.readerType?X(e,o,r):function(e,t,r){const o=e._reader._readIntoRequests.shift();r?o._closeSteps(t):o._chunkSteps(t)}(e,o,r)}function we(e){const t=e.bytesFilled,r=e.elementSize;return new e.viewConstructor(e.buffer,e.byteOffset,t/r)}function ve(e,t,r,o){e._queue.push({buffer:t,byteOffset:r,byteLength:o}),e._queueTotalSize+=o}function Se(e,t){const r=t.elementSize,o=t.bytesFilled-t.bytesFilled%r,n=Math.min(e._queueTotalSize,t.byteLength-t.bytesFilled),i=t.bytesFilled+n,a=i-i%r;let s=n,l=!1;a>o&&(s=a-t.bytesFilled,l=!0);const u=e._queue;

2for(;s>0;){const r=u.peek(),o=Math.min(s,r.byteLength),n=t.byteOffset+t.bytesFilled;c=t.buffer,d=n,f=r.buffer,h=r.byteOffset,_=o,new Uint8Array(c).set(new Uint8Array(f,h,_),d),r.byteLength===o?u.shift():(r.byteOffset+=o,r.byteLength-=o),e._queueTotalSize-=o,Re(e,o,t),s-=o}var c,d,f,h,_;return l}function Re(e,t,r){Pe(e),r.bytesFilled+=t}function Te(e){0===e._queueTotalSize&&e._closeRequested?(ke(e),lr(e._controlledReadableByteStream)):ye(e)}function Pe(e){null!==e._byobRequest&&(e._byobRequest._associatedReadableByteStreamController=void 0,e._byobRequest._view=null,e._byobRequest=null)}function qe(e){for(;e._pendingPullIntos.length>0;){if(0===e._queueTotalSize)return;const t=e._pendingPullIntos.peek();Se(e,t)&&(Ce(e),ge(e._controlledReadableByteStream,t))}}function Ee(e,t){const r=e._pendingPullIntos.peek();if("closed"===e._controlledReadableByteStream._state){if(0!==t)throw new TypeError("bytesWritten must be 0 when calling respond() on a closed stream");!function(e,t){t.buffer=t.buffer;const r=e._controlledReadableByteStream;if(Fe(r))for(;Be(r)>0;)ge(r,Ce(e))}(e,r)}else!function(e,t,r){if(r.bytesFilled+t>r.byteLength)throw new RangeError("bytesWritten out of range");if(Re(e,t,r),r.bytesFilled<r.elementSize)return;Ce(e);const o=r.bytesFilled%r.elementSize;if(o>0){const t=r.byteOffset+r.bytesFilled,n=r.buffer.slice(t-o,t);ve(e,n,0,n.byteLength)}r.buffer=r.buffer,r.bytesFilled-=o,ge(e._controlledReadableByteStream,r),qe(e)}(e,t,r);ye(e)}function Ce(e){const t=e._pendingPullIntos.shift();return Pe(e),t}function ke(e){e._pullAlgorithm=void 0,e._cancelAlgorithm=void 0}function Oe(e,t){const r=e._controlledReadableByteStream;"readable"===r._state&&(function(e){Pe(e),e._pendingPullIntos=new T}(e),fe(e),ke(e),ur(r,t))}function We(e){const t=e._controlledReadableByteStream._state;return"errored"===t?null:"closed"===t?0:e._strategyHWM-e._queueTotalSize}function je(e){return new TypeError(`ReadableStreamBYOBRequest.prototype.${e} can only be used on a ReadableStreamBYOBRequest`)}function Ae(e){return new TypeError(`ReadableByteStreamController.prototype.${e} can only be used on a ReadableByteStreamController`)}function ze(e,t){e._reader._readIntoRequests.push(t)}function Be(e){return e._reader._readIntoRequests.length}function Fe(e){const t=e._reader;return void 0!==t&&!!Le(t)}Object.defineProperties(be.prototype,{close:{enumerable:!0},enqueue:{enumerable:!0},error:{enumerable:!0},byobRequest:{enumerable:!0},desiredSize:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(be.prototype,o.toStringTag,{value:"ReadableByteStreamController",configurable:!0});class Ie{constructor(e){if(x(e,1,"ReadableStreamBYOBReader"),V(e,"First parameter"),ar(e))throw new TypeError("This stream has already been locked for exclusive reading by another reader");if(!pe(e._readableStreamController))throw new TypeError("Cannot construct a ReadableStreamBYOBReader for a stream not constructed with a byte source");P(this,e),this._readIntoRequests=new T}get closed(){return Le(this)?this._closedPromise:_(Me("closed"))}cancel(e){return Le(this)?void 0===this._ownerReadableStream?_(C("cancel")):q(this,e):_(Me("cancel"))}read(e){if(!Le(this))return _(Me("read"));if(!ArrayBuffer.isView(e))return _(new TypeError("view must be an array buffer view"));if(0===e.byteLength)return _(new TypeError("view must have non-zero byteLength"));if(0===e.buffer.byteLength)return _(new TypeError("view's buffer must have non-zero byteLength"));if(void 0===this._ownerReadableStream)return _(C("read from"));let t,r;const o=f(((e,o)=>{t=e,r=o}));return function(e,t,r){const o=e._ownerReadableStream;o._disturbed=!0,"errored"===o._state?r._errorSteps(o._storedError):function(e,t,r){const o=e._controlledReadableByteStream;let n=1;t.constructor!==DataView&&(n=t.constructor.BYTES_PER_ELEMENT);const i=t.constructor,a={buffer:t.buffer,byteOffset:t.byteOffset,byteLength:t.byteLength,bytesFilled:0,elementSize:n,viewConstructor:i,readerType:"byob"};if(e._pendingPullIntos.length>0)return e._pendingPullIntos.push(a),void ze(o,r);if("closed"!==o._state){if(e._queueTotalSize>0){if(Se(e,a)){const t=we(a);

2return Te(e),void r._chunkSteps(t)}if(e._closeRequested){const t=new TypeError("Insufficient bytes to fill elements in the given buffer");return Oe(e,t),void r._errorSteps(t)}}e._pendingPullIntos.push(a),ze(o,r),ye(e)}else{const e=new i(a.buffer,a.byteOffset,0);r._closeSteps(e)}}(o._readableStreamController,t,r)}(this,e,{_chunkSteps:e=>t({value:e,done:!1}),_closeSteps:e=>t({value:e,done:!0}),_errorSteps:e=>r(e)}),o}releaseLock(){if(!Le(this))throw Me("releaseLock");if(void 0!==this._ownerReadableStream){if(this._readIntoRequests.length>0)throw new TypeError("Tried to release a reader lock when that reader has pending read() calls un-settled");E(this)}}}function Le(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_readIntoRequests")}function Me(e){return new TypeError(`ReadableStreamBYOBReader.prototype.${e} can only be used on a ReadableStreamBYOBReader`)}function $e(e,t){const{highWaterMark:r}=e;if(void 0===r)return t;if(le(r)||r<0)throw new RangeError("Invalid highWaterMark");return r}function De(e){const{size:t}=e;return t||(()=>1)}function xe(e,t){M(e,t);const r=null==e?void 0:e.highWaterMark,o=null==e?void 0:e.size;return{highWaterMark:void 0===r?void 0:Q(r),size:void 0===o?void 0:Ne(o,t+" has member 'size' that")}}function Ne(e,t){return $(e,t),t=>Q(e(t))}function Qe(e,t,r){return $(e,r),r=>R(e,t,[r])}function Ye(e,t,r){return $(e,r),()=>R(e,t,[])}function He(e,t,r){return $(e,r),r=>S(e,t,[r])}function Ve(e,t,r){return $(e,r),(r,o)=>R(e,t,[r,o])}function Ue(e,t){if(!Ke(e))throw new TypeError(t+" is not a WritableStream.")}Object.defineProperties(Ie.prototype,{cancel:{enumerable:!0},read:{enumerable:!0},releaseLock:{enumerable:!0},closed:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(Ie.prototype,o.toStringTag,{value:"ReadableStreamBYOBReader",configurable:!0});class Ge{constructor(e={},t={}){void 0===e?e=null:D(e,"First parameter");const r=xe(t,"Second parameter"),o=function(e,t){M(e,t);const r=null==e?void 0:e.abort,o=null==e?void 0:e.close,n=null==e?void 0:e.start,i=null==e?void 0:e.type,a=null==e?void 0:e.write;return{abort:void 0===r?void 0:Qe(r,e,t+" has member 'abort' that"),close:void 0===o?void 0:Ye(o,e,t+" has member 'close' that"),start:void 0===n?void 0:He(n,e,t+" has member 'start' that"),write:void 0===a?void 0:Ve(a,e,t+" has member 'write' that"),type:i}}(e,"First parameter");if(Je(this),void 0!==o.type)throw new RangeError("Invalid type is specified");const n=De(r);!function(e,t,r,o){const n=Object.create(bt.prototype);let i=()=>{},a=()=>h(void 0),s=()=>h(void 0),l=()=>h(void 0);void 0!==t.start&&(i=()=>t.start(n)),void 0!==t.write&&(a=e=>t.write(e,n)),void 0!==t.close&&(s=()=>t.close()),void 0!==t.abort&&(l=e=>t.abort(e)),pt(e,n,i,a,s,l,r,o)}(this,o,$e(r,1),n)}get locked(){if(!Ke(this))throw Rt("locked");return Ze(this)}abort(e){return Ke(this)?Ze(this)?_(new TypeError("Cannot abort a stream that already has a writer")):et(this,e):_(Rt("abort"))}close(){return Ke(this)?Ze(this)?_(new TypeError("Cannot close a stream that already has a writer")):it(this)?_(new TypeError("Cannot close an already-closing stream")):tt(this):_(Rt("close"))}getWriter(){if(!Ke(this))throw Rt("getWriter");return Xe(this)}}function Xe(e){return new lt(e)}function Je(e){e._state="writable",e._storedError=void 0,e._writer=void 0,e._writableStreamController=void 0,e._writeRequests=new T,e._inFlightWriteRequest=void 0,e._closeRequest=void 0,e._inFlightCloseRequest=void 0,e._pendingAbortRequest=void 0,e._backpressure=!1}function Ke(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_writableStreamController")}function Ze(e){return void 0!==e._writer}function et(e,t){const r=e._state;if("closed"===r||"errored"===r)return h(void 0);if(void 0!==e._pendingAbortRequest)return e._pendingAbortRequest._promise;let o=!1;"erroring"===r&&(o=!0,t=void 0);const n=f(((r,n)=>{e._pendingAbortRequest={_promise:void 0,_resolve:r,_reject:n,_reason:t,_wasAlreadyErroring:o}}));return e._pendingAbortRequest._promise=n,o||ot(e,t),n}function tt(e){const t=e._state;if("closed"===t||"errored"===t)return _(new TypeError(`The stream (in ${t} state) is not in the writable state and cannot be closed`));const r=f(((t,r)=>{const o={_resolve:t,_reject:r};e._closeRequest=o})),o=e._writer;var n;return void 0!==o&&e._backpressure&&"writable"===t&&zt(o),de(n=e._writableStreamController,_t,0),gt(n),r}function rt(e,t){"writable"!==e._state?nt(e):ot(e,t)}function ot(e,t){const r=e._writableStreamController;e._state="erroring",e._storedError=t;const o=e._writer;void 0!==o&&dt(o,t),!function(e){return void 0!==e._inFlightWriteRequest||void 0!==e._inFlightCloseRequest}(e)&&r._started&&nt(e)}function nt(e){e._state="errored",e._writableStreamController[z]();const t=e._storedError;

2if(e._writeRequests.forEach((e=>{e._reject(t)})),e._writeRequests=new T,void 0===e._pendingAbortRequest)return void at(e);const r=e._pendingAbortRequest;if(e._pendingAbortRequest=void 0,r._wasAlreadyErroring)return r._reject(t),void at(e);p(e._writableStreamController[A](r._reason),(()=>{r._resolve(),at(e)}),(t=>{r._reject(t),at(e)}))}function it(e){return void 0!==e._closeRequest||void 0!==e._inFlightCloseRequest}function at(e){void 0!==e._closeRequest&&(e._closeRequest._reject(e._storedError),e._closeRequest=void 0);const t=e._writer;void 0!==t&&Ct(t,e._storedError)}function st(e,t){const r=e._writer;void 0!==r&&t!==e._backpressure&&(t?function(e){Ot(e)}(r):zt(r)),e._backpressure=t}Object.defineProperties(Ge.prototype,{abort:{enumerable:!0},close:{enumerable:!0},getWriter:{enumerable:!0},locked:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(Ge.prototype,o.toStringTag,{value:"WritableStream",configurable:!0});class lt{constructor(e){if(x(e,1,"WritableStreamDefaultWriter"),Ue(e,"First parameter"),Ze(e))throw new TypeError("This stream has already been locked for exclusive writing by another writer");this._ownerWritableStream=e,e._writer=this;const t=e._state;if("writable"===t)!it(e)&&e._backpressure?Ot(this):jt(this),qt(this);else if("erroring"===t)Wt(this,e._storedError),qt(this);else if("closed"===t)jt(this),qt(this),kt(this);else{const t=e._storedError;Wt(this,t),Et(this,t)}}get closed(){return ut(this)?this._closedPromise:_(Tt("closed"))}get desiredSize(){if(!ut(this))throw Tt("desiredSize");if(void 0===this._ownerWritableStream)throw Pt("desiredSize");return function(e){const t=e._ownerWritableStream,r=t._state;return"errored"===r||"erroring"===r?null:"closed"===r?0:yt(t._writableStreamController)}(this)}get ready(){return ut(this)?this._readyPromise:_(Tt("ready"))}abort(e){return ut(this)?void 0===this._ownerWritableStream?_(Pt("abort")):function(e,t){return et(e._ownerWritableStream,t)}(this,e):_(Tt("abort"))}close(){if(!ut(this))return _(Tt("close"));const e=this._ownerWritableStream;return void 0===e?_(Pt("close")):it(e)?_(new TypeError("Cannot close an already-closing stream")):ct(this)}releaseLock(){if(!ut(this))throw Tt("releaseLock");void 0!==this._ownerWritableStream&&ft(this)}write(e){return ut(this)?void 0===this._ownerWritableStream?_(Pt("write to")):ht(this,e):_(Tt("write"))}}function ut(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_ownerWritableStream")}function ct(e){return tt(e._ownerWritableStream)}function dt(e,t){"pending"===e._readyPromiseState?At(e,t):function(e,t){Wt(e,t)}(e,t)}function ft(e){const t=e._ownerWritableStream,r=new TypeError("Writer was released and can no longer be used to monitor the stream's closedness");dt(e,r),function(e,t){"pending"===e._closedPromiseState?Ct(e,t):function(e,t){Et(e,t)}(e,t)}(e,r),t._writer=void 0,e._ownerWritableStream=void 0}function ht(e,t){const r=e._ownerWritableStream,o=r._writableStreamController,n=function(e,t){try{return e._strategySizeAlgorithm(t)}catch(t){return wt(e,t),1}}(o,t);if(r!==e._ownerWritableStream)return _(Pt("write to"));const i=r._state;if("errored"===i)return _(r._storedError);if(it(r)||"closed"===i)return _(new TypeError("The stream is closing or closed and cannot be written to"));if("erroring"===i)return _(r._storedError);const a=function(e){return f(((t,r)=>{const o={_resolve:t,_reject:r};e._writeRequests.push(o)}))}(r);return function(e,t,r){try{de(e,t,r)}catch(t){return void wt(e,t)}const o=e._controlledWritableStream;it(o)||"writable"!==o._state||st(o,vt(e)),gt(e)}(o,t,n),a}Object.defineProperties(lt.prototype,{abort:{enumerable:!0},close:{enumerable:!0},releaseLock:{enumerable:!0},write:{enumerable:!0},closed:{enumerable:!0},desiredSize:{enumerable:!0},ready:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(lt.prototype,o.toStringTag,{value:"WritableStreamDefaultWriter",configurable:!0});const _t={};class bt{constructor(){throw new TypeError("Illegal constructor")}error(e){if(!function(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_controlledWritableStream")}(this))throw new TypeError("WritableStreamDefaultController.prototype.error can only be used on a WritableStreamDefaultController");"writable"===this._controlledWritableStream._state&&St(this,e)}[A](e){const t=this._abortAlgorithm(e);return mt(this),t}[z](){fe(this)}}function pt(e,t,r,o,n,i,a,s){t._controlledWritableStream=e,e._writableStreamController=t,t._queue=void 0,t._queueTotalSize=void 0,fe(t),t._started=!1,t._strategySizeAlgorithm=s,t._strategyHWM=a,t._writeAlgorithm=o,t._closeAlgorithm=n,t._abortAlgorithm=i;const l=vt(t);st(e,l),p(h(r()),(()=>{t._started=!0,gt(t)}),(r=>{t._started=!0,rt(e,r)}))}function mt(e){e._writeAlgorithm=void 0,e._closeAlgorithm=void 0,e._abortAlgorithm=void 0,e._strategySizeAlgorithm=void 0}function yt(e){return e._strategyHWM-e._queueTotalSize}function gt(e){const t=e._controlledWritableStream;if(!e._started)return;if(void 0!==t._inFlightWriteRequest)return;if("erroring"===t._state)return void nt(t);if(0===e._queue.length)return;const r=e._queue.peek().value;r===_t?function(e){const t=e._controlledWritableStream;(function(e){e._inFlightCloseRequest=e._closeRequest,e._closeRequest=void 0})(t),ce(e);const r=e._closeAlgorithm();mt(e),p(r,(()=>{!function(e){e._inFlightCloseRequest._resolve(void 0),e._inFlightCloseRequest=void 0,"erroring"===e._state&&(e._storedError=void 0,void 0!==e._pendingAbortRequest&&(e._pendingAbortRequest._resolve(),e._pendingAbortRequest=void 0)),e._state="closed";const t=e._writer;void 0!==t&&kt(t)}(t)}),(e=>{!function(e,t){e._inFlightCloseRequest._reject(t),e._inFlightCloseRequest=void 0,void 0!==e._pendingAbortRequest&&(e._pendingAbortRequest._reject(t),e._pendingAbortRequest=void 0),rt(e,t)}(t,e)}))}(e):function(e,t){const r=e._controlledWritableStream;!function(e){e._inFlightWriteRequest=e._writeRequests.shift()}(r),p(e._writeAlgorithm(t),(()=>{!function(e){e._inFlightWriteRequest._resolve(void 0),e._inFlightWriteRequest=void 0}(r);const t=r._state;if(ce(e),!it(r)&&"writable"===t){const t=vt(e);st(r,t)}gt(e)}),(t=>{"writable"===r._state&&mt(e),function(e,t){e._inFlightWriteRequest._reject(t),e._inFlightWriteRequest=void 0,rt(e,t)}(r,t)}))}(e,r)}function wt(e,t){"writable"===e._controlledWritableStream._state&&St(e,t)}function vt(e){return yt(e)<=0}function St(e,t){const r=e._controlledWritableStream;mt(e),ot(r,t)}function Rt(e){return new TypeError(`WritableStream.prototype.${e} can only be used on a WritableStream`)}function Tt(e){return new TypeError(`WritableStreamDefaultWriter.prototype.${e} can only be used on a WritableStreamDefaultWriter`)}function Pt(e){return new TypeError("Cannot "+e+" a stream using a released writer")}function qt(e){e._closedPromise=f(((t,r)=>{e._closedPromise_resolve=t,e._closedPromise_reject=r,e._closedPromiseState="pending"}))}function Et(e,t){qt(e),Ct(e,t)}function Ct(e,t){void 0!==e._closedPromise_reject&&(w(e._closedPromise),e._closedPromise_reject(t),e._closedPromise_resolve=void 0,e._closedPromise_reject=void 0,e._closedPromiseState="rejected")}function kt(e){void 0!==e._closedPromise_resolve&&(e._closedPromise_resolve(void 0),e._closedPromise_resolve=void 0,e._closedPromise_reject=void 0,e._closedPromiseState="resolved")}function Ot(e){e._readyPromise=f(((t,r)=>{e._readyPromise_resolve=t,e._readyPromise_reject=r})),e._readyPromiseState="pending"}function Wt(e,t){Ot(e),At(e,t)}function jt(e){Ot(e),zt(e)}function At(e,t){void 0!==e._readyPromise_reject&&(w(e._readyPromise),e._readyPromise_reject(t),e._readyPromise_resolve=void 0,e._readyPromise_reject=void 0,e._readyPromiseState="rejected")}function zt(e){void 0!==e._readyPromise_resolve&&(e._readyPromise_resolve(void 0),e._readyPromise_resolve=void 0,e._readyPromise_reject=void 0,e._readyPromiseState="fulfilled")}Object.defineProperties(bt.prototype,{error:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(bt.prototype,o.toStringTag,{value:"WritableStreamDefaultController",configurable:!0});const Bt="undefined"!=typeof DOMException?DOMException:void 0,Ft=function(e){if("function"!=typeof e&&"object"!=typeof e)return!1;try{return new e,!0}catch(e){return!1}}(Bt)?Bt:function(){const e=function(e,t){this.message=e||"",this.name=t||"Error",Error.captureStackTrace&&Error.captureStackTrace(this,this.constructor)};return Object.defineProperty(e.prototype=Object.create(Error.prototype),"constructor",{value:e,writable:!0,configurable:!0}),e}();function It(e,t,r,o,i,a){const s=U(e),l=Xe(t);e._disturbed=!0;

2let u=!1,c=h(void 0);return f(((d,g)=>{let v;if(void 0!==a){if(v=()=>{const r=new Ft("Aborted","AbortError"),n=[];o||n.push((()=>"writable"===t._state?et(t,r):h(void 0))),i||n.push((()=>"readable"===e._state?sr(e,r):h(void 0))),C((()=>Promise.all(n.map((e=>e())))),!0,r)},a.aborted)return void v();a.addEventListener("abort",v)}var S,R,T;if(q(e,s._closedPromise,(e=>{o?k(!0,e):C((()=>et(t,e)),!0,e)})),q(t,l._closedPromise,(t=>{i?k(!0,t):C((()=>sr(e,t)),!0,t)})),S=e,R=s._closedPromise,T=()=>{r?k():C((()=>function(e){const t=e._ownerWritableStream,r=t._state;return it(t)||"closed"===r?h(void 0):"errored"===r?_(t._storedError):ct(e)}(l)))},"closed"===S._state?T():m(R,T),it(t)||"closed"===t._state){const t=new TypeError("the destination writable stream closed before all data could be piped to it");i?k(!0,t):C((()=>sr(e,t)),!0,t)}function P(){const e=c;return b(c,(()=>e!==c?P():void 0))}function q(e,t,r){"errored"===e._state?r(e._storedError):y(t,r)}function C(e,r,o){function n(){p(e(),(()=>O(r,o)),(e=>O(!0,e)))}u||(u=!0,"writable"!==t._state||it(t)?n():m(P(),n))}function k(e,r){u||(u=!0,"writable"!==t._state||it(t)?O(e,r):m(P(),(()=>O(e,r))))}function O(e,t){ft(l),E(s),void 0!==a&&a.removeEventListener("abort",v),e?g(t):d(void 0)}w(f(((e,t)=>{!function r(o){o?e():b(u?h(!0):b(l._readyPromise,(()=>f(((e,t)=>{te(s,{_chunkSteps:t=>{c=b(ht(l,t),void 0,n),e(!1)},_closeSteps:()=>e(!0),_errorSteps:t})})))),r,t)}(!1)})))}))}class Lt{constructor(){throw new TypeError("Illegal constructor")}get desiredSize(){if(!Mt(this))throw Gt("desiredSize");return Ht(this)}close(){if(!Mt(this))throw Gt("close");if(!Vt(this))throw new TypeError("The stream is not in a state that permits close");Nt(this)}enqueue(e){if(!Mt(this))throw Gt("enqueue");if(!Vt(this))throw new TypeError("The stream is not in a state that permits enqueue");return Qt(this,e)}error(e){if(!Mt(this))throw Gt("error");Yt(this,e)}[B](e){fe(this);const t=this._cancelAlgorithm(e);return xt(this),t}[F](e){const t=this._controlledReadableStream;if(this._queue.length>0){const r=ce(this);this._closeRequested&&0===this._queue.length?(xt(this),lr(t)):$t(this),e._chunkSteps(r)}else G(t,e),$t(this)}}function Mt(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_controlledReadableStream")}function $t(e){Dt(e)&&(e._pulling?e._pullAgain=!0:(e._pulling=!0,p(e._pullAlgorithm(),(()=>{e._pulling=!1,e._pullAgain&&(e._pullAgain=!1,$t(e))}),(t=>{Yt(e,t)}))))}function Dt(e){const t=e._controlledReadableStream;return!!Vt(e)&&(!!e._started&&(!!(ar(t)&&J(t)>0)||Ht(e)>0))}function xt(e){e._pullAlgorithm=void 0,e._cancelAlgorithm=void 0,e._strategySizeAlgorithm=void 0}function Nt(e){if(!Vt(e))return;const t=e._controlledReadableStream;e._closeRequested=!0,0===e._queue.length&&(xt(e),lr(t))}function Qt(e,t){if(!Vt(e))return;const r=e._controlledReadableStream;if(ar(r)&&J(r)>0)X(r,t,!1);else{let r;try{r=e._strategySizeAlgorithm(t)}catch(t){throw Yt(e,t),t}try{de(e,t,r)}catch(t){throw Yt(e,t),t}}$t(e)}function Yt(e,t){const r=e._controlledReadableStream;"readable"===r._state&&(fe(e),xt(e),ur(r,t))}function Ht(e){const t=e._controlledReadableStream._state;return"errored"===t?null:"closed"===t?0:e._strategyHWM-e._queueTotalSize}function Vt(e){const t=e._controlledReadableStream._state;return!e._closeRequested&&"readable"===t}function Ut(e,t,r,o,n,i,a){t._controlledReadableStream=e,t._queue=void 0,t._queueTotalSize=void 0,fe(t),t._started=!1,t._closeRequested=!1,t._pullAgain=!1,t._pulling=!1,t._strategySizeAlgorithm=a,t._strategyHWM=i,t._pullAlgorithm=o,t._cancelAlgorithm=n,e._readableStreamController=t,p(h(r()),(()=>{t._started=!0,$t(t)}),(e=>{Yt(t,e)}))}function Gt(e){return new TypeError(`ReadableStreamDefaultController.prototype.${e} can only be used on a ReadableStreamDefaultController`)}function Xt(e,t,r){return $(e,r),r=>R(e,t,[r])}function Jt(e,t,r){return $(e,r),r=>R(e,t,[r])}function Kt(e,t,r){return $(e,r),r=>S(e,t,[r])}function Zt(e,t){if("bytes"!=(e=""+e))throw new TypeError(`${t} '${e}' is not a valid enumeration value for ReadableStreamType`);return e}function er(e,t){if("byob"!=(e=""+e))throw new TypeError(`${t} '${e}' is not a valid enumeration value for ReadableStreamReaderMode`);return e}function tr(e,t){M(e,t);const r=null==e?void 0:e.preventAbort,o=null==e?void 0:e.preventCancel,n=null==e?void 0:e.preventClose,i=null==e?void 0:e.signal;return void 0!==i&&function(e,t){if(!function(e){if("object"!=typeof e||null===e)return!1;try{return"boolean"==typeof e.aborted}catch(e){return!1}}(e))throw new TypeError(t+" is not an AbortSignal.")}(i,t+" has member 'signal' that"),{preventAbort:!!r,preventCancel:!!o,preventClose:!!n,signal:i}}Object.defineProperties(Lt.prototype,{close:{enumerable:!0},enqueue:{enumerable:!0},error:{enumerable:!0},desiredSize:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(Lt.prototype,o.toStringTag,{value:"ReadableStreamDefaultController",configurable:!0});class rr{constructor(e={},t={}){void 0===e?e=null:D(e,"First parameter");const r=xe(t,"Second parameter"),o=function(e,t){M(e,t);const r=e,o=null==r?void 0:r.autoAllocateChunkSize,n=null==r?void 0:r.cancel,i=null==r?void 0:r.pull,a=null==r?void 0:r.start,s=null==r?void 0:r.type;return{autoAllocateChunkSize:void 0===o?void 0:H(o,t+" has member 'autoAllocateChunkSize' that"),cancel:void 0===n?void 0:Xt(n,r,t+" has member 'cancel' that"),pull:void 0===i?void 0:Jt(i,r,t+" has member 'pull' that"),start:void 0===a?void 0:Kt(a,r,t+" has member 'start' that"),type:void 0===s?void 0:Zt(s,t+" has member 'type' that")}}(e,"First parameter");if(nr(this),"bytes"===o.type){if(void 0!==r.size)throw new RangeError("The strategy for a byte stream cannot have a size function");!function(e,t,r){const o=Object.create(be.prototype);let n=()=>{},i=()=>h(void 0),a=()=>h(void 0);void 0!==t.start&&(n=()=>t.start(o)),void 0!==t.pull&&(i=()=>t.pull(o)),void 0!==t.cancel&&(a=e=>t.cancel(e));const s=t.autoAllocateChunkSize;if(0===s)throw new TypeError("autoAllocateChunkSize must be greater than 0");!function(e,t,r,o,n,i,a){t._controlledReadableByteStream=e,t._pullAgain=!1,t._pulling=!1,t._byobRequest=null,t._queue=t._queueTotalSize=void 0,fe(t),t._closeRequested=!1,t._started=!1,t._strategyHWM=i,t._pullAlgorithm=o,t._cancelAlgorithm=n,t._autoAllocateChunkSize=a,t._pendingPullIntos=new T,e._readableStreamController=t,p(h(r()),(()=>{t._started=!0,ye(t)}),(e=>{Oe(t,e)}))}(e,o,n,i,a,r,s)}(this,o,$e(r,0))}else{const e=De(r);!function(e,t,r,o){const n=Object.create(Lt.prototype);let i=()=>{},a=()=>h(void 0),s=()=>h(void 0);void 0!==t.start&&(i=()=>t.start(n)),void 0!==t.pull&&(a=()=>t.pull(n)),void 0!==t.cancel&&(s=e=>t.cancel(e)),Ut(e,n,i,a,s,r,o)}(this,o,$e(r,1),e)}}get locked(){if(!ir(this))throw cr("locked");return ar(this)}cancel(e){return ir(this)?ar(this)?_(new TypeError("Cannot cancel a stream that already has a reader")):sr(this,e):_(cr("cancel"))}getReader(e){if(!ir(this))throw cr("getReader");return void 0===function(e,t){M(e,t);const r=null==e?void 0:e.mode;return{mode:void 0===r?void 0:er(r,t+" has member 'mode' that")}}(e,"First parameter").mode?U(this):new Ie(this)}pipeThrough(e,t={}){if(!ir(this))throw cr("pipeThrough");x(e,1,"pipeThrough");const r=function(e,t){M(e,t);const r=null==e?void 0:e.readable;N(r,"readable","ReadableWritablePair"),V(r,t+" has member 'readable' that");const o=null==e?void 0:e.writable;return N(o,"writable","ReadableWritablePair"),Ue(o,t+" has member 'writable' that"),{readable:r,writable:o}}(e,"First parameter"),o=tr(t,"Second parameter");if(ar(this))throw new TypeError("ReadableStream.prototype.pipeThrough cannot be used on a locked ReadableStream");if(Ze(r.writable))throw new TypeError("ReadableStream.prototype.pipeThrough cannot be used on a locked WritableStream");return w(It(this,r.writable,o.preventClose,o.preventAbort,o.preventCancel,o.signal)),r.readable}pipeTo(e,t={}){if(!ir(this))return _(cr("pipeTo"));if(void 0===e)return _("Parameter 1 is required in 'pipeTo'.");if(!Ke(e))return _(new TypeError("ReadableStream.prototype.pipeTo's first argument must be a WritableStream"));let r;try{r=tr(t,"Second parameter")}catch(e){return _(e)}return ar(this)?_(new TypeError("ReadableStream.prototype.pipeTo cannot be used on a locked ReadableStream")):Ze(e)?_(new TypeError("ReadableStream.prototype.pipeTo cannot be used on a locked WritableStream")):It(this,e,r.preventClose,r.preventAbort,r.preventCancel,r.signal)}tee(){if(!ir(this))throw cr("tee");const e=function(e,t){const r=U(e);

2let o,n,i,a,s,l=!1,u=!1,c=!1;const d=f((e=>{s=e}));function _(){return l||(l=!0,te(r,{_chunkSteps:e=>{v((()=>{l=!1;const t=e,r=e;u||Qt(i._readableStreamController,t),c||Qt(a._readableStreamController,r)}))},_closeSteps:()=>{l=!1,u||Nt(i._readableStreamController),c||Nt(a._readableStreamController),u&&c||s(void 0)},_errorSteps:()=>{l=!1}})),h(void 0)}function b(){}return i=or(b,_,(function(t){if(u=!0,o=t,c){const t=he([o,n]),r=sr(e,t);s(r)}return d})),a=or(b,_,(function(t){if(c=!0,n=t,u){const t=he([o,n]),r=sr(e,t);s(r)}return d})),y(r._closedPromise,(e=>{Yt(i._readableStreamController,e),Yt(a._readableStreamController,e),u&&c||s(void 0)})),[i,a]}(this);return he(e)}values(e){if(!ir(this))throw cr("values");return function(e,t){const r=U(e),o=new ne(r,t),n=Object.create(ie);return n._asyncIteratorImpl=o,n}(this,function(e,t){return M(e,"First parameter"),{preventCancel:!!(null==e?void 0:e.preventCancel)}}(e).preventCancel)}}function or(e,t,r,o=1,n=(()=>1)){const i=Object.create(rr.prototype);return nr(i),Ut(i,Object.create(Lt.prototype),e,t,r,o,n),i}function nr(e){e._state="readable",e._reader=void 0,e._storedError=void 0,e._disturbed=!1}function ir(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_readableStreamController")}function ar(e){return void 0!==e._reader}function sr(e,t){return e._disturbed=!0,"closed"===e._state?h(void 0):"errored"===e._state?_(e._storedError):(lr(e),g(e._readableStreamController[B](t),n))}function lr(e){e._state="closed";const t=e._reader;void 0!==t&&(j(t),ee(t)&&(t._readRequests.forEach((e=>{e._closeSteps()})),t._readRequests=new T))}function ur(e,t){e._state="errored",e._storedError=t;const r=e._reader;void 0!==r&&(W(r,t),ee(r)?(r._readRequests.forEach((e=>{e._errorSteps(t)})),r._readRequests=new T):(r._readIntoRequests.forEach((e=>{e._errorSteps(t)})),r._readIntoRequests=new T))}function cr(e){return new TypeError(`ReadableStream.prototype.${e} can only be used on a ReadableStream`)}function dr(e,t){M(e,t);const r=null==e?void 0:e.highWaterMark;return N(r,"highWaterMark","QueuingStrategyInit"),{highWaterMark:Q(r)}}Object.defineProperties(rr.prototype,{cancel:{enumerable:!0},getReader:{enumerable:!0},pipeThrough:{enumerable:!0},pipeTo:{enumerable:!0},tee:{enumerable:!0},values:{enumerable:!0},locked:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(rr.prototype,o.toStringTag,{value:"ReadableStream",configurable:!0}),"symbol"==typeof o.asyncIterator&&Object.defineProperty(rr.prototype,o.asyncIterator,{value:rr.prototype.values,writable:!0,configurable:!0});const fr=function(e){return e.byteLength};class hr{constructor(e){x(e,1,"ByteLengthQueuingStrategy"),e=dr(e,"First parameter"),this._byteLengthQueuingStrategyHighWaterMark=e.highWaterMark}get highWaterMark(){if(!br(this))throw _r("highWaterMark");return this._byteLengthQueuingStrategyHighWaterMark}get size(){if(!br(this))throw _r("size");return fr}}function _r(e){return new TypeError(`ByteLengthQueuingStrategy.prototype.${e} can only be used on a ByteLengthQueuingStrategy`)}function br(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_byteLengthQueuingStrategyHighWaterMark")}Object.defineProperties(hr.prototype,{highWaterMark:{enumerable:!0},size:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(hr.prototype,o.toStringTag,{value:"ByteLengthQueuingStrategy",configurable:!0});const pr=function(){return 1};class mr{constructor(e){x(e,1,"CountQueuingStrategy"),e=dr(e,"First parameter"),this._countQueuingStrategyHighWaterMark=e.highWaterMark}get highWaterMark(){if(!gr(this))throw yr("highWaterMark");return this._countQueuingStrategyHighWaterMark}get size(){if(!gr(this))throw yr("size");return pr}}function yr(e){return new TypeError(`CountQueuingStrategy.prototype.${e} can only be used on a CountQueuingStrategy`)}function gr(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_countQueuingStrategyHighWaterMark")}function wr(e,t,r){return $(e,r),r=>R(e,t,[r])}function vr(e,t,r){return $(e,r),r=>S(e,t,[r])}function Sr(e,t,r){return $(e,r),(r,o)=>R(e,t,[r,o])}Object.defineProperties(mr.prototype,{highWaterMark:{enumerable:!0},size:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(mr.prototype,o.toStringTag,{value:"CountQueuingStrategy",configurable:!0});class Rr{constructor(e={},t={},r={}){void 0===e&&(e=null);const o=xe(t,"Second parameter"),n=xe(r,"Third parameter"),i=function(e,t){M(e,t);const r=null==e?void 0:e.flush,o=null==e?void 0:e.readableType,n=null==e?void 0:e.start,i=null==e?void 0:e.transform,a=null==e?void 0:e.writableType;return{flush:void 0===r?void 0:wr(r,e,t+" has member 'flush' that"),readableType:o,start:void 0===n?void 0:vr(n,e,t+" has member 'start' that"),transform:void 0===i?void 0:Sr(i,e,t+" has member 'transform' that"),writableType:a}}(e,"First parameter");if(void 0!==i.readableType)throw new RangeError("Invalid readableType specified");if(void 0!==i.writableType)throw new RangeError("Invalid writableType specified");const a=$e(n,0),s=De(n),l=$e(o,1),u=De(o);let c;!function(e,t,r,o,n,i){function a(){return t}e._writable=function(e,t,r,o,n=1,i=(()=>1)){const a=Object.create(Ge.prototype);return Je(a),pt(a,Object.create(bt.prototype),e,t,r,o,n,i),a}(a,(function(t){return function(e,t){const r=e._transformStreamController;return e._backpressure?g(e._backpressureChangePromise,(()=>{const o=e._writable;if("erroring"===o._state)throw o._storedError;return jr(r,t)})):jr(r,t)}(e,t)}),(function(){return function(e){const t=e._readable,r=e._transformStreamController,o=r._flushAlgorithm();return Or(r),g(o,(()=>{if("errored"===t._state)throw t._storedError;Nt(t._readableStreamController)}),(r=>{throw Pr(e,r),t._storedError}))}(e)}),(function(t){return function(e,t){return Pr(e,t),h(void 0)}(e,t)}),r,o),e._readable=or(a,(function(){return function(e){return Er(e,!1),e._backpressureChangePromise}(e)}),(function(t){return qr(e,t),h(void 0)}),n,i),e._backpressure=void 0,e._backpressureChangePromise=void 0,e._backpressureChangePromise_resolve=void 0,Er(e,!0),e._transformStreamController=void 0}(this,f((e=>{c=e})),l,u,a,s),function(e,t){const r=Object.create(Cr.prototype);let o=e=>{try{return Wr(r,e),h(void 0)}catch(e){return _(e)}},n=()=>h(void 0);void 0!==t.transform&&(o=e=>t.transform(e,r)),void 0!==t.flush&&(n=()=>t.flush(r)),function(e,t,r,o){t._controlledTransformStream=e,e._transformStreamController=t,t._transformAlgorithm=r,t._flushAlgorithm=o}(e,r,o,n)}(this,i),void 0!==i.start?c(i.start(this._transformStreamController)):c(void 0)}get readable(){if(!Tr(this))throw zr("readable");return this._readable}get writable(){if(!Tr(this))throw zr("writable");return this._writable}}function Tr(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_transformStreamController")}function Pr(e,t){Yt(e._readable._readableStreamController,t),qr(e,t)}function qr(e,t){Or(e._transformStreamController),wt(e._writable._writableStreamController,t),e._backpressure&&Er(e,!1)}function Er(e,t){void 0!==e._backpressureChangePromise&&e._backpressureChangePromise_resolve(),e._backpressureChangePromise=f((t=>{e._backpressureChangePromise_resolve=t})),e._backpressure=t}Object.defineProperties(Rr.prototype,{readable:{enumerable:!0},writable:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(Rr.prototype,o.toStringTag,{value:"TransformStream",configurable:!0});class Cr{constructor(){throw new TypeError("Illegal constructor")}get desiredSize(){if(!kr(this))throw Ar("desiredSize");return Ht(this._controlledTransformStream._readable._readableStreamController)}enqueue(e){if(!kr(this))throw Ar("enqueue");Wr(this,e)}error(e){if(!kr(this))throw Ar("error");var t;t=e,Pr(this._controlledTransformStream,t)}terminate(){if(!kr(this))throw Ar("terminate");!function(e){const t=e._controlledTransformStream;Nt(t._readable._readableStreamController),qr(t,new TypeError("TransformStream terminated"))}(this)}}function kr(e){return!!a(e)&&!!Object.prototype.hasOwnProperty.call(e,"_controlledTransformStream")}function Or(e){e._transformAlgorithm=void 0,e._flushAlgorithm=void 0}function Wr(e,t){const r=e._controlledTransformStream,o=r._readable._readableStreamController;if(!Vt(o))throw new TypeError("Readable side is not in a state that permits enqueue");try{Qt(o,t)}catch(e){throw qr(r,e),r._readable._storedError}(function(e){return!Dt(e)})(o)!==r._backpressure&&Er(r,!0)}function jr(e,t){return g(e._transformAlgorithm(t),void 0,(t=>{throw Pr(e._controlledTransformStream,t),t}))}function Ar(e){return new TypeError(`TransformStreamDefaultController.prototype.${e} can only be used on a TransformStreamDefaultController`)}function zr(e){return new TypeError(`TransformStream.prototype.${e} can only be used on a TransformStream`)}Object.defineProperties(Cr.prototype,{enqueue:{enumerable:!0},error:{enumerable:!0},terminate:{enumerable:!0},desiredSize:{enumerable:!0}}),"symbol"==typeof o.toStringTag&&Object.defineProperty(Cr.prototype,o.toStringTag,{value:"TransformStreamDefaultController",configurable:!0})}}]);