+
    PV-jP  ã                   ó–   € ^ RI t ^ RIHtHtHt ^RIHt ^RIHt ^RI	H
t
 ]'       d   ^RIHt ]]]3t ! R R] P"                  4      tR# )	é    N)ÚTYPE_CHECKINGÚAnyÚcast)ÚClientConnectionResetError)Úset_exception)Útcp_nodelay)Ú
HttpParserc                   ó  a € ] tR t^t o RtRV 3R lR l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RV 3R lR l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# )ÚBaseProtocolNc                ó<   <€ V ^8„  d   QhRS[ P                  RRRR/# )é   ÚloopÚparserzHttpParser[Any] | NoneÚreturnN)ÚasyncioÚAbstractEventLoop)ÚformatÚ__classdict__s   "€Úf/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/aiohttp/base_protocol.pyÚ__annotate__ÚBaseProtocol.__annotate__   s+   ø€ ÷ 
8ñ 
8Ù×-Ñ-ð
8Ø7Oð
8à	ñ
8ó    c                ód   € Wn         R V n        RV n        R V n        W n        R V n        RV n        R# ©FN)Ú_loopÚ_pausedÚ_drain_waiterÚ_reading_pausedÚ_parserÚ	_upgradedÚ	transport)Úselfr   r   s   &&&r   Ú__init__ÚBaseProtocol.__init__   s3   € ð 15Œ
ØˆŒØ:>ˆÔØ$ˆÔØŒØˆŒà37ˆŽ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   1   s   ø€ ÷ ñ ¡ñ r   c                ó   € V P                   # ©N©r   r*   s   &r   Úwriting_pausedÚBaseProtocol.writing_paused0   s   € à�|‰|Ðr   c                ó   <€ V ^8„  d   QhRR/# ©r   r   N© )r   r   s   "€r   r   r   4   s   ø€ ÷ ñ ˜tñ r   c                ó<   € V P                   '       d   Q hR V n         R# ©TNr0   r*   s   &r   Úpause_writingÚBaseProtocol.pause_writing4   s   € Ø—<—<�<ÐÐØˆŽr   c                ó   <€ V ^8„  d   QhRR/# r4   r5   )r   r   s   "€r   r   r   8   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_writing8   sS   € Ø�|�|ˆ|Ðˆ|ØˆŒà×#Ñ#ˆØÒØ!%ˆDÔØ—;‘;—=’=Ø×!Ñ! $Ö'ñ !ñ r   c                ó   <€ V ^8„  d   QhRR/# r4   r5   )r   r   s   "€r   r   r   B   s   ø€ ÷ ñ ˜tñ r   c                ó  € R V n         V P                  '       g+   V P                  f   Q hV P                  P                  4        V P                  e    V P                  P                  4        R# R#   \
         d     R# i ; ir7   )r   r    r   Úpause_readingr!   ÚPAUSE_RESUME_READING_ERRORSr*   s   &r   rD   ÚBaseProtocol.pause_readingB   sm   € Ø#ˆÔà�~�~ˆ~Ø—<‘<Ò+Ð+Ð+Ø�L‰L×&Ñ&Ô(Ø�>‰>Ò%ðØ—‘×,Ñ,Ö.ñ &øô /ô ò ðús   ÁA1 Á1B Á?B c                ó    <€ V ^8„  d   QhRS[ /# r&   r'   )r   r   s   "€r   r   r   P   s   ø€ ÷ ñ ©tñ r   c                ó   € R# )zEKeep the transport paused for protocol-specific reasons (overridden).Fr5   r*   s   &r   Ú_reading_paused_for_msg_queueÚ*BaseProtocol._reading_paused_for_msg_queueP   s   € ár   c                ó$   <€ V ^8„  d   QhRS[ RR/# )r   Úresume_parserr   Nr'   )r   r   s   "€r   r   r   T   s   ø€ ÷ )ñ )©Dð )¸Dñ )r   c                óH  € R V n         V P                  '       g   V'       d   V P                  R4       V P                   '       gM   V P                  4       '       g5   V P                  e%    V P                  P                  4        R V n         R# R# R# R#   \         d     Li ; i)Fr   N)r   r    Údata_receivedrI   r!   Úresume_readingrE   )r"   rL   s   &&r   rO   ÚBaseProtocol.resume_readingT   s�   € Ø$ˆÔð �~�~ˆ~§-Ø×Ñ˜sÔ#ð
 ×$×$Ð$Ø×6Ñ6×8Ò8Ø—‘Ò*ðØ—‘×-Ñ-Ô/ð
 $)ˆDÖ ñ +ñ 9ñ %øô /ô ñ ðús   Á*B ÂB!Â B!c                ó8   <€ V ^8„  d   QhRS[ P                  RR/# )r   r!   r   N)r   ÚBaseTransport)r   r   s   "€r   r   r   j   s!   ø€ ÷ ñ ©×)>Ñ)>ð À4ñ r   c                ó^   € \        \        P                  V4      p\        VR 4       W n        R# r7   )r   r   Ú	Transportr   r!   )r"   r!   Útrs   && r   Úconnection_madeÚBaseProtocol.connection_madej   s#   € Ü”'×#Ñ# YÓ/ˆÜ�B˜ÔØŽr   c                ó2   <€ V ^8„  d   QhRS[ R,          RR/# )r   ÚexcNr   )ÚBaseException)r   r   s   "€r   r   r   o   s    ø€ ÷ ñ ¡=°4Õ#7ð ¸Dñ 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   r<   r=   r   ÚConnectionError)r"   rY   r?   s   && r   Úconnection_lostÚBaseProtocol.connection_losto   sh   € àˆŒØ�|�|ˆ|ÙØ×#Ñ#ˆØŠ>ÙØ!ˆÔØ�;‰;�=Š=ÙØŠ;Ø×Ñ˜dÖ#äØÜÐ 1Ó2Øör   c                ó   <€ V ^8„  d   QhRR/# r4   r5   )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        VG R j  x€L
  R #  L5ir\   )r!   r   r   r   r   Úcreate_futurer>   s   & r   Ú_drain_helperÚBaseProtocol._drain_helperƒ   sV   é € Ø�>‰>Ò!Ü,Ð->Ó?Ð?Ø�|�|ˆ|ÙØ×#Ñ#ˆØŠ>Ø—Z‘Z×-Ñ-Ó/ˆFØ!'ÔØ�Œùs   ‚+A.®7A.Á%A,Á&A.)r   r   r   r   r   r    r!   )r   r   r   r   Ú_connection_lostr   r    r!   r/   )T)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú	__slots__r#   Úpropertyr+   r1   r8   r@   rD   rI   rO   rV   r^   rc   Ú__static_attributes__Ú__classdictcell__)r   s   @r   r   r      sŽ   ø‡ € ð	€I÷
8ò 
8ð ÷*ó ð*ð ÷ó ð÷ð ÷(ð (÷ð ÷ð ÷)ò )÷,ð ÷
ð ÷(	ö 	r   r   )r   Útypingr   r   r   Úclient_exceptionsr   Úhelpersr   Útcp_helpersr   Úhttp_parserr	   ÚAttributeErrorÚNotImplementedErrorÚRuntimeErrorrE   ÚProtocolr   r5   r   r   Ú<module>rw      sA   ðÛ ß +Ñ +å 9Ý "Ý $çÝ'ð  .Ð/BÀLÐQÐ ôy�7×#Ñ#ö yr   