wceddlZddlZddlmZddlmZmZ ddlZdZ dZ ddee de d efd ZGd d ZGd deZGddeZGddZy#e $rddlZYJwxYw#e $rdZ YUwxYw)N)Executor)OptionalcastTFiencodingsuppress_deflate_headerreturncx|dk(rdtjzS|rtj StjS)Ngzip)zlib MAX_WBITS)rrs ;/usr/lib/python3/dist-packages/aiohttp/compression_utils.pyencoding_to_moders26DNN""5DNN?I4>>Ic2eZdZdefdedeedeefdZy)ZlibBaseHandlerNmodeexecutormax_sync_chunk_sizec.||_||_||_yN)_mode _executor_max_sync_chunk_size)selfrrrs r__init__zZlibBaseHandler.__init__s  !$7!r)__name__ __module__ __qualname__MAX_SYNC_CHUNK_SIZEintrrrrrrrs4(,-@ 888$8&c] 8rrceZdZddddejdefdeededee dee de dee d ee ffd Z d e d e fd Z d e d e fdZejfde d e fdZxZS)ZLibCompressorNFrrlevelwbitsstrategyrrct|| t||n||||'tj|j ||_n'tj|j |||_tj|_ y)Nrrr)r&r')r&r'r%) superrrr compressobjr _compressorasyncioLock_compress_lock) rrrr%r&r'rr __class__s rrzZLibCompressor.__init__*s }"(,CD 3   =#//djj8TD #//jj85 D &llnrdatarc8|jj|Sr)r,compressrr1s r compress_synczZLibCompressor.compress_syncCs((..rcK|j4d{|jjt||jkDrRtjj |j |j|d{cdddd{S|j|cdddd{S7797+7 #1d{7swYyxYwwr)r/rlenr-get_event_looprun_in_executorrr5r4s rr3zZLibCompressor.compressFs&& , , ))5I 9 99$335EENND$6$6 , , ,%%d+ , , , , , , , ,suC B0C A!B88B29B8< C B4 C B8 C *B6+C 2B84C 6C 8C >C ?C C rc8|jj|Sr)r,flush)rrs rr;zZLibCompressor.flushUs%%d++r)rrrr Z_DEFAULT_STRATEGYr rstrboolr!rrbytesr5r3Z_FINISHr; __classcell__r0s@rr$r$)s#'(-##//'+-@-3--"&-} - } -  -8$-&c]-2/%/E/ ,5 ,U ,!% ,#,%,rr$c eZdZdddefdeededeedeeffd Z dde d ed e fd Z dde d ed e fd Z dd ed e fdZ ed efdZed e fdZed e fdZxZS)ZLibDecompressorNFrrrrct|t||||tj|j |_y)Nr))r&)r*rrr decompressobjr _decompressor)rrrrrr0s rrzZLibDecompressor.__init__ZsA !(,CD 3  "//djjArr1 max_lengthrc:|jj||Sr)rG decompressrr1rHs rdecompress_syncz ZLibDecompressor.decompress_synchs!!,,T:>>rcK|jZt||jkDrBtjj |j |j ||d{S|j ||S7wr)rr7r-r8r9rrLrKs rrJzZLibDecompressor.decompressksr  % % 1D D555 //1AA 4 4dJ ##D*55sA"A=$A;%A=lengthcv|dkDr|jj|S|jjS)Nr)rGr;)rrNs rr;zZLibDecompressor.flushus?z    $ $V , ##))+ rc.|jjSr)rGeofrs rrQzZLibDecompressor.eof|s!!%%%rc.|jjSr)rGunconsumed_tailrRs rrTz ZLibDecompressor.unconsumed_tails!!111rc.|jjSr)rG unused_datarRs rrVzZLibDecompressor.unused_datas!!---r)r)rrrr rr=r>rr!rr?rLrJr;propertyrQrTrVrArBs@rrDrDYs#'(-'+-@ B3- B"& B8$ B &c] B?E?s?5?6U66E6 C  &T&&222.U..rrDc0eZdZddZdedefdZdefdZy)BrotliDecompressorrNcXts tdtj|_y)NzIThe brotli decompression is not available. Please install `Brotli` module) HAS_BROTLI RuntimeErrorbrotli Decompressor_objrRs rrzBrotliDecompressor.__init__s)1 '') rr1ct|jdr)tt|jj |Stt|jj |S)NrJ)hasattrr_rr?rJprocessr4s rrLz"BrotliDecompressor.decompress_syncsH 499l +tyy33D9: :E499,,T233rct|jdr(tt|jj Sy)Nr;r)rar_rr?r;rRs rr;zBrotliDecompressor.flushs+ 499g &tyy01 1r)rN)rrrrr?rLr;r"rrrYrYs&*4E4e4 urrY)NF)r-r concurrent.futuresrtypingrr brotlicffir] ImportErrorr[r r=r>r!rrr$rDrYr"rrrhs '!#J#$)JsmJ!J J 8 8-,_-,`-.-.`A Js.AA+ A(%A+'A((A++A54A5