U
'7` @ sx d dl Z d dlZd dlmZmZ d dlmZ d dlmZm Z d dl
m Z m Z m
Z
mZmZmZmZmZmZmZ d dlmZ d dlmZ dd lmZ dd
lm Z e rdd l m Z dd l m Z dd
l!m"Z"m#Z# ddl$m%Z% nd Z" Z# Z Z%dZ G dd deZ&G dd deZ'G dd deZ(G dd deZ)e r>ee e* Z+neZ+G dd dee+Z,G dd deZ-G dd d eZ.dS ) N)ABCabstractmethod)Sized)
BaseCookieMorsel)
TYPE_CHECKINGAny AwaitableCallableDict GeneratorIterableListOptionalTuple) CIMultiDict)URL )get_running_loop) LooseCookies) Application)
HTTPException) BaseRequestRequest)StreamResponsec @ s^ e Zd ZddddZeddddZeeddd Zddd
d Z e
e d d
ddZ dS )AbstractRouterNreturnc C s
d| _ d S )NFZ_frozenself r! >/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/abc.py__init__$ s zAbstractRouter.__init__appr c C s dS )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' s zAbstractRouter.post_initc C s | j S Nr r r! r! r" frozen/ s zAbstractRouter.frozenc C s
d| _ dS )zFreeze router.TNr r r! r! r" freeze3 s zAbstractRouter.freezeAbstractMatchInforequestr c s dS )z#Return MATCH_INFO for given requestNr! r r- r! r! r" resolve7 s zAbstractRouter.resolve)
__name__
__module__ __qualname__r# r r' propertyboolr) r* r r r/ r! r! r! r" r # s r c @ s e Zd Zeeeegee f dddZ eeeeged f dddZ
eee e dddZ
eeeef dd d
Zeeeed f dd d
ZeeddddZeddddZdS )r+ r c C s dS )z Execute matched request handlerNr! r r! r! r" handler= s zAbstractMatchInfo.handlerNc C s dS )z*Expect handler for 100-continue processingNr! r r! r! r" expect_handlerB s z AbstractMatchInfo.expect_handlerc C s dS )z<HTTPException instance raised on router's resolving, or NoneNr! r r! r! r" http_exceptionG s z AbstractMatchInfo.http_exceptionc C s dS )z;Return a dict with additional info useful for introspectionNr! r r! r! r" get_infoL s zAbstractMatchInfo.get_info.c C s dS )z\Stack of nested applications.
Top level application is left-most element.
Nr! r r! r! r" appsP s zAbstractMatchInfo.appsr$ c C s dS )z)Add application to the nested apps stack.Nr! r& r! r! r" add_appY s zAbstractMatchInfo.add_appc C s dS )zFreeze the match info.
The method is called after route resolution.
After the call .add_app() is forbidden.
Nr! r r! r! r" r* ] s zAbstractMatchInfo.freeze)r0 r1 r2 r3 r r
r r r r5 r6 r r r7 r strr r8 r r r9 r: r* r! r! r! r" r+ < s$ r+ c @ sN e Zd ZdZeddddZeedddZee e
de f dd d
Z dS ) AbstractViewzAbstract class based view.Nr, c C s
|| _ d S r( Z_requestr. r! r! r" r# k s zAbstractView.__init__r c C s | j S )zRequest instance.r= r r! r! r" r- n s zAbstractView.requestc C s dS )zExecute the view handler.Nr! r r! r! r" __await__s s zAbstractView.__await__)
r0 r1 r2 __doc__r r# r3 r- r r r r r> r! r! r! r" r< h s r< c @ sF e Zd ZdZeeeeeeee f dddZ
eddddZ dS ) AbstractResolverzAbstract DNS resolver.)hostportfamilyr c s dS )z$Return IP address for given hostnameNr! )r rA rB rC r! r! r" r/ { s zAbstractResolver.resolveNr c s dS )zRelease resolverNr! r r! r! r" close s zAbstractResolver.close) r0 r1 r2 r? r r; intr r r r/ rD r! r! r! r" r@ x s
"r@ c @ sn e Zd ZdZddeej ddddZedddd Z ee
fe e
dd
d d Z ee
d
dddZ
dS )AbstractCookieJarzAbstract Cookie Jar.N)loop)rG r c C s t || _d S r( )r Z_loop)r rG r! r! r" r# s zAbstractCookieJar.__init__r c C s dS )zClear all cookies.Nr! r r! r! r" clear s zAbstractCookieJar.clear)cookies response_urlr c C s dS )zUpdate cookies.Nr! )r rI rJ r! r! r" update_cookies s z AbstractCookieJar.update_cookieszBaseCookie[str]) request_urlr c C s dS )z6Return the jar's cookies filtered by their attributes.Nr! )r rL r! r! r" filter_cookies s z AbstractCookieJar.filter_cookies)r0 r1 r2 r? r asyncioZAbstractEventLoopr# r rH r r rK rM r! r! r! r" rF s rF c @ s e Zd ZdZdZdZdZeeddddZ ededddd Z
edd
d d Z ede ddddZ
edd
ddZee dddddZdS )AbstractStreamWriterzAbstract stream writer.r N)chunkr c s dS )zWrite chunk into stream.Nr! r rP r! r! r" write s zAbstractStreamWriter.write c s dS )zWrite last chunk.Nr! rQ r! r! r" write_eof s z AbstractStreamWriter.write_eofr c s dS )zFlush the write buffer.Nr! r r! r! r" drain s zAbstractStreamWriter.draindeflate)encodingr c C s dS )z Enable HTTP body compressionNr! )r rW r! r! r" enable_compression s z'AbstractStreamWriter.enable_compressionc C s dS )zEnable HTTP chunked modeNr! r r! r! r" enable_chunking s z$AbstractStreamWriter.enable_chunkingzCIMultiDict[str]) status_lineheadersr c s dS )zWrite HTTP headersNr! )r rZ r[ r! r! r"
write_headers s z"AbstractStreamWriter.write_headers)rS )rV )r0 r1 r2 r? Z buffer_sizeZ output_sizeZlengthr bytesrR rT rU r; rX rY r\ r! r! r! r" rO s& rO c @ s< e Zd ZdZejeddddZee e
e ddddZ dS ) AbstractAccessLoggerz Abstract writer to access log.N)logger
log_formatr c C s || _ || _d S r( )r_ r` )r r_ r` r! r! r" r# s z AbstractAccessLogger.__init__)r- responsetimer c C s dS )zEmit log to logger.Nr! )r r- ra rb r! r! r" log s zAbstractAccessLogger.log)
r0 r1 r2 r? loggingZLoggerr; r# r r r floatrc r! r! r! r" r^ s r^ )/rN rd abcr r Zcollections.abcr Z http.cookiesr r typingr r r r
r r r
r r r Z multidictr Zyarlr Zhelpersr Ztypedefsr Zweb_appr Zweb_exceptionsr Z web_requestr r Z web_responser r r+ r< r@ r; Z IterableBaserF rO r^ r! r! r! r" <module> s4 0
, "