
    h                     j    S SK r S SKJrJr  SSKJr  SSKJr  SSKJ	r	   " S S\ R                  5      rg)	    N)Optionalcast   )ClientConnectionResetError)set_exception)tcp_nodelayc                       \ rS rSrSrS\R                  SS4S 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S jrS\R                   SS4S jrS\\   SS4S jrSS jrSrg)BaseProtocol	   )_loop_paused_drain_waiter_connection_lost_reading_paused	transportloopreturnNc                 H    Xl         SU l        S U l        SU l        S U l        g NF)r   r   r   r   r   )selfr   s     G/var/www/html/env/lib/python3.13/site-packages/aiohttp/base_protocol.py__init__BaseProtocol.__init__   s%    04
=A$6:    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_paused    s    ||r   c                 8    U R                   (       a   eSU l         g NTr    r   s    r   pause_writingBaseProtocol.pause_writing$   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_writing(   sQ    |||##!%D;;==!!$' ! r   c                     U R                   (       d1  U R                  b#   U R                  R                  5         SU l         g g g ! [        [        [
        4 a     N!f = fr$   )r   r   pause_readingAttributeErrorNotImplementedErrorRuntimeErrorr   s    r   r/   BaseProtocol.pause_reading2   sX    ##(B,,. $(D  )C# #$7F    A AAc                     U R                   (       a1  U R                  b#   U R                  R                  5         SU l         g g g ! [        [        [
        4 a     N!f = fr   )r   r   resume_readingr0   r1   r2   r   s    r   r6   BaseProtocol.resume_reading:   sW    DNN$>--/ $)D  %? #$7F r4   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_madeB   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   r>   r+   s      r   connection_lostBaseProtocol.connection_lostG   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        [        R                  " U5      I S h  vN   g  N7fr@   )r   r   r   r   r   create_futurer9   shieldr*   s     r   _drain_helperBaseProtocol._drain_helper[   s_     >>!,->??||##>ZZ--/F!'nnV$$$s   A3A=5A;6A=)r   r   r   r   r   )r   N)__name__
__module____qualname____firstlineno__	__slots__r9   AbstractEventLoopr   propertyboolr   r!   r%   r,   r/   r6   BaseTransportr<   r   BaseExceptionrB   rG   __static_attributes__ r   r   r
   r
   	   s    I;W66 ;4 ; *4 * *   (())>)> 4 
8M#: t (	%r   r
   )r9   typingr   r   client_exceptionsr   helpersr   tcp_helpersr   Protocolr
   rT   r   r   <module>rZ      s(     ! 9 " $[%7## [%r   