;3h"UddlZddlZddlZddlmZddlmZmZmZm Z m Z m Z ejdk\rddl mZnddlmZeeeddfZ ddlZd Zd ZGd d e ZGdde ZGdde ZGdde d ZGddZeeZeed<deddfdZ d&deede de!fdZ"GddZ#Gd d!e#Z$Gd"d#e#Z%Gd$d%Z&y#e$rddlZYwxYw#e$rd ZYwxYw)'N)Executor)AnyFinalOptionalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TFic.eZdZdedefdZddedefdZy)ZLibCompressObjProtocoldatareturncyNselfrs Y/var/www/html/audio-gradio/venv/lib/python3.12/site-packages/aiohttp/compression_utils.pycompressz ZLibCompressObjProtocol.compressmodecyrrrrs rflushzZLibCompressObjProtocol.flushrrN.)__name__ __module__ __qualname__r bytesrintrrrrrrs2V225#555rrcJeZdZd dededefdZd dedefdZede fdZ y) ZLibDecompressObjProtocolr max_lengthrcyrrrrr's r decompressz$ZLibDecompressObjProtocol.decompress!rrlengthcyrrrr+s rrzZLibDecompressObjProtocol.flush"rrcyrrrs reofzZLibDecompressObjProtocol.eof$srNr) r r!r"r r$r#r*rpropertyboolr0rrrr&r& s4KvK3KK7C7U7 Trr&ceZdZUeed<eed<eed<eed<eed< ddededed ed ed eed efd Z dded ed e fdZ ddededed e fdZ ddededed e fdZ y)ZLibBackendProtocol MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISHlevelmethodwbitsmemLevelstrategyzdictrcyrr)rr:r;r<r=r>r?s r compressobjzZLibBackendProtocol.compressobj/s#&rcyrr)rr<r?s r decompressobjz!ZLibBackendProtocol.decompressobj8s$'rrcyrr)rrr:r<s rrzZLibBackendProtocol.compress<rbufsizecyrr)rrr<rFs rr*zZLibBackendProtocol.decompress?rErN)......)..)r r!r"r$__annotations__rr rrAr&rCr#rr*rrrr4r4(sNM"%&&& &  &  && !&14(('-( "( ?B&)8; AD&):= rr4c,eZdZUeed<eed<eed<y)CompressObjArgsr<r>r:N)r r!r"r$rHrrrrJrJDs JM JrrJ)totalceZdZdefdZedefdZedefdZ edefdZ edefdZ edefdZ edefd Z d ed edefd Zd ed edefd Zded ed edefdZded ed edefdZdedefdZy)ZLibBackendWrapper _zlib_backendc||_yr)rN)rrNs r__init__zZLibBackendWrapper.__init__Ks 2?rrc0t|jddS)Nr undefinedgetattrrNr/s rnamezZLibBackendWrapper.nameNst)):{CCrc.|jjSr)rNr5r/s rr5zZLibBackendWrapper.MAX_WBITSRs!!+++rc.|jjSr)rNr6r/s rr6zZLibBackendWrapper.Z_FULL_FLUSHV!!...rc.|jjSr)rNr7r/s rr7zZLibBackendWrapper.Z_SYNC_FLUSHZrXrc.|jjSr)rNr8r/s rr8zZLibBackendWrapper.Z_BEST_SPEED^rXrc.|jjSr)rNr9r/s rr9zZLibBackendWrapper.Z_FINISHbs!!***rargskwargsc:|jj|i|Sr)rNrArr\r]s rrAzZLibBackendWrapper.compressobjfs -t!!--t>v>>rc:|jj|i|Sr)rNrCr_s rrCz ZLibBackendWrapper.decompressobjis /t!!//@@@rrcB|jj|g|i|Sr)rNrrrr\r]s rrzZLibBackendWrapper.compressls%*t!!**4A$A&AArcB|jj|g|i|Sr)rNr*rbs rr*zZLibBackendWrapper.decompressos%,t!!,,TCDCFCCrattrnamec.t|j|SrrS)rrds r __getattr__zZLibBackendWrapper.__getattr__sst))844rN)r r!r"r4rPr1strrUr$r5r6r7r8r9rrrAr&rCr r#rr*rfrrrrMrMJsO@&9@DcDD,3,,/c///c///c//+#++???8O?A3A#A:SABVBCB3B5BDvDcDSDUD5C5C5rrM ZLibBackendnew_zlib_backendrc|t_yr)rhrN)ris rset_zlib_backendrkzs 0Krencodingsuppress_deflate_headercx|dk(rdtjzS|rtj StjS)Ngzip)rhr5)rlrms rencoding_to_moderq~s96K))))%rtruc4t || t||n|||ttj |_i}|j |d<|||d<|||d<|j jdi||_tj|_ y)Nrrtrur<r>r:r) superrPrqrMrhrNrwrA _compressorasyncioLock_compress_lock) rrlrmr:r<r>rtrur] __class__s rrPzZLibCompressor.__init__s =!+BC 3  %7{7P7P$Q"$**w  !)F:   #F7O94--99CFC%llnrrrc8|jj|Sr)rrrs r compress_synczZLibCompressor.compress_syncs((..rcK|j4d{|jtt||jkDr\tjj |j |jj|d{cdddd{S|j|cdddd{S7797+7 #1d{7swYyxYww)aCCompress the data and returned the compressed bytes. Note that flush() must be called after the last call to compress() If the data size is large than the max_sync_chunk_size, the compression will be done in the executor. Otherwise, the compression will be done in the event loop. N) rrylenrget_running_looprun_in_executorrxrrrrs rrzZLibCompressor.compresss&& , , ))5I 9 99$557GGNND$4$4$=$=t , , ,%%d+ , , , , , , , ,suCB:CA+CB<C CB>CC( C4C5C<C>CCCC CCrcp|jj||S|jjSr)rrrNr9rs rrzZLibCompressor.flushs<%%$D  *.*<*<*E*E  rr)r r!r"rzrrgr2r$rrPr#rrr __classcell__rs@rr|r|s#'(-##"&'+-@-3--"&-} - } - 3- -8$-&c]-</%/E/,5,U,. (3- 5 rr|c eZdZdddefdeededeedeeffd Z dde d ed e fd Z dde d ed e fd Z dd ed e fdZ ed efdZxZS)ZLibDecompressorNFrlrmrtruct|t||||ttj |_|j j |j|_y)Nr~)r<) rrPrqrMrhrNrCrw _decompressor)rrlrmrtrurs rrPzZLibDecompressor.__init__s] !(,CD 3  %7{7P7P$Q!//==DJJ=Orrr'rc:|jj||Sr)rr*r)s rdecompress_syncz ZLibDecompressor.decompress_syncs!!,,T:>>rcK|jdt||jkDrLtjj |j |j j||d{S|j||S7w)zDecompress the data and return the decompressed bytes. If the data size is large than the max_sync_chunk_size, the decompression will be done in the executor. Otherwise, the decompression will be done in the event loop. N) ryrrrrrxrr*rr)s rr*zZLibDecompressor.decompresssz  % % 1D D555 113CC 2 2 = =tZ ##D*55sA,B.B/Br+cv|dkDr|jj|S|jjS)Nr)rrr-s rrzZLibDecompressor.flushs?z    $ $V , ##))+ rc.|jjSr)rr0r/s rr0zZLibDecompressor.eofs!!%%%r)r)r r!r"rzrrgr2rr$rPr#rr*rr1r0rrs@rrrs#'(-'+-@ P3- P"& P8$ P &c] P?E?s?5?6U66E6  C  &T&&rrc0eZdZddZdedefdZdefdZy)BrotliDecompressorrNcXts tdtj|_y)NzIThe brotli decompression is not available. Please install `Brotli` module) HAS_BROTLI RuntimeErrorbrotli Decompressor_objr/s rrPzBrotliDecompressor.__init__s)1 '') rrct|jdr)tt|jj |Stt|jj |S)Nr*)hasattrrr r#r*processrs rrz"BrotliDecompressor.decompress_syncsH 499l +tyy33D9: :E499,,T233rct|jdr(tt|jj Sy)Nrr)rrr r#rr/s rrzBrotliDecompressor.flushs+ 499g &tyy01 1r)rN)r r!r"rPr#rrrrrrrs&*4E4e4 urr)NF)'rsyszlibconcurrent.futuresrtypingrrrrrr version_infocollections.abcr r r# bytearray brotlicffir ImportErrorrrzrr&r4rJrMrhrHrkrgr2r$rqrsr|rrrrrrsF 'BBw& 5)%68KK LF#J6h6 (8iu *5*5Z#5T": :1':1t1 #$)XsmX!X X 8 8< _< ~,&,&^c Js0 CC* C'$C*&C''C**C43C4