ó
    Û°›jP  ã                   ó’   • 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      ÚR/home/mande/repo/quber/.venv/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   € Ø#ˆÔà�~�~Ø—<‘<Ñ+Ð+Ð+Ø�L‰L×&Ñ&Ô(Ø�>‰>Ñ%ðØ—‘×,Ñ,Õ.ð &øô /ó ñ ðú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   é € Ø�>‰>Ñ!Ü,Ð->Ó?Ð?Ø�|�|ØØ×#Ñ#ˆØ‰>Ø—Z‘Z×-Ñ-Ó/ˆ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Ø×-Ñ-ð
8Ø7Oð
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Ý "Ý $æÝ'ð  .Ð/BÀLÐQÐ ôy�7×#Ñ#õ yr   