+ TŎi-aR&t/0t^RIt^RIt^RIt^RIHtHt^RIHt^RI H t H t H t H t HtHt]P R'8d^RIHtM^RI Ht]]]RR3,t^RItR t]P R(8d^R IHtM^R IHtR tR tR)t^t R*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)AnyFinalOptionalProtocol TypedDictcast)Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)ZstdDecompressoricHa]tRt^,toV3RlRltRV3RlRlltRtVtR#)ZLibCompressObjProtocolc&<V^8dQhRS[RS[/#datareturn)r bytes)format __classdict__s"h/Users/ahmad/.openclaw/workspace/scripts/.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,s22555rrcha]tRt^1toR V3RlRlltR V3RlRllt]V3RlRl4tRtVt R#) ZLibDecompressObjProtocolc,<V^8dQhRS[RS[RS[/#rr max_lengthrr r(r)rrs"rr&ZLibDecompressObjProtocol.__annotate__2sKKvK3KKrcR#rrr!rr9s&&&r decompress$ZLibDecompressObjProtocol.decompress2src&<V^8dQhRS[RS[/#rlengthrr')rrs"rrr;3s77C7U7rcR#rrr!rBs""rr+ZLibDecompressObjProtocol.flush3sCrc <V^8dQhRS[/#rrbool)rrs"rrr;6sTrcR#rrr!s&reofZLibDecompressObjProtocol.eof5srrNr-) r.r/r0r1r>r+propertyrLr2r3r4s@rr6r61sKK77 rr6ca]tRt^9toR V3RlRlltR V3RlRlltR V3RlRlltR V3RlRlltV3R ltR t Vt R #)ZLibBackendProtocolcT<V^8dQhRS[RS[RS[RS[RS[RS[S[,RS[/#)rlevelmethodwbitsmemLevelstrategyzdictr)r(rr r)rrs"rr ZLibBackendProtocol.__annotate__@sV&&&& &  &  && !&rcR#rr)r!rRrSrTrUrVrWs&&&&&&&r compressobjZLibBackendProtocol.compressobj@s#&rc,<V^8dQhRS[RS[RS[/#)rrTrWr)r(r r6)rrs"rrrXIs%((('-( "(rcR#rr)r!rTrWs&&&r decompressobj!ZLibBackendProtocol.decompressobjIs$'rc2<V^8dQhRS[RS[RS[RS[/#)rrRrTrrr(r r)rrs"rrrXMs-&)8; rcR#rr)r!rrRrTs""&&rr"ZLibBackendProtocol.compressMrc2<V^8dQhRS[RS[RS[RS[/#)rrTbufsizerrra)rrs"rrrXPs-&):= rcR#rr)r!rrTrfs""&&rr>ZLibBackendProtocol.decompressPrdrcV<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"rrrX9s@N  M rrN)......)..) r.r/r0r1rZr^r"r>__annotate_func__r2r3r4s@rrPrP9s4&&((/rrPc,a]tRt^UtoV3RltRtVtR#)CompressObjArgsc><V^8dQh/S[;R&S[;R&S[;R&#)rrTrVrRro)rrs"rrCompressObjArgs.__annotate__Us% JM JrrN)r.r/r0r1rpr2r3r4s@rrrrrUsrrr)totalc4a]tRt^[toV3RlRlt]V3RlRl4t]V3RlRl4t]V3RlRl4t]V3R lR l4t ]V3R lR l4t ]V3R lRl4t V3RlRlt V3RlRlt V3RlRltV3RlRltV3RlRltRtVtR#)ZLibBackendWrapperc <V^8dQhRS[/#)r _zlib_backendrP)rrs"rrZLibBackendWrapper.__annotate__\s@@&9@rcWnR#rry)r!rys&&r__init__ZLibBackendWrapper.__init__\s2?rc <V^8dQhRS[/#rG)str)rrs"rrr{`sDDcDrc0\VPRR4#)r. undefinedgetattrryrKs&rnameZLibBackendWrapper.name_st)):{CCrc <V^8dQhRS[/#rGro)rrs"rrr{ds,,3,rc.VPP#r)ryrjrKs&rrjZLibBackendWrapper.MAX_WBITScs!!+++rc <V^8dQhRS[/#rGro)rrs"rrr{h//c/rc.VPP#r)ryrkrKs&rrkZLibBackendWrapper.Z_FULL_FLUSHg!!...rc <V^8dQhRS[/#rGro)rrs"rrr{lrrc.VPP#r)ryrlrKs&rrlZLibBackendWrapper.Z_SYNC_FLUSHkrrc <V^8dQhRS[/#rGro)rrs"rrr{prrc.VPP#r)ryrmrKs&rrmZLibBackendWrapper.Z_BEST_SPEEDorrc <V^8dQhRS[/#rGro)rrs"rrr{ts++#+rc.VPP#r)ryrnrKs&rrnZLibBackendWrapper.Z_FINISHss!!***rc,<V^8dQhRS[RS[RS[/#rargskwargsr)rr)rrs"rrr{ws#????8O?rc:VPP!V/VB#r)ryrZr!rrs&*,rrZZLibBackendWrapper.compressobjws!!--t>v>>rc,<V^8dQhRS[RS[RS[/#r)rr6)rrs"rrr{zs(AA3A#A:SArc:VPP!V/VB#r)ryr^rs&*,rr^ ZLibBackendWrapper.decompressobjzs!!//@@@rc2<V^8dQhRS[RS[RS[RS[/#rrrrrr rr)rrs"rrr{}s/BBVBCB3B5BrcBVPP!V.VO5/VB#r)ryr"r!rrrs&&*,rr"ZLibBackendWrapper.compress}s#!!**4A$A&AArc2<V^8dQhRS[RS[RS[RS[/#rr)rrs"rrr{s/DDvDcDSDUDrcBVPP!V.VO5/VB#r)ryr>rs&&*,rr>ZLibBackendWrapper.decompresss#!!,,TCDCFCCrc&<V^8dQhRS[RS[/#)rattrnamer)rr)rrs"rrr{s55C5C5rc.\VPV4#rr)r!rs&&r __getattr__ZLibBackendWrapper.__getattr__st))844rr}N)r.r/r0r1r~rNrrjrkrlrmrnrZr^r"r>rr2r3r4s@rrwrw[s@@DD,,//////++??AABBDD55rrwc(V^8dQhR\RR/#)rnew_zlib_backendrNrz)rs"rrrs11':1t1rcV\nR#r) ZLibBackendry)rs&rset_zlib_backendrs 0KrcRV^8dQhR\\,R\R\/#)rencodingsuppress_deflate_headerr)rrrIr()rs"rrrs/XXsmX!X XrcVR8Xd^\P,#V'd\P)#\P#)gzip)rrj)rrs&&rencoding_to_moders96K))))%#DecompressionBaseHandler.decompressso  % % 1D D555 //1AA 4 4d ##D55sA&B(A>)Br) r.r/r0r1MAX_SYNC_CHUNK_SIZEr~rZLIB_MAX_LENGTH_UNLIMITEDrr>r2r3r4s@rrrsH(,-@88-F))) .G 6 6 6rrc~a]tRt^toRRRRRR]3V3RlRlltV3RlRltV3RlRltR V3R lR lltR t Vt R#) ZLibCompressorNFc<V^8dQhRS[S[,RS[RS[S[,RS[S[,RS[S[,RS[S[,RS[S[,/#)rrrrRrTrVrr)rrrIr(r)rrs"rrZLibCompressor.__annotate__ssDD3-D"&D} D } D 3- D8$D&c]Drc W`nWpnVf \W4MTVn\ \ P 4Vn/pVPVR&VeWXR&VeW8R&VP P!R/VBVnR#)NrTrVrRr) rrr_moderwrryrZ _compressor) r!rrrRrTrVrrrs &&&&&&&& rr~ZLibCompressor.__init__s"$7!} X ? %7{7P7P$Q"$**w  !):   #7O--99CFCrc&<V^8dQhRS[RS[/#rr)rrs"rrrs//%/E/rc8VPPV4#r)rr"r s&&r compress_syncZLibCompressor.compress_syncs((..rc&<V^8dQhRS[RS[/#rr)rrs"rrrs((5(U(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 !!$''s6BABBBc6<V^8dQhRS[S[,RS[/#r%)rr(r)rrs"rrrs   (3-  5  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+ryrnr*s&&rr+ZLibCompressor.flushs>%%$D  *.*<*<*E*E  r)rrrrryr) r.r/r0r1rr~rr"r+r2r3r4s@rrrsK#'(-##"&'+-@DD6//((8    rrcaa]tRtRtoRRR]3V3RlV3Rlllt]3V3RlRlltR V3RlR llt] V3R lR l4t R t Vt V;t #)ZLibDecompressoriNFc b<V^8dQhRS[S[,RS[RS[S[,RS[S[,/#)rrrrr)rrrIrr()rrs"rrZLibDecompressor.__annotate__sF P P3- P"& P8$ P &c] Prc<\SV`W4R7\W4Vn\ \ P 4VnVP PVPR7VnR#)rr)rTN) superr~rrrwrryr^ _decompressor)r!rrrr __class__s&&&&&rr~ZLibDecompressor.__init__sT (T%hH $6{7P7P$Q!//==DJJ=Orc,<V^8dQhRS[RS[RS[/#r8r:)rrs"rrrs%???(+? ?rc8VPPW4#r)rr>r=s&&&rr ZLibDecompressor.decompress_syncs!!,,T>>rc&<V^8dQhRS[RS[/#rAr')rrs"rrrs  C  rczV^8dVPPV4#VPP4#r)rr+rDs&&rr+ZLibDecompressor.flushs?z    $ $V , ##))+ rc <V^8dQhRS[/#rGrH)rrs"rrrs&&T&rc.VPP#r)rrLrKs&rrLZLibDecompressor.eofs!!%%%r)rrryr)r.r/r0r1rr~rrr+rNrLr2r3 __classcell__rrs@@rrrsR#'(-'+-@ P P/H??   &&&rrcpaa]tRtRtoR]3V3RlV3Rlllt]3V3RlRlltV3RlRltR t Vt V;t #) BrotliDecompressori NcJ<V^8dQhRS[S[,RS[S[,RR/#rrrrNr)rrs"rrBrotliDecompressor.__annotate__$s7 U U8$ U&c] U  Urc <\'g \R4h\P!4Vn\ SV`WR7R#)z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` modulerN) HAS_BROTLI RuntimeErrorbrotli Decompressor_objrr~r!rrrs&&&rr~BrotliDecompressor.__init__$s> z1 '')  (Trc,<V^8dQhRS[RS[RS[/#r8r:)rrs"rrr2s*@@@(+@ @rc \VPR4'd*\\VPP W44#\\VPP W44#)rr>)hasattrr r rr>processr=s&&&rr"BrotliDecompressor.decompress_sync2sM 499l + +tyy33DEF FE499,,T>??rc <V^8dQhRS[/#rGr)rrs"rrr:surc \VPR4'd)\\VPP 44#R#)zFlush the decompressor.r+r)rr r rr+rKs&rr+BrotliDecompressor.flush:s. 499g & &tyy01 1rr  r.r/r0r1rr~rrr+r2r3rrs@@rrr s: (,-@ U U/H@@rrcpaa]tRtRtoR]3V3RlV3Rlllt]3V3RlRlltV3RlRltR t Vt V;t #) ZSTDDecompressoriANcJ<V^8dQhRS[S[,RS[S[,RR/#rr)rrs"rrZSTDDecompressor.__annotate__Bs7 U U8$ U&c] U  Urct<\'g \R4h\4Vn\SV`WR7R#)zOThe zstd decompression is not available. Please install `backports.zstd` modulerN)HAS_ZSTDr rr rr~rs&&&rr~ZSTDDecompressor.__init__Bs8 x9 %&  (Trc,<V^8dQhRS[RS[RS[/#r8r)rrs"rrrOs% ; ; ;'* ;  ;rc^V\8Xd\MTpVPPW4#r)rZSTD_MAX_LENGTH_UNLIMITEDr r>)r!rr9zstd_max_lengths&&& rr ZSTDDecompressor.decompress_syncOs166 &  yy##D::rc <V^8dQhRS[/#rGr)rrs"rrr[surcR#)rrrKs&rr+ZSTDDecompressor.flush[srrrrs@@rrrAs8(,-@ U U.G ; ;rrc@V^8dQh/^\9d \;R&#)rr)__conditional_annotations__rw)rs"rrrsN;: :Or) )r+i)NF)0r*rsyszlibabcrrconcurrent.futuresrtypingrrrr r r version_infocollections.abcr r r bytearray brotlicffir  ImportErrorr compression.zstdrbackports.zstdrrDEFAULT_MAX_DECOMPRESS_SIZErr#rr6rPrrrwrrrrrrrrr)r*s@rr<sk #'BBw& 5)%68KK LF#J 7"53H #6h6 (8iu *5*5Z#5T": :1X6s6