+
    TŎi                     l    ^ RI t ^ RIHtHt ^RIHt ^RIHt ^RIH	t	  ! R R] P                  4      tR# )    N)Optionalcast)ClientConnectionResetError)set_exception)tcp_nodelayc                      a  ] tR t^	t o RtV 3R lR lt]V 3R lR l4       t]V 3R lR l4       tV 3R lR lt	V 3R	 lR
 lt
V 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltRtV tR# )BaseProtocolc                8   < V ^8  d   QhRS[ P                  RR/# )   loopreturnN)asyncioAbstractEventLoop)format__classdict__s   "d/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/base_protocol.py__annotate__BaseProtocol.__annotate__   s!     ; ;W66 ;4 ;    c                J    Wn         R V n        RV n        R V n        RV n        R# FN)_loop_paused_drain_waiter_reading_paused	transport)selfr   s   &&r   __init__BaseProtocol.__init__   s%    04
=A$6:r   c                    < V ^8  d   QhRS[ /# r   r   bool)r   r   s   "r   r   r      s     * *4 *r   c                    V P                   RJ# )z&Return True if the connection is open.N)r   r   s   &r   	connectedBaseProtocol.connected   s     ~~T))r   c                    < V ^8  d   QhRS[ /# r!   r"   )r   r   s   "r   r   r   !   s       r   c                    V P                   # )Nr   r%   s   &r   writing_pausedBaseProtocol.writing_paused    s    ||r   c                   < V ^8  d   QhRR/# r   r   N )r   r   s   "r   r   r   $   s      t r   c                <    V P                   '       d   Q hR V n         R# TNr*   r%   s   &r   pause_writingBaseProtocol.pause_writing$   s    <<<r   c                   < V ^8  d   QhRR/# r.   r/   )r   r   s   "r   r   r   (   s     ( ( (r   c                    V P                   '       g   Q hR V n         V P                  pVe3   RV n        VP                  4       '       g   VP                  R4       R# R# R# r   )r   r   done
set_resultr   waiters   & r   resume_writingBaseProtocol.resume_writing(   sS    ||||##!%D;;==!!$' ! r   c                   < V ^8  d   QhRR/# r.   r/   )r   r   s   "r   r   r   2   s     ( (t (r   c                    V P                   '       g5   V P                  e%    V P                  P                  4        RV n         R # R # R #   \        \        \
        3 d     L%i ; i)NT)r   r   pause_readingAttributeErrorNotImplementedErrorRuntimeErrorr%   s   &r   r>   BaseProtocol.pause_reading2   s[    ###(B,,. $(D  )C# #$7F    A	 	A"!A"c                   < V ^8  d   QhRR/# r.   r/   )r   r   s   "r   r   r   :   s     ) ) )r   c                    V P                   '       d5   V P                  e%    V P                  P                  4        RV n         R # R # R #   \        \        \
        3 d     L%i ; i)NF)r   r   resume_readingr?   r@   rA   r%   s   &r   rF   BaseProtocol.resume_reading:   sZ    DNN$>--/ $)D  %? #$7F rC   c                8   < V ^8  d   QhRS[ P                  RR/# )r   r   r   N)r   BaseTransport)r   r   s   "r   r   r   B   s!      )>)> 4 r   c                ^    \        \        P                  V4      p\        VR 4       W n        R# r1   )r   r   	Transportr   r   )r   r   trs   && r   connection_madeBaseProtocol.connection_madeB   s#    '##Y/Br   c                4   < V ^8  d   QhRS[ S[,          RR/# )r   excr   N)r   BaseException)r   r   s   "r   r   r   G   s       8M#: t r   c                    R V n         V P                  '       g   R # V P                  pVf   R # R V n        VP                  4       '       d   R # Vf   VP	                  R 4       R # \        V\        R4      V4       R # NzConnection lost)r   r   r   r6   r7   r   ConnectionError)r   rP   r9   s   && r   connection_lostBaseProtocol.connection_lostG   sh    |||##>!;;==;d# 12r   c                   < V ^8  d   QhRR/# r.   r/   )r   r   s   "r   r   r   [   s     	% 	%T 	%r   c                  "   V P                   f   \        R4      hV P                  '       g   R # V P                  pVf!   V P                  P                  4       pWn        \        P                  ! V4      G R j  xL
  R #  L5irS   )r   r   r   r   r   create_futurer   shieldr8   s   & r   _drain_helperBaseProtocol._drain_helper[   sa     >>!,->??|||##>ZZ--/F!'nnV$$$s   +BAB9B :B)r   r   r   r   r   N)r   r   r   _connection_lostr   r   )__name__
__module____qualname____firstlineno__	__slots__r   propertyr&   r+   r2   r:   r>   rF   rM   rU   r[   __static_attributes____classdictcell__)r   s   @r   r	   r	   	   s     I; ; * *   ( (( () ) 
 (	% 	%r   r	   )r   typingr   r   client_exceptionsr   helpersr   tcp_helpersr   Protocolr	   r/   r   r   <module>rk      s(     ! 9 " $[%7## [%r   