"Ki-%SSKrSSKrSSKrSSKJrJr SSKJr SSKJ r J r J r J r J r Jr \RS:aSSKJr OSSKJr \\\SS 4rSSKrS r\RS :aSS KJr OSS KJr S rSrSrSrSr "SS\ 5r!"SS\ 5r""SS\ 5r#"SS\ S S9r$"SS5r%\%"\5r&\%\'S'S\#SS4Sjr(S-S \ \)S!\*S\+4S"jjr,"S#S$\5r-"S%S&5r."S'S(\-5r/"S)S*\-5r0"S+S,\-5r1g!\a SSKrNf=f!\a S rNf=f!\a S rNf=f).N)ABCabstractmethod)Executor)AnyFinalOptionalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)r )ZstdDecompressoriic<\rSrSrS\S\4SjrS S\S\4SjjrSr g) ZLibCompressObjProtocol,datareturncgNselfrs [/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/aiohttp/compression_utils.pycompress ZLibCompressObjProtocol.compress-ssmodecgrrrr!s rflushZLibCompressObjProtocol.flush.s#r rN.) __name__ __module__ __qualname____firstlineno__rbytesrintr$__static_attributes__rr rrr,s2V225#5555r rc\\rSrSrS S\S\S\4SjjrS S\S\4Sjjr\ S\ 4Sj5r S r g ) ZLibDecompressObjProtocol1r max_lengthrcgrrrrr1s r decompress$ZLibDecompressObjProtocol.decompress2sr lengthcgrrrr6s rr$ZLibDecompressObjProtocol.flush3sCr cgrrrs reofZLibDecompressObjProtocol.eof5sr rNr&) r'r(r)r*rr,r+r4r$propertyboolr<r-rr rr/r/1s4KvK3KK7C7U7 Tr r/c\rSrSr%\\S'\\S'\\S'\\S'\\S'SS\S\S \S \S \S \\S \4Sjjr SS \S \S \ 4Sjjr SS\S \S\S \ 4Sjjr SS \S\S\S \ 4SjjrSrg)ZLibBackendProtocol9 MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISHlevelmethodwbitsmemLevelstrategyzdictrcgrr)rrHrIrJrKrLrMs r compressobjZLibBackendProtocol.compressobj@s#&r cgrr)rrJrMs r decompressobj!ZLibBackendProtocol.decompressobjIs$'r rcgrr)rrrHrJs rrZLibBackendProtocol.compressMr bufsizecgrr)rrrJrWs rr4ZLibBackendProtocol.decompressPrVr rN)......)..)r'r(r)r*r,__annotations__rrrrOr/rRr+rr4r-rr rrArA9sNM"%&&& &  &  && !&14(('-( "( ?B&)8; AD&):= r rAc4\rSrSr%\\S'\\S'\\S'Srg)CompressObjArgsUrJrLrHrN)r'r(r)r*r,rZr-rr rr\r\Us JM Jr r\)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_backendcXlgrrb)rrbs r__init__ZLibBackendWrapper.__init__\s2?r rc0[URSS5$)Nr' undefinedgetattrrbr;s rnameZLibBackendWrapper.name_st)):{CCr c.URR$r)rbrCr;s rrCZLibBackendWrapper.MAX_WBITScs!!+++r c.URR$r)rbrDr;s rrDZLibBackendWrapper.Z_FULL_FLUSHg!!...r c.URR$r)rbrEr;s rrEZLibBackendWrapper.Z_SYNC_FLUSHkrqr c.URR$r)rbrFr;s rrFZLibBackendWrapper.Z_BEST_SPEEDorqr c.URR$r)rbrGr;s rrGZLibBackendWrapper.Z_FINISHss!!***r argskwargsc:URR"U0UD6$r)rbrOrrxrys rrOZLibBackendWrapper.compressobjws!!--t>v>>r c:URR"U0UD6$r)rbrRr{s rrR ZLibBackendWrapper.decompressobjzs!!//@@@r rcBURR"U/UQ70UD6$r)rbrrrrxrys rrZLibBackendWrapper.compress}s#!!**4A$A&AAr cBURR"U/UQ70UD6$r)rbr4rs rr4ZLibBackendWrapper.decompresss#!!,,TCDCFCCr attrnamec.[URU5$rri)rrs r __getattr__ZLibBackendWrapper.__getattr__st))844r rdN)r'r(r)r*rArer>strrkr,rCrDrErFrGrrrOr/rRrr+rr4rr-rr rr`r`[sO@&9@DcDD,3,,/c///c///c//+#++???8O?A3A#A:SABVBCB3B5BDvDcDSDUD5C5C5r r` ZLibBackendnew_zlib_backendrcU[lgr)rrb)rs rset_zlib_backendrs 0Kr encodingsuppress_deflate_headercUS:XaS[R-$U(a[R*$[R$)Ngzip)rrC)rrs rencoding_to_moders96K))))%&A<'A>r)r'r(r)r*MAX_SYNC_CHUNK_SIZErrr,rerZLIB_MAX_LENGTH_UNLIMITEDr+rr4r-rr rrrs(,-@88$8&c]8-F))'*) )) .G 6 6'* 6  6 6r rc\rSrSrSSSSSS\4S\\S\S\\S\\S\\S \\ S \\4S jjr S \ S \ 4Sjr S \ S \ 4Sjr SS\\S \ 4SjjrSrg)ZLibCompressorNFrrrHrJrLrrcX`lXplUc [X5OUUl[ [ R 5Ul0nURUS'UbXXS'UbX8S'UR R"S0UD6Ulg)NrJrLrHr) rrr_moder`rrbrO _compressor) rrrrHrJrLrrrys rreZLibCompressor.__init__s"$7!} X ? %7{7P7P$Q"$**w  !):   #7O--99CFCr rrc8URRU5$r)rrrs r compress_syncZLibCompressor.compress_syncs((..r c0# 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$rbrGr#s rr$ZLibCompressor.flushs>%%$D  *.*<*<*E*E  r )rrrrrbr)r'r(r)r*rrrr?r,rrer+rrr$r-rr rrrs#'(-##"&'+-@D3-D"&D} D } D 3- D8$D&c]D6/%/E/(5(U(8  (3-  5   r rc ^\rSrSrSSS\4S\\S\S\\S\\ 4U4Sjjjr \ 4S \ S \ S \ 4S jjrSS \ S \ 4Sjjr\S \4Sj5rSrU=r$)ZLibDecompressoriNFrrrrc>[TU]X4S9 [X5Ul[ [ R 5UlUR RURS9Ulg)Nrr)rJ) superrerrr`rrbrR _decompressor)rrrrr __class__s rreZLibDecompressor.__init__sT (T%hH $6{7P7P$Q!//==DJJ=Or rr1rc8URRX5$r)rr4r3s rr ZLibDecompressor.decompress_syncs!!,,T>>r r6cxUS:aURRU5$URR5$)Nr)rr$r8s rr$ZLibDecompressor.flushs?z    $ $V , ##))+ r c.URR$r)rr<r;s rr<ZLibDecompressor.eofs!!%%%r )rrrb)r)r'r(r)r*rrrr?rr,rerrr+rr$r>r<r- __classcell__rs@rrrs#'(-'+-@ P3- P"& P8$ P &c] P P/H??(+? ?  C  &T&&r rcv^\rSrSrS\4S\\S\\SS4U4Sjjjr\ 4S\ S\S\ 4S jjr S\ 4S jr S rU=r$) BrotliDecompressori Nrrrc>[(d [S5e[R"5Ul[ TU]XS9 g)z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` modulerN) HAS_BROTLI RuntimeErrorbrotli Decompressor_objrrerrrrs rreBrotliDecompressor.__init__$s> z1 '')  (Tr rr1c[URS5(a)[[URR X55$[[URR X55$)rr4)hasattrrr r+r4processr3s rr"BrotliDecompressor.decompress_sync2sM 499l + +tyy33DEF FE499,,T>??r c[URS5(a([[URR 55$g)zFlush the decompressor.r$r )rrr r+r$r;s rr$BrotliDecompressor.flush:s. 499g & &tyy01 1r r)r'r(r)r*rrrr,rerrr+rr$r-rrs@rrr sw (,-@ U8$ U&c] U  U U/H@@(+@ @ur rcv^\rSrSrS\4S\\S\\SS4U4Sjjjr\ 4S\ S\S\ 4S jjr S\ 4S jr S r U=r$) ZSTDDecompressoriANrrrcj>[(d [S5e[5Ul[TU]XS9 g)NzOThe zstd decompression is not available. Please install `backports.zstd` moduler)HAS_ZSTDrrrrrers rreZSTDDecompressor.__init__Bs8 x9 %&  (Tr rr1c\U[:Xa[OUnURRX5$r)rZSTD_MAX_LENGTH_UNLIMITEDrr4)rrr1zstd_max_lengths rr ZSTDDecompressor.decompress_syncOs166 &  yy##D::r cg)Nr rr;s rr$ZSTDDecompressor.flush[sr r)r'r(r)r*rrrr,rerr+rr$r-rrs@rrrAss(,-@ U8$ U&c] U  U U.G ; ;'* ;  ;ur r)NF)2rsyszlibabcrrconcurrent.futuresrtypingrrrr r r version_infocollections.abcrrr+ bytearray brotlicffir ImportErrorrcompression.zstdrbackports.zstdrrDEFAULT_MAX_DECOMPRESS_SIZErrrr/rAr\r`rrZrrr?r,rrrrrrrr rrs #'BBw& 5)%68KK LF#J 7"53H #6h6 (8iu *5*5Z#5T": :1':1t1 #$)XsmX!X X6s6D?