+
    TŎiH                         R t ^ RIt^ RIHtHtHtHtHtHt ^RI	H
t
 ^RIHt ^RIHt ^RIHtHtHt ^RIHt R
t ! R	 R4      tR# )zLow level HTTP server.N)Any	AwaitableCallableDictListOptional)AbstractStreamWriter)RawRequestMessage)StreamReader)RequestHandler_RequestFactory_RequestHandler)BaseRequestServerc                      a  ] tR t^t o RRRRRR/V 3R lR llt]V 3R lR	 l4       tV 3R
 lR ltRV 3R lR lltV 3R lR lt	V 3R lR lt
RV 3R lR lltV 3R lR ltRtV tR# )r   request_factoryNhandler_cancellationFloopc                p   < V ^8  d   QhRS[ RS[S[,          RS[RS[S[P
                  ,          RS[RR/# )   handlerr   r   r   kwargsreturnN)r   r   r   boolasyncioAbstractEventLoopr   )format__classdict__s   "a/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/web_server.py__annotate__Server.__annotate__   sW     9 9 9 "/2	9
 #9 w0019 9 
9    c                   T;'       g    \         P                  ! 4       V n        / V n        WPn        ^ V n        Wn        T;'       g    V P                  V n        W0n	        R# )    N)
r   get_running_loop_loop_connections_kwargsrequests_countrequest_handler_make_requestr   r   )selfr   r   r   r   r   s   &&$$$,r   __init__Server.__init__   sU     77W557
EG  &.DD$2D2D$8!r!   c                0   < V ^8  d   QhRS[ S[,          /# r   r   )r   r   )r   r   s   "r   r   r    $   s     . .T.1 .r!   c                H    \        V P                  P                  4       4      # N)listr&   keys)r+   s   &r   connectionsServer.connections#   s    D%%**,--r!   c                >   < V ^8  d   QhRS[ RS[P                  RR/# )r   r   	transportr   N)r   r   	Transport)r   r   s   "r   r   r    '   s+     / /%/292C2C/	/r!   c                "    W P                   V&   R # r1   )r&   )r+   r   r7   s   &&&r   connection_madeServer.connection_made'   s     &/'"r!   c                :   < V ^8  d   QhRS[ RS[S[,          RR/# )r   r   excr   N)r   r   BaseException)r   r   s   "r   r   r    ,   s*     	/ 	/%	/,4],C	/		/r!   c                   a a SS P                   9   dD   SP                  '       d#   SP                  P                  VV 3R  l4       R# S P                   S R# R# )c                 <   < SP                   P                  SR 4      # r1   )r&   pop)fr   r+   s   &r   <lambda>(Server.connection_lost.<locals>.<lambda>2   s    d//33GTBr!   N)r&   _task_handleradd_done_callback)r+   r   r=   s   ff&r   connection_lostServer.connection_lost,   sK     d'''$$$%%77B %%g. (r!   c                <   < V ^8  d   QhRS[ RS[RS[RS[RRRS[/# )r   messagepayloadprotocolwritertaskzasyncio.Task[None]r   )r	   r
   r   r   r   )r   r   s   "r   r   r    7   sO     Q Q"Q Q !	Q
 %Q #Q 
Qr!   c                0    \        WW4WPP                  4      # r1   )r   r%   )r+   rJ   rK   rL   rM   rN   s   &&&&&&r   r*   Server._make_request7   s     7XtZZPPr!   c                   < V ^8  d   QhRR/# )r   r   N )r   r   s   "r   r   r    A   s      d r!   c                L    V P                    F  pVP                  4        K  	  R # r1   )r&   close)r+   conns   & r   pre_shutdownServer.pre_shutdownA   s    %%DJJL &r!   c                4   < V ^8  d   QhRS[ S[,          RR/# )r   timeoutr   N)r   float)r   r   s   "r   r   r    E   s     " "huo " "r!   c                   a"   V3R  lV P                    4       p\        P                  ! V!  G Rj  xL
  V P                   P                  4        R#  L 5i)c              3   D   <"   T F  qP                  S4      x  K  	  R # 5ir1   )shutdown).0rU   rY   s   & r   	<genexpr>"Server.shutdown.<locals>.<genexpr>F   s     F4EDw''4Es    N)r&   r   gatherclear)r+   rY   coross   &f r   r]   Server.shutdownE   s?     FD4E4EFnne$$$! 	%s   .AA!Ac                    < V ^8  d   QhRS[ /# r/   )r   )r   r   s   "r   r   r    J   s     
C 
C. 
Cr!   c                    \        V 3R V P                  /V P                  B #   \         dY    T P                  P	                  4        UUu/ uF  w  rTR9   g   K  YbK  	  Mu uppi ppp\        T 3R T P                  /TB u # i ; i)r   )debugaccess_log_class)r   r%   r'   	TypeErroritems)r+   kvr   s   &   r   __call__Server.__call__J   s    		C!$HTZZH4<<HH 	C !LL..00DA55 0F 
 "$BTZZB6BB	Cs!   !$ (BA#A#""BB)r&   r'   r%   r   r   r)   r(   r1   )__name__
__module____qualname____firstlineno__r,   propertyr4   r:   rG   r*   rV   r]   rm   __static_attributes____classdictcell__)r   s   @r   r   r      s     9 6:	9
 &+9 599 9& . ./ /
	/ 	/Q Q " "

C 
Cr!   )r   )__doc__r   typingr   r   r   r   r   r   abcr   http_parserr	   streamsr
   web_protocolr   r   r   web_requestr   __all__r   rR   r!   r   <module>r~      s6      A A % * ! J J $
EC ECr!   