­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ U '7`@sxddlZddlZddlmZmZddlmZddlmZm Z ddl m Z m Z m Z mZmZmZmZmZmZmZddlmZddlmZdd lmZdd lmZe rdd lmZdd lm Z dd l!m"Z"m#Z#ddl$m%Z%ndZ"Z#ZZ%dZ GdddeZ&GdddeZ'GdddeZ(GdddeZ)e r>ee e*Z+neZ+Gdddee+Z,GdddeZ-GdddeZ.dS)N)ABCabstractmethod)Sized) BaseCookieMorsel) TYPE_CHECKINGAny AwaitableCallableDict GeneratorIterableListOptionalTuple) CIMultiDict)URL)get_running_loop) LooseCookies) Application) HTTPException) BaseRequestRequest)StreamResponsec@s^eZdZddddZeddddZeeddd Zddd d Z e e d d ddZ dS)AbstractRouterNreturncCs d|_dS)NFZ_frozenselfr!>/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/abc.py__init__$szAbstractRouter.__init__apprcCsdS)zPost init stage. Not an abstract method for sake of backward compatibility, but if the router wants to be aware of the application it can override this. Nr!r r%r!r!r" post_init'szAbstractRouter.post_initcCs|jSNrrr!r!r"frozen/szAbstractRouter.frozencCs d|_dS)zFreeze router.TNrrr!r!r"freeze3szAbstractRouter.freezeAbstractMatchInforequestrcsdS)z#Return MATCH_INFO for given requestNr!r r-r!r!r"resolve7szAbstractRouter.resolve) __name__ __module__ __qualname__r#rr'propertyboolr)r*rrr/r!r!r!r"r#src@seZdZeeeegeefdddZ eeeegedfdddZ eee e dddZ eeeefdd d Zeeeed fdd d ZeeddddZeddddZdS)r+rcCsdS)zExecute matched request handlerNr!rr!r!r"handler=szAbstractMatchInfo.handlerNcCsdS)z*Expect handler for 100-continue processingNr!rr!r!r"expect_handlerBsz AbstractMatchInfo.expect_handlercCsdS)zr!r!r!r"r<hs r<c@sFeZdZdZeeeeeeee fdddZ eddddZ dS) AbstractResolverzAbstract DNS resolver.)hostportfamilyrcsdS)z$Return IP address for given hostnameNr!)r rArBrCr!r!r"r/{szAbstractResolver.resolveNrcsdS)zRelease resolverNr!rr!r!r"closeszAbstractResolver.close) r0r1r2r?rr;intrr rr/rDr!r!r!r"r@xs "r@c@sneZdZdZddeejddddZedddd Z ee fe e dd d d Z ee d dddZ dS)AbstractCookieJarzAbstract Cookie Jar.N)loop)rGrcCst||_dSr()rZ_loop)r rGr!r!r"r#szAbstractCookieJar.__init__rcCsdS)zClear all cookies.Nr!rr!r!r"clearszAbstractCookieJar.clear)cookies response_urlrcCsdS)zUpdate cookies.Nr!)r rIrJr!r!r"update_cookiessz AbstractCookieJar.update_cookieszBaseCookie[str]) request_urlrcCsdS)z6Return the jar's cookies filtered by their attributes.Nr!)r rLr!r!r"filter_cookiessz AbstractCookieJar.filter_cookies)r0r1r2r?rasyncioZAbstractEventLoopr#rrHrrrKrMr!r!r!r"rFsrFc@seZdZdZdZdZdZeeddddZ ededddd Z edd d d Z ede ddddZ edd ddZee dddddZdS)AbstractStreamWriterzAbstract stream writer.rN)chunkrcsdS)zWrite chunk into stream.Nr!r rPr!r!r"writeszAbstractStreamWriter.writecsdS)zWrite last chunk.Nr!rQr!r!r" write_eofszAbstractStreamWriter.write_eofrcsdS)zFlush the write buffer.Nr!rr!r!r"drainszAbstractStreamWriter.draindeflate)encodingrcCsdS)zEnable HTTP body compressionNr!)r rWr!r!r"enable_compressionsz'AbstractStreamWriter.enable_compressioncCsdS)zEnable HTTP chunked modeNr!rr!r!r"enable_chunkingsz$AbstractStreamWriter.enable_chunkingzCIMultiDict[str]) status_lineheadersrcsdS)zWrite HTTP headersNr!)r rZr[r!r!r" write_headerssz"AbstractStreamWriter.write_headers)rS)rV)r0r1r2r? buffer_sizeZ output_sizelengthrbytesrRrTrUr;rXrYr\r!r!r!r"rOs&rOc@s<eZdZdZejeddddZee e e ddddZ dS) AbstractAccessLoggerzAbstract writer to access log.N)logger log_formatrcCs||_||_dSr()rarb)r rarbr!r!r"r#szAbstractAccessLogger.__init__)r-responsetimercCsdS)zEmit log to logger.Nr!)r r-rcrdr!r!r"logszAbstractAccessLogger.log) r0r1r2r?loggingLoggerr;r#rrrfloatrer!r!r!r"r`sr`)/rNrfabcrrcollections.abcrZ http.cookiesrrtypingrrr r r r r rrrZ multidictrZyarlrZhelpersrZtypedefsrZweb_apprZweb_exceptionsrZ web_requestrrZ web_responserrr+r<r@r;Z IterableBaserFrOr`r!r!r!r"s4 0      , "