+ PV-j=aR&t-0t^RIt^RIt^RIt^RIHtHt^RIHt^RI H t H t H t H t Ht]PR'8d^RIHtM^RI Ht]]]RR3,t^RItR t]PR(8d^R IHtM^R IHtR tR t^tR)t!R R] 4t !RR] 4t!!RR] 4t"!RR] R R7t#!RR4t$]$!]4t%]^kRRlt&R*RRllt'!RR]4t(!RR4t)!R R!](4t*!R"R#](4t+!R$R%](4t,R# ]d^RItLi;i ]dR tLi;i ]dR tLi;i)+N)ABCabstractmethod)Executor)AnyFinalProtocol TypedDictcast)Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)ZstdDecompressoricHa]tRt^+toV3RlRltRV3RlRlltRtVtR#)ZLibCompressObjProtocolc&<V^8dQhRS[RS[/#datareturnr bytes)format __classdict__s"j/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/aiohttp/compression_utils.py __annotate__$ZLibCompressObjProtocol.__annotate__,s22V22cR#Nselfrs&&rcompress ZLibCompressObjProtocol.compress,ssrc&<V^8dQhRS[RS[/#)rmoderintr)rrs"rrr-s55#555rcR#rrr!r%s""rflushZLibCompressObjProtocol.flush-s#rrN.)__name__ __module__ __qualname____firstlineno__r"r*__static_attributes____classdictcell__rs@rrr+s22555rrca]tRt^0toR V3RlRlltR V3RlRllt]V3RlRl4t]V3RlRl4t]V3R lR l4t R t Vt R #)ZLibDecompressObjProtocolc,<V^8dQhRS[RS[RS[/#rr max_lengthrr r'r)rrs"rr&ZLibDecompressObjProtocol.__annotate__1sKKvK3KKrcR#rrr!rr8s&&&r decompress$ZLibDecompressObjProtocol.decompress1src&<V^8dQhRS[RS[/#rlengthrr&)rrs"rrr:2s77C7U7rcR#rrr!rAs""rr*ZLibDecompressObjProtocol.flush2sCrc <V^8dQhRS[/#rrbool)rrs"rrr:5sTrcR#rrr!s&reofZLibDecompressObjProtocol.eof4src <V^8dQhRS[/#rFr)rrs"rrr:8s+++rcR#rrrJs&runconsumed_tail)ZLibDecompressObjProtocol.unconsumed_tail7s(+rc <V^8dQhRS[/#rFrN)rrs"rrr:;s''U'rcR#rrrJs&r unused_data%ZLibDecompressObjProtocol.unused_data:s$'rrNr,) r-r.r/r0r=r*propertyrKrPrTr1r2r3s@rr5r50s;KK77  ++ ''rr5ca]tRt^>toR V3RlRlltR V3RlRlltR V3RlRlltR V3RlRlltV3R ltR t Vt R #)ZLibBackendProtocolcR<V^8dQhRS[RS[RS[RS[RS[RS[R,RS[/#) rlevelmethodwbitsmemLevelstrategyzdictNr)r'r r)rrs"rr ZLibBackendProtocol.__annotate__EsU&&&& &  &  &}& !&rcR#rr)r!rZr[r\r]r^r_s&&&&&&&r compressobjZLibBackendProtocol.compressobjEs#&rc,<V^8dQhRS[RS[RS[/#)rr\r_r)r'r r5)rrs"rrr`Ns%((('-( "(rcR#rr)r!r\r_s&&&r decompressobj!ZLibBackendProtocol.decompressobjNs$'rc2<V^8dQhRS[RS[RS[RS[/#)rrZr\rrr'r r)rrs"rrr`Rs-&)8; rcR#rr)r!rrZr\s""&&rr"ZLibBackendProtocol.compressRrc2<V^8dQhRS[RS[RS[RS[/#)rr\bufsizerrri)rrs"rrr`Us-&):= rcR#rr)r!rr\rns""&&rr=ZLibBackendProtocol.decompressUrlrcV<V^8dQh/S[;R&S[;R&S[;R&S[;R&S[;R&#)r MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISHr')rrs"rrr`>s@N  M rrN)......)..) r-r.r/r0rbrfr"r=__annotate_func__r1r2r3s@rrXrX>s4&&((/rrXc,a]tRt^ZtoV3RltRtVtR#)CompressObjArgsc><V^8dQh/S[;R&S[;R&S[;R&#)rr\r^rZrw)rrs"rrCompressObjArgs.__annotate__Zs% JM JrrN)r-r.r/r0rxr1r2r3s@rrzrzZsrrz)totalc4a]tRt^`toV3RlRlt]V3RlRl4t]V3RlRl4t]V3RlRl4t]V3R lR l4t ]V3R lR l4t ]V3R lRl4t V3RlRlt V3RlRlt V3RlRltV3RlRltV3RlRltRtVtR#)ZLibBackendWrapperc <V^8dQhRS[/#)r _zlib_backendrX)rrs"rrZLibBackendWrapper.__annotate__as@@&9@rcWnR#rr)r!rs&&r__init__ZLibBackendWrapper.__init__as2?rc <V^8dQhRS[/#rF)str)rrs"rrresDDcDrc0\VPRR4#)r- undefinedgetattrrrJs&rnameZLibBackendWrapper.namedst)):{CCrc <V^8dQhRS[/#rFrw)rrs"rrris,,3,rc.VPP#r)rrrrJs&rrrZLibBackendWrapper.MAX_WBITShs!!+++rc <V^8dQhRS[/#rFrw)rrs"rrrm//c/rc.VPP#r)rrsrJs&rrsZLibBackendWrapper.Z_FULL_FLUSHl!!...rc <V^8dQhRS[/#rFrw)rrs"rrrqrrc.VPP#r)rrtrJs&rrtZLibBackendWrapper.Z_SYNC_FLUSHprrc <V^8dQhRS[/#rFrw)rrs"rrrurrc.VPP#r)rrurJs&rruZLibBackendWrapper.Z_BEST_SPEEDtrrc <V^8dQhRS[/#rFrw)rrs"rrrys++#+rc.VPP#r)rrvrJs&rrvZLibBackendWrapper.Z_FINISHxs!!***rc,<V^8dQhRS[RS[RS[/#rargskwargsr)rr)rrs"rrr|s#????8O?rc:VPP!V/VB#r)rrbr!rrs&*,rrbZLibBackendWrapper.compressobj|s!!--t>v>>rc,<V^8dQhRS[RS[RS[/#r)rr5)rrs"rrrs(AA3A#A:SArc:VPP!V/VB#r)rrfrs&*,rrf ZLibBackendWrapper.decompressobjs!!//@@@rc2<V^8dQhRS[RS[RS[RS[/#rrrrrr rr)rrs"rrrs/BBVBCB3B5BrcBVPP!V.VO5/VB#r)rr"r!rrrs&&*,rr"ZLibBackendWrapper.compresss#!!**4A$A&AArc2<V^8dQhRS[RS[RS[RS[/#rr)rrs"rrrs/DDvDcDSDUDrcBVPP!V.VO5/VB#r)rr=rs&&*,rr=ZLibBackendWrapper.decompresss#!!,,TCDCFCCrc&<V^8dQhRS[RS[/#)rattrnamer)rr)rrs"rrrs55C5C5rc.\VPV4#rr)r!rs&&r __getattr__ZLibBackendWrapper.__getattr__st))844rrN)r-r.r/r0rrVrrrrsrtrurvrbrfr"r=rr1r2r3s@rrr`s@@DD,,//////++??AABBDD55rrc(V^8dQhR\RR/#)rnew_zlib_backendrNr)rs"rrrs11':1t1rcV\nR#r) ZLibBackendr)rs&rset_zlib_backendrs 0KrcJV^8dQhR\R,R\R\/#)rencodingNsuppress_deflate_headerr)rrHr')rs"rrrs/XXDjX!X XrcVR8Xd^\P,#V'd\P)#\P#)gzip)rrr)rrs&&rencoding_to_moders96K))))%)Bc <V^8dQhRS[/#rFrG)rrs"rrrsFFFrc R#)z7Return True if more output is available by passing b"".NrrJs&rdata_available'DecompressionBaseHandler.data_availablerrr)r-r.r/r0MAX_SYNC_CHUNK_SIZErrZLIB_MAX_LENGTH_UNLIMITEDrr=rVrr1r2r3s@rrrsa%)*=88.G))) /H 6 6FFrrc~a]tRt^toRRRRRR]3V3RlRlltV3RlRltV3RlRltR V3R lR lltR t Vt R#) ZLibCompressorNFc<V^8dQhRS[R,RS[RS[R,RS[R,RS[R,RS[R,RS[R,/#) rrNrrZr\r^rr)rrHr'r)rrs"rrZLibCompressor.__annotate__srDD*D"&DTz D Tz D * DT/D!4ZDrc W`nWpnVf \W4MTVn\ \ P 4Vn/pVPVR&VeWXR&VeW8R&VP P!R/VBVnR#)Nr\r^rZr) rrr_moderrrrb _compressor) r!rrrZr\r^rrrs &&&&&&&& rrZLibCompressor.__init__s"$7!} X ? %7{7P7P$Q"$**w  !):   #7O--99CFCrc&<V^8dQhRS[RS[/#rr)rrs"rrrs//&/U/rc8VPPV4#r)rr"r s&&r compress_syncZLibCompressor.compress_syncs((..rc&<V^8dQhRS[RS[/#rr)rrs"rrrs((6(e(rc 4"VPRJ;'d\V4VP8pV'dM\P!4P VP VP PV4GRjxL #VPV4#L5i)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_looprrrr"r)r!rshould_use_executors&& rr"ZLibCompressor.compresss&  % %T 1 6 6D D555   113CC 0 0 9 94 !!$''s6BABBBc4<V^8dQhRS[R,RS[/#)rr%Nrr&)rrs"rrrs   #*    rc tVPPVeV4#VPP4#)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*rrvr)s&&rr*ZLibCompressor.flushs>%%$D  *.*<*<*E*E  r)rrrrrr) r-r.r/r0rrrr"r*r1r2r3s@rrrsK $(-  #$(*=DD6//((8    rrcaa]tRtRtoRRR]3V3RlV3Rlllt]3V3RlRlltRV3RlR llt] V3R lR l4t ] V3R lR l4t Rt Vt V;t#)ZLibDecompressori NFc \<V^8dQhRS[R,RS[RS[R,RS[R,/#)rrNrrr)rrHrr')rrs"rrZLibDecompressor.__annotate__ s? 7 7* 7"& 7T/ 7 !4Z 7rc<\SV`W4R7\W4Vn\ \ P 4VnVP PVPR7VnRVn RVn R#)rrr\FN) superrrrrrrrf _decompressor _last_empty_pending_unused_data)r!rrrr __class__s&&&&&rrZLibDecompressor.__init__ sd (T%hH $6{7P7P$Q!//==DJJ=O 26!rc,<V^8dQhRS[RS[RS[/#r7r9)rrs"rrrs%"""(+" "rchVPe$VP\V4,pRVnVPPVPPV,V4pVR8HVnVPP 'dVPP'dVPPpVPPVPR7VnV\8wd!V\V4,pV^8:dW@nM/VPPWB4pVR8HVnW5, pKVPP 'dQVPVPP8d,VPPVPR7VnV#)Nrr)rrrr=rPrrKrTrrfrrrrr)r!rr8resultunusedchunks&&& rr ZLibDecompressor.decompress_syncs\  $ $ 0,,uT{:D(,D %##..    . . 5z "S=   $$$););)G)G)G''33F!%!3!3!A!A !A!SD 66c&k) ?06-&&11&EE$|D  OF    ! ! !djj43E3E3O3O&O!%!3!3!A!A !A!SD  rc&<V^8dQhRS[RS[/#r@r&)rrs"rrr?s  C  rczV^8dVPPV4#VPP4#r)rr*rCs&&rr*ZLibDecompressor.flush?s?z    $ $V , ##))+ rc <V^8dQhRS[/#rFrG)rrs"rrrGs   rc\VPP4;'g(VP'*;'gVPRJ#r)rHrrPrrrJs&rrZLibDecompressor.data_availableFsK ##33 4 5 5### 5 5((4 rc <V^8dQhRS[/#rFrG)rrs"rrrOs&&T&rc.VPP#r)rrKrJs&rrKZLibDecompressor.eofNs!!%%%r)rrrrrr )r-r.r/r0rrrrr*rVrrKr1r2 __classcell__rrs@@rrr se $(-$(*= 7 7/H""H    &&&rrcaa]tRtRtoR]3V3RlV3Rlllt]3V3RlRlltV3RlRlt] V3R lR l4t R t Vt V;t #) BrotliDecompressoriSNcF<V^8dQhRS[R,RS[R,RR/#rrNrrr)rrs"rrBrotliDecompressor.__annotate__Ws6 U UT/ U!4Z U  Urc <\'g \R4h\P!4VnRVn\ SV`WR7R#)z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` moduleFrN) HAS_BROTLI RuntimeErrorbrotli Decompressor_objrrrr!rrrs&&&rrBrotliDecompressor.__init__WsF z1 '')   (Trc,<V^8dQhRS[RS[RS[/#r7r9)rrs"rrrfs%(+ rc \VPR4'd`V\8Xd+\\VPP V44pM\\VPP W44pM^V\8Xd+\\VPP V44pM)\\VPP W44pVR8HVnV#)rr=r)hasattrr!rr rr=processr)r!rr8rs&&& rr"BrotliDecompressor.decompress_syncfs 499l + +66eTYY%9%9$%?@eTYY%9%9$%KL66eTYY%6%6t%<=eTYY%6%6t%HI!S= rc <V^8dQhRS[/#rFrN)rrs"rrrxsurc \VPR4'd)\\VPP 44#R#)zFlush the decompressor.r*r)r&r!r rr*rJs&rr*BrotliDecompressor.flushxs. 499g & &tyy01 1rc <V^8dQhRS[/#rFrG)rrs"rrrsDDDrcrVPP4'*;'dVP'*#r)r! is_finishedrrJs&rr!BrotliDecompressor.data_available~s)99((**CC43C3C/CCr)rr!r-r.r/r0rrrrr*rVrr1r2rrs@@rrrSsO %)*= U U /H$ DDDrrcaa]tRtRtoR]3V3RlV3Rlllt]3V3RlRlltV3RlRlt] V3R lR l4t R t Vt V;t #) ZSTDDecompressoriNcF<V^8dQhRS[R,RS[R,RR/#rr)rrs"rrZSTDDecompressor.__annotate__s6 U UT/ U!4Z U  Urc<\'g \R4h\4VnRVn\ SV`WR7R#)zOThe zstd decompression is not available. Please install `backports.zstd` moduleNr)HAS_ZSTDrr r!rrrr"s&&&rrZSTDDecompressor.__init__s@ x9 %& 26! (Trc,<V^8dQhRS[RS[RS[/#r7r9)rrs"rrr4s%$$$(+$ $rc^V\8Xd\MTpVPeVPV,pRVnVPP W4pVPP 'dVPP 'dtVPP p\4VnV\8wd!V\V4,pV^8:dWPnM#W@PP WS4, pKVPP 'd\4VnV#r) rZSTD_MAX_LENGTH_UNLIMITEDrr!r=rKrTr r)r!rr8zstd_max_lengthrrTs&&& rr ZSTDDecompressor.decompress_syncs66 &   $ $ 0,,t3D(,D %%%d<iimmm 5 5 5))//K(*DI";;3v;."a'0;- ii**;H HF 99===(*DI rc <V^8dQhRS[/#rFrN)rrs"rrr4surcR#)rrrJs&rr*ZSTDDecompressor.flushsrc <V^8dQhRS[/#rFrG)rrs"rrr4s333rcVPP'*;'d$VPP'*;'gVPRJ#r)r! needs_inputrKrrJs&rrZSTDDecompressor.data_availablesD %% % ; ;diimm*;33  & &d 2 3r)r!rr0rs@@rr2r2sM%)*= U U/H$$L333rr2c@V^8dQh/^\9d \;R&#)rr)__conditional_annotations__r)rs"rrrsX;: :Yr) )rF)NF).rErsyszlibabcrrconcurrent.futuresrtypingrrrr r version_infocollections.abcr r r bytearray brotlicffir ImportErrorrcompression.zstdr backports.zstdr6rrr:rr5rXrzrrrrrrrrr2r)rEs@rrVsm #'88w& 5)%68KK LF#J 7"53H 6h6 ( ((8iu *5*5Z#5T": :1X Fs FFH H VD&/D&N-D1-D`<3/<3c JHsBD D$# D3 D!D$ D!!D$$ D0/D03 D?>D?