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