q*i(d%SSKrSSKrSSKrSSKJr SSKJrJrJrJ r J r J r \RS:aSSK Jr OSSKJr \\\SS4rSSKrS r\RS :aSS KJr OSS KJr S rS r"SS\ 5r"SS\ 5r"SS\ 5r"SS\ S S9r"SS5r\"\5r \\!S'S\SS4Sjr"S*S\\#S\$S\%4Sjjr&"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)Executor)AnyFinalOptionalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)r )ZstdDecompressoric<\rSrSrS\S\4SjrS S\S\4SjjrSr g) ZLibCompressObjProtocol&datareturncgNselfrs Y/var/www/html/land-doc-ocr/venv/lib/python3.13/site-packages/aiohttp/compression_utils.pycompress ZLibCompressObjProtocol.compress'ssmodecgrrrrs 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 r g ) ZLibDecompressObjProtocol+r max_lengthrcgrrrrr.s r decompress$ZLibDecompressObjProtocol.decompress,srlengthcgrrrr3s rr!ZLibDecompressObjProtocol.flush-sCrcgrrrs reofZLibDecompressObjProtocol.eof/srrNr#) r$r%r&r'r r)r(r1r!propertyboolr9r*rrrr,r,+s4KvK3KK7C7U7 Trr,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)ZLibBackendProtocol3 MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISHlevelmethodwbitsmemLevelstrategyzdictrcgrr)rrErFrGrHrIrJs r compressobjZLibBackendProtocol.compressobj:s#&rcgrr)rrGrJs r decompressobj!ZLibBackendProtocol.decompressobjCs$'rrcgrr)rrrErGs rrZLibBackendProtocol.compressGrbufsizecgrr)rrrGrTs rr1ZLibBackendProtocol.decompressJrSrrN)......)..)r$r%r&r'r)__annotations__rr rrLr,rOr(rr1r*rrrr>r>3sNM"%&&& &  &  && !&14(('-( "( ?B&)8; AD&):= rr>c4\rSrSr%\\S'\\S'\\S'Srg)CompressObjArgsOrGrIrErN)r$r%r&r'r)rWr*rrrrYrYOs JM JrrY)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)ZLibBackendWrapperU _zlib_backendcXlgrr_)rr_s r__init__ZLibBackendWrapper.__init__Vs2?rrc0[URSS5$)Nr$ undefinedgetattrr_r8s rnameZLibBackendWrapper.nameYst)):{CCrc.URR$r)r_r@r8s rr@ZLibBackendWrapper.MAX_WBITS]s!!+++rc.URR$r)r_rAr8s rrAZLibBackendWrapper.Z_FULL_FLUSHa!!...rc.URR$r)r_rBr8s rrBZLibBackendWrapper.Z_SYNC_FLUSHernrc.URR$r)r_rCr8s rrCZLibBackendWrapper.Z_BEST_SPEEDirnrc.URR$r)r_rDr8s rrDZLibBackendWrapper.Z_FINISHms!!***rargskwargsc:URR"U0UD6$r)r_rLrrurvs rrLZLibBackendWrapper.compressobjqs!!--t>v>>rc:URR"U0UD6$r)r_rOrxs rrO ZLibBackendWrapper.decompressobjts!!//@@@rrcBURR"U/UQ70UD6$r)r_rrrrurvs rrZLibBackendWrapper.compressws#!!**4A$A&AArcBURR"U/UQ70UD6$r)r_r1r}s rr1ZLibBackendWrapper.decompresszs#!!,,TCDCFCCrattrnamec.[URU5$rrf)rrs r __getattr__ZLibBackendWrapper.__getattr__~st))844rraN)r$r%r&r'r>rbr;strrhr)r@rArBrCrDrrrLr,rOr r(rr1rr*rrrr]r]UsO@&9@DcDD,3,,/c///c///c//+#++???8O?A3A#A:SABVBCB3B5BDvDcDSDUD5C5C5rr] ZLibBackendnew_zlib_backendrcU[lgr)rr_)rs rset_zlib_backendrs 0Krencodingsuppress_deflate_headercUS:XaS[R-$U(a[R*$[R$)Ngzip)rr@)rrs rencoding_to_moders96K))))%\rSrSrS\4S\S\\S\\4SjjrSr g)ZlibBaseHandlerNrexecutormax_sync_chunk_sizec(XlX lX0lgr)_mode _executor_max_sync_chunk_size)rrrrs rrbZlibBaseHandler.__init__s  !$7!r)rrr) r$r%r&r'MAX_SYNC_CHUNK_SIZEr)rrrbr*rrrrrs9(,-@ 888$8&c] 88rrc^\rSrSrSSSSSS\4S\\S\S\\S\\S\\S \\ S \\4U4S jjjr S \ S \ 4Sjr S \ S \ 4Sjr SS\\S \ 4SjjrSrU=r$)ZLibCompressorNFrrrErGrIrrc>[T U]Uc [X5OUUUS9 [[R 5Ul0nUR US'UbXXS'UbX8S'UR R"S0UD6Ulg)NrrrrGrIrEr) superrbrr]rr_rrL _compressor) rrrrErGrIrrrv __class__s rrbZLibCompressor.__init__s =!C 3  %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) rlenasyncioget_running_looprun_in_executorrrrr)rrshould_use_executors rrZLibCompressor.compresss&  % %T 1 6D D555   113CC 0 0 9 94 !!$''sAB?BrcrURRUbU5$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!r_rDr s rr!ZLibCompressor.flushs>%%$D  *.*<*<*E*E  r)rr_r)r$r%r&r'rrrr<r)rrbr(rrr!r* __classcell__rs@rrrs#'(-##"&'+-@D3-D"&D} D } D 3- D8$D&c]DD:/%/E/(5(U(8  (3-  5   rrc ^\rSrSrSSS\4S\\S\S\\S\\ 4U4Sjjjr SS \ S \ S \ 4S jjr SS \ S \ S \ 4S jjr SS\ S \ 4Sjjr\S \4Sj5rSrU=r$)ZLibDecompressorNFrrrrc>[TU][X5UUS9 [[R 5UlUR R URS9Ulg)Nr)rG) rrbrr]rr_rOr _decompressor)rrrrrrs rrbZLibDecompressor.__init__sZ !(D 3  %7{7P7P$Q!//==DJJ=Orrr.rc8URRX5$r)rr1r0s rdecompress_sync ZLibDecompressor.decompress_syncs!!,,T>>rc# URbe[U5UR:aL[R"5R UR UR RX5IShvN $URX5$N7f)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) rrrrrrrr1rr0s rr1ZLibDecompressor.decompresssu  % % 1D D555 113CC 2 2 = =t ##D55sA.B0B1Br3cxUS:aURRU5$URR5$)Nr)rr!r5s rr!ZLibDecompressor.flushs?z    $ $V , ##))+ rc.URR$r)rr9r8s rr9ZLibDecompressor.eofs!!%%%r)rr_)r)r$r%r&r'rrrr<rr)rbr(rr1r!r;r9r*rrs@rrrs#'(-'+-@ P3- P"& P8$ P &c] P P?E?s?5?6U66E6  C  &T&&rrc>\rSrSrS SjrS\S\4SjrS\4SjrSrg) BrotliDecompressorirNcd[(d [S5e[R"5Ulg)NzIThe brotli decompression is not available. Please install `Brotli` module) HAS_BROTLI RuntimeErrorbrotli Decompressor_objr8s rrbBrotliDecompressor.__init__s+z1 '') rrc[URS5(a)[[URR U55$[[URR U55$)Nr1)hasattrrr r(r1processrs rr"BrotliDecompressor.decompress_sync'sK 499l + +tyy33D9: :E499,,T233rc[URS5(a([[URR 55$g)Nr!r)rrr r(r!r8s rr!BrotliDecompressor.flush,s. 499g & &tyy01 1rrrN r$r%r&r'rbr(rr!r*rrrrrs&*4E4e4 urrc>\rSrSrS SjrS\S\4SjrS\4SjrSrg) ZSTDDecompressori2rNcN[(d [S5e[5Ulg)NzOThe zstd decompression is not available. Please install `backports.zstd` module)HAS_ZSTDrrrr8s rrbZSTDDecompressor.__init__3s%x9 %& rrc8URRU5$r)rr1rs rr ZSTDDecompressor.decompress_sync;syy##D))rcg)Nrrr8s rr!ZSTDDecompressor.flush>srrrrrrrrr2s&'*E*e*urr)NF),rsyszlibconcurrent.futuresrtypingrrrrrr version_infocollections.abcr r r( bytearray brotlicffir ImportErrorrcompression.zstdrbackports.zstdrrrr,r>rYr]rrWrrr<r)rrrrrrrrrrs 'BBw& 5)%68KK LF#J 7"53H 6h6 (8iu *5*5Z#5T": :1':1t1 #$)XsmX!X X 8 8J _J Z,&,&^.  C JHsB DDD$ DDDDD! D!$D/.D/