
    rp0jP                         S SK r S SKJrJrJr  SSKJr  SSKJr  SSK	J
r
  \(       a  SSKJr  \\\4r " S S	\ R"                  5      rg)
    N)TYPE_CHECKINGAnycast   )ClientConnectionResetError)set_exception)tcp_nodelay)
HttpParserc                      \ rS rSrSr SS\R                  SSSS4S jjr\S\	4S	 j5       r
\S\	4S
 j5       rSS jrSS jrSS jrS\	4S jrSS\	SS4S jjrS\R"                  SS4S jrS\S-  SS4S jrSS jrSrg)BaseProtocol   )_loop_paused_parser_drain_waiter_connection_lost_reading_paused	_upgraded	transportNloopparserzHttpParser[Any] | Nonereturnc                 b    Xl         SU l        S U l        SU l        X l        SU l        S U l        g NF)r   r   r   r   r   r   r   )selfr   r   s      O/home/wildlama/miniconda3/lib/python3.13/site-packages/aiohttp/base_protocol.py__init__BaseProtocol.__init__   s3     15
:>$37    c                     U R                   SL$ )z&Return True if the connection is open.N)r   r   s    r   	connectedBaseProtocol.connected+   s     ~~T))r   c                     U R                   $ Nr   r!   s    r   writing_pausedBaseProtocol.writing_paused0   s    ||r   c                 8    U R                   (       a   eSU l         g NTr&   r!   s    r   pause_writingBaseProtocol.pause_writing4   s    <<r   c                     U R                   (       d   eSU l         U R                  nUb/  S U l        UR                  5       (       d  UR                  S 5        g g g r   )r   r   done
set_resultr   waiters     r   resume_writingBaseProtocol.resume_writing8   sQ    |||##!%D;;==!!$' ! r   c                     SU l         U R                  (       d)  U R                  c   eU R                  R                  5         U R                  b   U R                  R                  5         g g ! [
         a     g f = fr*   )r   r   r   pause_readingr   PAUSE_RESUME_READING_ERRORSr!   s    r   r5   BaseProtocol.pause_readingB   sk    #~~<<+++LL&&(>>%,,. & /  s   A, ,
A98A9c                     g)zEKeep the transport paused for protocol-specific reasons (overridden).F r!   s    r   _reading_paused_for_msg_queue*BaseProtocol._reading_paused_for_msg_queueP   s    r   resume_parserc                 4   SU l         U R                  (       d  U(       a  U R                  S5        U R                   (       dG  U R                  5       (       d1  U R                  b#   U R                  R                  5         SU l         g g g g ! [         a     Nf = f)NFr   )r   r   data_receivedr:   r   resume_readingr6   )r   r<   s     r   r?   BaseProtocol.resume_readingT   s    $ ~~-s#
 $$6688*--/
 $)D  + 9 % /  s   %B
 

BBr   c                 \    [        [        R                  U5      n[        US5        X l        g r*   )r   asyncio	Transportr	   r   )r   r   trs      r   connection_madeBaseProtocol.connection_madej   s#    '##Y/Br   excc                     S U l         U R                  (       d  g U R                  nUc  g S U l        UR                  5       (       a  g Uc  UR	                  S 5        g [        U[        S5      U5        g NzConnection lost)r   r   r   r.   r/   r   ConnectionError)r   rG   r1   s      r   connection_lostBaseProtocol.connection_losto   sf    ||##>!;;==;d# 12r   c                    #    U R                   c  [        S5      eU R                  (       d  g U R                  nUc   U R                  R                  5       nXl        UI S h  vN   g  N7frI   )r   r   r   r   r   create_futurer0   s     r   _drain_helperBaseProtocol._drain_helper   sT     >>!,->??||##>ZZ--/F!'s   AA)!A'"A))r   r   r   r   r   r   r   r%   )r   N)T)__name__
__module____qualname____firstlineno__	__slots__rB   AbstractEventLoopr   propertyboolr"   r'   r+   r2   r5   r:   r?   BaseTransportrE   BaseExceptionrK   rO   __static_attributes__r9   r   r   r   r      s    	I SW
8--
87O
8	
8 *4 * *   (t )D )D ),)>)> 4 
=4#7 D (	r   r   )rB   typingr   r   r   client_exceptionsr   helpersr   tcp_helpersr	   http_parserr
   AttributeErrorNotImplementedErrorRuntimeErrorr6   Protocolr   r9   r   r   <module>re      sA     + + 9 " $'  ./BLQ y7## yr   