rp0j=|%SSKrSSKrSSKrSSKJrJr SSKJr SSKJ r J r J r J r J r \RS:aSSKJr OSSKJr \\\SS 4rSSKrS r\RS :aSS KJr OSS KJr S rSrSrSr"SS\ 5r"SS\ 5r "SS\ 5r!"SS\ S S9r""SS5r#\#"\5r$\#\%S'S\!SS4Sjr&S,S\'S-S \(S\)4S!jjr*"S"S#\5r+"S$S%5r,"S&S'\+5r-"S(S)\+5r."S*S+\+5r/g!\a SSKrNf=f!\a S rNf=f!\a S rNf=f)-N)ABCabstractmethod)Executor)AnyFinalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)r )ZstdDecompressoric<\rSrSrS\S\4SjrS S\S\4SjjrSr g) ZLibCompressObjProtocol+datareturncgNselfrs S/home/wildlama/miniconda3/lib/python3.13/site-packages/aiohttp/compression_utils.pycompress ZLibCompressObjProtocol.compress,ssmodecgrrrr s rflushZLibCompressObjProtocol.flush-s#rrN.) __name__ __module__ __qualname____firstlineno__r bytesrintr#__static_attributes__rrrrr+s2V225#5555rrc\rSrSrS S\S\S\4SjjrS S\S\4Sjjr\ S\ 4Sj5r \ S\4S j5r \ S\4S j5r S rg )ZLibDecompressObjProtocol0r max_lengthrcgrrrrr0s r decompress$ZLibDecompressObjProtocol.decompress1srlengthcgrrrr5s rr#ZLibDecompressObjProtocol.flush2sCrcgrrrs reofZLibDecompressObjProtocol.eof4srcgrrr:s runconsumed_tail)ZLibDecompressObjProtocol.unconsumed_tail7s(+rcgrrr:s r unused_data%ZLibDecompressObjProtocol.unused_data:s$'rrNr%)r&r'r(r)r r+r*r3r#propertyboolr;r>rAr,rrrr.r.0sZKvK3KK7C7U7 T +++ 'U''rr.c\rSrSr%\\S'\\S'\\S'\\S'\\S'SS\S\S \S \S \S \S -S\4SjjrSS \S \S\ 4Sjjr SS\S \S\S\ 4Sjjr SS \S\S\S\ 4Sjjr Srg )ZLibBackendProtocol> MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISHlevelmethodwbitsmemLevelstrategyzdictNrcgrr)rrMrNrOrPrQrRs r compressobjZLibBackendProtocol.compressobjEs#&rcgrr)rrOrRs r decompressobj!ZLibBackendProtocol.decompressobjNs$'rrcgrr)rrrMrOs rrZLibBackendProtocol.compressRrbufsizecgrr)rrrOr\s rr3ZLibBackendProtocol.decompressUr[rr)......)..)r&r'r(r)r+__annotations__r rrTr.rWr*rr3r,rrrrFrF>sNM"&&& &  &  &}& !&14(('-( "( ?B&)8; AD&):= rrFc4\rSrSr%\\S'\\S'\\S'Srg)CompressObjArgsZrOrQrMrN)r&r'r(r)r+r_r,rrrraraZs JM Jrra)totalc$\rSrSrS\4Sjr\S\4Sj5r\S\ 4Sj5r \S\ 4Sj5r \S\ 4Sj5r \S\ 4S j5r \S\ 4S j5rS \S \S\4S jrS \S \S\4SjrS\S \S \S\4SjrS\S \S \S\4SjrS\S\4SjrSrg)ZLibBackendWrapper` _zlib_backendcXlgrrg)rrgs r__init__ZLibBackendWrapper.__init__as2?rrc0[URSS5$)Nr& undefinedgetattrrgr:s rnameZLibBackendWrapper.namedst)):{CCrc.URR$r)rgrHr:s rrHZLibBackendWrapper.MAX_WBITShs!!+++rc.URR$r)rgrIr:s rrIZLibBackendWrapper.Z_FULL_FLUSHl!!...rc.URR$r)rgrJr:s rrJZLibBackendWrapper.Z_SYNC_FLUSHprvrc.URR$r)rgrKr:s rrKZLibBackendWrapper.Z_BEST_SPEEDtrvrc.URR$r)rgrLr:s rrLZLibBackendWrapper.Z_FINISHxs!!***rargskwargsc:URR"U0UD6$r)rgrTrr}r~s rrTZLibBackendWrapper.compressobj|s!!--t>v>>rc:URR"U0UD6$r)rgrWrs rrW ZLibBackendWrapper.decompressobjs!!//@@@rrcBURR"U/UQ70UD6$r)rgrrrr}r~s rrZLibBackendWrapper.compresss#!!**4A$A&AArcBURR"U/UQ70UD6$r)rgr3rs rr3ZLibBackendWrapper.decompresss#!!,,TCDCFCCrattrnamec.[URU5$rrn)rrs r __getattr__ZLibBackendWrapper.__getattr__st))844rriN)r&r'r(r)rFrjrCstrrpr+rHrIrJrKrLrrrTr.rWr r*rr3rr,rrrrere`sO@&9@DcDD,3,,/c///c///c//+#++???8O?A3A#A:SABVBCB3B5BDvDcDSDUD5C5C5rre ZLibBackendnew_zlib_backendrcU[lgr)rrg)rs rset_zlib_backendrs 0Krencodingsuppress_deflate_headercUS:XaS[R-$U(a[R*$[R$)Ngzip)rrH)rrs rencoding_to_moders96K))))%&A<'A>cg)z7Return True if more output is available by passing b"".Nrr:s rdata_available'DecompressionBaseHandler.data_availablerrr)r&r'r(r)MAX_SYNC_CHUNK_SIZErr+rjrZLIB_MAX_LENGTH_UNLIMITEDr r*rr3rCrDrr,rrrrrs%)*=8T/8!4Z8.G))(+) )) /H 6 6(+ 6  6FFFrrc\rSrSrSSSSSS\4S\S-S\S\S-S\S-S\S-S \S-S \S-4S jjr S \ S \ 4Sjr S \ S \ 4Sjr SS\S-S \ 4SjjrSrg)ZLibCompressorNFrrrMrOrQrrcX`lXplUc [X5OUUl[ [ R 5Ul0nURUS'UbXXS'UbX8S'UR R"S0UD6Ulg)NrOrQrMr) rrr_modererrgrT _compressor) rrrrMrOrQrrr~s rrjZLibCompressor.__init__s"$7!} X ? %7{7P7P$Q"$**w  !):   #7O--99CFCrrrc8URRU5$r)rrrs r compress_syncZLibCompressor.compress_syncs((..rc0# URSL=(a [U5UR:nU(aL[R"5R UR UR RU5IShvN $URU5$N7f)aCompress 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. **WARNING: This method is NOT cancellation-safe when used with flush().** If this operation is cancelled, the compressor state may be corrupted. The connection MUST be closed after cancellation to avoid data corruption in subsequent compress operations. For cancellation-safe compression (e.g., WebSocket), the caller MUST wrap compress() + flush() + send operations in a shield and lock to ensure atomicity. N) rrrget_running_looprrrrr)rrshould_use_executors rrZLibCompressor.compresss&  % %T 1 6D D555   113CC 0 0 9 94 !!$''sAB?Br crURRUbU5$URR5$)aFlush the compressor synchronously. **WARNING: This method is NOT cancellation-safe when called after compress().** The flush() operation accesses shared compressor state. If compress() was cancelled, calling flush() may result in corrupted data. The connection MUST be closed after compress() cancellation. For cancellation-safe compression (e.g., WebSocket), the caller MUST wrap compress() + flush() + send operations in a shield and lock to ensure atomicity. )rr#rgrLr"s rr#ZLibCompressor.flushs>%%$D  *.*<*<*E*E  r)rrrrrgr)r&r'r(r)rrrDr+rrjr r*rrr#r,rrrrrs $(-  #$(*=D*D"&DTz D Tz D * DT/D!4ZD6/&/U/(6(e(8  #*     rrc ^\rSrSrSSS\4S\S-S\S\S-S\S-4U4Sjjjr \ 4S \ S \S \ 4S jjr SS \S \ 4Sjjr\S \4Sj5r\S \4Sj5rSrU=r$)ZLibDecompressori NFrrrrc>[TU]X4S9 [X5Ul[ [ R 5UlUR RURS9UlSUl SUl g)NrrrOF) superrjrrrerrgrW _decompressor _last_empty_pending_unused_data)rrrrr __class__s rrjZLibDecompressor.__init__ sd (T%hH $6{7P7P$Q!//==DJJ=O 26!rrr0rcURbUR[U5-nSUlURRURRU-U5nUS:HUlURR (aURR(aURRnURRURS9UlU[:waU[U5-nUS::aX@lOaURRXB5nUS:HUlX5- nURR (aURR(aMURR (aLURURR:a(URRURS9UlU$)Nrrr)rr*rr3r>rr;rArgrWrrrrH)rrr0resultunusedchunks rr ZLibDecompressor.decompress_syncsu  $ $ 0,,uT{:D(,D %##..    . . 5z "S=   $$););)G)G''33F!%!3!3!A!A !A!SD 66c&k) ?06-&&11&EE$|D  OF  $$););)G)G)G    ! !djj43E3E3O3O&O!%!3!3!A!A !A!SD  rr5cxUS:aURRU5$URR5$Nr)rr#r7s rr#ZLibDecompressor.flush?s?z    $ $V , ##))+ rc[URR5=(d& UR(+=(d URSL$r)rDrr>rrr:s rrZLibDecompressor.data_availableFsA ##33 4 5### 5((4 rc.URR$r)rr;r:s rr;ZLibDecompressor.eofNs!!%%%r)rrrrrg)r)r&r'r(r)rrrDrr+rjrr r*rr#rCrr;r, __classcell__rs@rrr s $(-$(*= 7* 7"& 7T/ 7 !4Z 7 7/H""(+" "H C     &T&&rrc^\rSrSrS\4S\S-S\S-SS4U4Sjjjr\4S\ S\S\ 4S jjr S\ 4S jr \ S\4S j5rS rU=r$) BrotliDecompressoriSNrrrc>[(d [S5e[R"5UlSUl[ TU]XS9 g)z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` moduleFrN) HAS_BROTLI RuntimeErrorbrotli Decompressor_objrrrjrrrrs rrjBrotliDecompressor.__init__WsF z1 '')   (Trrr0c[URS5(a^U[:Xa*[[URR U55nO[[URR X55nO]U[:Xa*[[URR U55nO)[[URR X55nUS:HUlU$)rr3r)hasattrrrr r*r3processr)rrr0rs rr"BrotliDecompressor.decompress_syncfs 499l + +66eTYY%9%9$%?@eTYY%9%9$%KL66eTYY%6%6t%<=eTYY%6%6t%HI!S= rc[URS5(a([[URR 55$g)zFlush the decompressor.r#r)rrr r*r#r:s rr#BrotliDecompressor.flushxs. 499g & &tyy01 1rcpURR5(+=(a UR(+$r)r is_finishedrr:s rr!BrotliDecompressor.data_available~s&99((**C43C3C/CCr)rrr&r'r(r)rrr+rjrr r*rr#rCrDrr,rrs@rrrSs %)*= UT/ U!4Z U  U U /H(+ $u DDDrrc^\rSrSrS\4S\S-S\S-SS4U4Sjjjr\4S\ S\S\ 4S jjr S\ 4S jr \ S\4S j5rS rU=r$) ZSTDDecompressoriNrrrcx>[(d [S5e[5UlSUl[ TU]XS9 g)NzOThe zstd decompression is not available. Please install `backports.zstd` moduler)HAS_ZSTDrrrrrrjrs rrjZSTDDecompressor.__init__s@ x9 %& 26! (Trrr0cU[:Xa[OUnURbURU-nSUlURR X5nURR (aURR (aURR n[5UlU[:waU[U5-nUS::aXPlOUX@RR XS5- nURR (aURR (aMURR (a[5UlU$r) rZSTD_MAX_LENGTH_UNLIMITEDrrr3r;rArr)rrr0zstd_max_lengthrrAs rr ZSTDDecompressor.decompress_syncs66 &   $ $ 0,,t3D(,D %%%d<iimm 5 5))//K(*DI";;3v;."a'0;- ii**;H HFiimm 5 5 5 99==(*DI rcg)Nrrr:s rr#ZSTDDecompressor.flushsrcURR(+=(a URR(+=(d URSL$r)r needs_inputr;rr:s rrZSTDDecompressor.data_availables< %% % ;diimm*;3  & &d 2 3r)rrrrs@rrrs%)*= UT/ U!4Z U  U U/H$$(+$ $Lu333rr)NF)0rsyszlibabcrrconcurrent.futuresrtypingrrrr r version_infocollections.abcr rr* bytearray brotlicffir ImportErrorrcompression.zstdrbackports.zstdrrrrrr.rFrarerr_rrrDr+rrrrrrrrrr s #'88w& 5)%68KK LF#J 7"53H 6h6 ( ((8iu *5*5Z#5T": :1':1t1  $)XDjX!X X Fs FFH H VD&/D&N-D1-D`<3/<3c JHsBDD"D0 DD"DD""D-,D-0D;:D;