+
    PV-jY1  ã            	       óÚ   € ^ RI t ^ RIHt ^ RIHtHt ^RIHt ^RIH	t	H
t
HtHtHt ^RIHtHtHtHtHtHt ^RIHtHt ^RIHt ^R	IHtHtHt  ! R
 R]]]]]3,          ,          4      tR# )é    N)Úsuppress©ÚAnyÚCallable)ÚBaseProtocol)ÚClientConnectionErrorÚClientOSErrorÚClientPayloadErrorÚServerDisconnectedErrorÚSocketTimeoutError)Ú_EXC_SENTINELÚDEFAULT_CHUNK_SIZEÚEMPTY_BODY_STATUS_CODESÚBaseTimerContextÚset_exceptionÚ
set_result)ÚHttpResponseParserÚRawResponseMessage)ÚHttpProcessingError)ÚEMPTY_PAYLOADÚ	DataQueueÚStreamReaderc                   óN  a 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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V 3R lltV3R lR ltV3R lV 3R lltR=V3R lV 3R lllt]3V3R lV 3R llltR>V3R lR lltR RR!R"R#R"R$RR%RR&]R'^R(R)R*R)R+^€/
V3R, lR- lltV3R. lR/ ltV3R0 lR1 ltV3R2 lR3 lt]V3R4 lR5 l4       t]P6                  V3R6 lR7 l4       tV3R8 lR9 ltV3R: lR; ltR<tVtV ;t # )?ÚResponseHandlerz8Helper class to adapt between Protocol and StreamReader.c                ó8   <€ V ^8„  d   QhRS[ P                  RR/# )é   ÚloopÚreturnN)ÚasyncioÚAbstractEventLoop)ÚformatÚ__classdict__s   "€Úe/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/aiohttp/client_proto.pyÚ__annotate__ÚResponseHandler.__annotate__   s!   ø€ ÷ -ñ -™W×6Ñ6ð -¸4ñ -ó    c                ó
  € \         P                  ! WR R7       \        P                  ! W4       RV n        R V n        RV n        R V n        R V n        R V n        RV n	        R V n
        R V n        ^V n        R V n        RV n        R # )N)r   ÚparserFr&   )r   Ú__init__r   Ú_should_closeÚ_payloadÚ_skip_payloadÚ_payload_parserÚ_data_received_cbÚ_timerÚ_tailÚ_read_timeoutÚ_read_timeout_handleÚ_timeout_ceil_thresholdÚ_closedÚ_connection_lost_called)Úselfr   s   &&r#   r)   ÚResponseHandler.__init__   s|   € Ü×Ò˜d°dÕ;Ü×Ò˜4Ô&à"ˆÔà-1ˆŒØ"ˆÔØ#ˆÔØ<@ˆÔàˆŒØˆŒ
à+/ˆÔØ@DˆÔ!à56ˆÔ$à48ˆŒØ',ˆÖ$r&   c                óP   <€ V ^8„  d   QhRRS[ P                  R,          ,          /# ©r   r   N)r   ÚFuture)r!   r"   s   "€r#   r$   r%   4   s"   ø€ ÷ ñ ˜™wŸ~™~¨dÕ3Õ3ñ r&   c                ó˜   € V P                   f2   V P                  '       g    V P                  P                  4       V n         V P                   # )aî  Future that is set when the connection is closed.

This property returns a Future that will be completed when the connection
is closed. The Future is created lazily on first access to avoid creating
futures that will never be awaited.

Returns:
    - A Future[None] if the connection is still open or was closed after
      this property was accessed
    - None if connection_lost() was already called before this property
      was ever accessed (indicating no one is waiting for the closure)
)r4   r5   Ú_loopÚcreate_future©r6   s   &r#   ÚclosedÚResponseHandler.closed3   s7   € ð �<‰<Ò¨×(D×(DÐ(DØŸ:™:×3Ñ3Ó5ˆDŒLØ�|‰|Ðr&   c                ó    <€ V ^8„  d   QhRS[ /# ©r   r   ©Úbool)r!   r"   s   "€r#   r$   r%   F   s   ø€ ÷ ñ ™$ñ r&   c                ó   € V P                   # ©N)Ú	_upgradedr>   s   &r#   ÚupgradedÚResponseHandler.upgradedE   s   € à�~‰~Ðr&   c                ó    <€ V ^8„  d   QhRS[ /# rB   rC   )r!   r"   s   "€r#   r$   r%   J   s   ø€ ÷ 	
ñ 	
™dñ 	
r&   c                óv  € \        V P                  ;'       gž    V P                  R J;'       d(    V P                  P                  4       '       * ;'       ga    V P                  ;'       gM    V P
                  R J;'       g7    V P                  R J;'       g!    V P                  ;'       g    V P                  4      # rF   )	rD   r*   r+   Úis_eofrG   Ú
_exceptionr-   Ú_bufferr0   r>   s   &r#   Úshould_closeÚResponseHandler.should_closeI   s¯   € äØ×Ñ÷ ð Ø—‘ TÐ)×HÐH°$·-±-×2FÑ2FÓ2HÔ.H÷ð à�~‰~÷ð ð �‰ dÐ*÷ð ð ×#Ñ#¨4Ð/÷	ð ð
 �|‰|÷ð ð �z‰zó
ð 	
r&   c                ó   <€ V ^8„  d   QhRR/# r9   © )r!   r"   s   "€r#   r$   r%   U   s   ø€ ÷ "ñ "˜Tñ "r&   c                ó   € R V n         R# ©TN)r*   r>   s   &r#   Úforce_closeÚResponseHandler.force_closeU   s
   € Ø!ˆÖr&   c                ó   <€ V ^8„  d   QhRR/# r9   rR   )r!   r"   s   "€r#   r$   r%   X   ó   ø€ ÷ !ñ !�tñ !r&   c                ó”   € R V n         V P                  pVe1   VP                  4        R V n        R V n        V P	                  4        R # R # rF   )rM   Ú	transportÚcloser+   Ú_drop_timeout©r6   rZ   s   & r#   r[   ÚResponseHandler.closeX   óA   € ØˆŒØ—N‘Nˆ	ØÒ Ø�O‰OÔØ!ˆDŒNØ ˆDŒMØ×ÑÖ ñ	 !r&   c                ó   <€ V ^8„  d   QhRR/# r9   rR   )r!   r"   s   "€r#   r$   r%   a   rX   r&   c                ó”   € R V n         V P                  pVe1   VP                  4        R V n        R V n        V P	                  4        R # R # rF   )rM   rZ   Úabortr+   r\   r]   s   & r#   rb   ÚResponseHandler.aborta   r_   r&   c                ó    <€ V ^8„  d   QhRS[ /# rB   rC   )r!   r"   s   "€r#   r$   r%   j   s   ø€ ÷ Nñ N™dñ Nr&   c                ól   € V P                   R J;'       d     V P                   P                  4       '       * # rF   )rZ   Ú
is_closingr>   s   &r#   Úis_connectedÚResponseHandler.is_connectedj   s)   € Ø�~‰~ TÐ)×MÐM°$·.±.×2KÑ2KÓ2MÔ.MÐMr&   c                ó2   <€ V ^8„  d   QhRS[ R,          RR/# )r   ÚexcNr   ©ÚBaseException)r!   r"   s   "€r#   r$   r%   m   s$   ø€ ÷ I.ñ I.¡=°4Õ#7ð I.¸Dñ I.r&   c                ó  <€ R V n         V P                  4        TpTpVRJ pV P                  eJ   V'       d   \        V P                  R4       M*Vf   Q h\	        V P                  \        RV: 24      V4       V P                  e;   \        \        4      ;_uu_ 4        V P                  P                  4        RRR4       RpV P                  e    V P                  P                  4       pV P                  4       '       gj   \        V\        4      '       d   \!        VP"                  !  pV'       d   \%        V4      pV'       d   \&        MTpVf   Q hVf   Q hV P	                  W84       R V n        RV n
        RV n        RV n        RV n        \,        S	V `]  V4       R#   + '       g   i     Lî; i  \         dQ   pT P                  e8   RT: 2pT'       g
   T: RT: 2p\	        T P                  \        T4      T4        Rp?ELRp?ii ; i)TNzConnection lost: z#Response payload is not completed: z. F)r5   r\   r4   r   r   r   r-   r   Ú	ExceptionÚfeed_eofÚ_parserr+   r
   rL   Ú
isinstanceÚOSErrorr	   Úargsr   r   r*   Ú_reading_pausedÚsuperÚconnection_lost)
r6   rj   Úoriginal_connection_errorÚreraised_excÚconnection_closed_cleanlyÚuncompletedÚunderlying_excÚclient_payload_exc_msgÚunderlying_non_eof_excÚ	__class__s
   &&       €r#   rv   ÚResponseHandler.connection_lostm   sì  ø€ Ø'+ˆÔ$Ø×ÑÔà$'Ð!Ø0ˆà$=ÀÐ$EÐ!à�<‰<Ò#÷ )Ü˜4Ÿ<™<¨Õ.à0Ò<Ð<Ð<ÜØ—L‘LÜ)Ø+Ð,EÑ+IÐJóð .ôð ×ÑÒ+Üœ)×$Õ$Ø×$Ñ$×-Ñ-Ô/÷ %ð ˆØ�<‰<Ò#ðØ"Ÿl™l×3Ñ3Ó5�ð" �{‰{�}Š}ÜÐ3´W×=Ò=Ü,Ð.G×.LÑ.LÑM�ß(Ü6°{ÓC�÷
 -õ à.ð #ð
 *Ò5Ð5Ð5ØÒ+Ð+Ð+Ø×Ñ˜|ÔDà!ˆÔØˆŒØˆŒØ#ˆÔØ$ˆÔä‰Ñ Ö-÷[ %×$ûô ô Ø—=‘=Ò,à=¸nÑ=PÐQð +÷ 5à5Ñ9¸Ø8Ñ<ð>ð /ô "ØŸ™Ü*Ð+AÓBØ&ôÿùðús*   ÂFÃF1 ÆF.	Æ1HÆ<HÇ)HÈHc                ó   <€ V ^8„  d   QhRR/# r9   rR   )r!   r"   s   "€r#   r$   r%   ¸   s   ø€ ÷ ñ ˜dñ r&   c                ó&   € V P                  4        R # rF   )r\   r>   s   &r#   Úeof_receivedÚResponseHandler.eof_received¸   s   € à×ÑÖr&   c                ó   <€ V ^8„  d   QhRR/# r9   rR   )r!   r"   s   "€r#   r$   r%   ¼   s   ø€ ÷ ñ ˜tñ r&   c                óD   <€ \         SV `  4        V P                  4        R # rF   )ru   Úpause_readingr\   )r6   r~   s   &€r#   r†   ÚResponseHandler.pause_reading¼   s   ø€ Ü‰ÑÔØ×ÑÖr&   Tc                ó$   <€ V ^8„  d   QhRS[ RR/# )r   Úresume_parserr   NrC   )r!   r"   s   "€r#   r$   r%   À   s   ø€ ÷ #ñ #©Dð #¸Dñ #r&   c                óF   <€ \         SV `  V4       V P                  4        R # rF   )ru   Úresume_readingÚ_reschedule_timeout)r6   r‰   r~   s   &&€r#   r‹   ÚResponseHandler.resume_readingÀ   s   ø€ Ü‰Ñ˜}Ô-Ø× Ñ Ö"r&   c                ó*   <€ V ^8„  d   QhRS[ RS[ RR/# )r   rj   Ú	exc_causer   Nrk   )r!   r"   s   "€r#   r$   r%   Ä   s)   ø€ ÷ .ñ .áð.ñ !ð.ð 
ñ	.r&   c                óT   <€ R V n         V P                  4        \        SV `  W4       R# rT   )r*   r\   ru   r   )r6   rj   r�   r~   s   &&&€r#   r   ÚResponseHandler.set_exceptionÄ   s&   ø€ ð
 "ˆÔØ×ÑÔÜ‰Ñ˜cÖ-r&   Nc                óP   <€ V ^8„  d   QhRS[ RS[ RS[. R3,          R,          RR/# )r   r(   ÚpayloadÚdata_received_cbNr   r   )r!   r"   s   "€r#   r$   r%   Í   sA   ø€ ÷ %ñ %áð%ñ ð%ñ # 2 t 8Õ,¨tÕ3ð	%ð
 
ñ%r&   c                óº   € W n         Wn        W0n        V P                  4        V P                  '       d'   V P                  R uq@n        V P                  V4       R# R# )r&   N)r+   r-   r.   r\   r0   Údata_received)r6   r(   r“   r”   Údatas   &&&& r#   Ú
set_parserÚResponseHandler.set_parserÍ   sM   € ð  ŒØ%ÔØ!1Ôà×ÑÔà�:�:ˆ:Ø#Ÿz™z¨3ÐˆD”*Ø×Ñ˜tÖ$ñ r&   ÚtimerÚskip_payloadFÚread_until_eofÚauto_decompressÚread_timeoutÚread_bufsizeÚtimeout_ceil_thresholdÚmax_line_sizeiþ  Úmax_field_sizeÚmax_headersc                óv   <€ V ^8„  d   QhRS[ R,          RS[RS[RS[RS[R,          RS[RS[R	S[R
S[RS[RR/# )r   rš   Nr›   rœ   r�   rž   rŸ   r    r¡   r¢   r£   r   )r   rD   ÚfloatÚint)r!   r"   s   "€r#   r$   r%   â   s„   ø€ ÷ $%ñ $%ñ   $Õ&ð$%ñ ð	$%ñ
 ð$%ñ ð$%ñ ˜d•lð$%ñ ð$%ñ !&ð$%ñ ð$%ñ ð$%ñ ð$%ð 
ñ$%r&   c       
        óö   € W n         WPn        Wpn        \        V V P                  VV\
        V'       * VVVV	V
R 7      V n        V P                  '       d'   V P                  Ruq°n        V P                  V4       R# R# ))rš   Úpayload_exceptionÚresponse_with_bodyrœ   r�   r¡   r¢   r£   r&   N)	r,   r1   r3   r   r<   r
   rp   r0   r–   )r6   rš   r›   rœ   r�   rž   rŸ   r    r¡   r¢   r£   r—   s   &$$$$$$$$$$ r#   Úset_response_paramsÚ#ResponseHandler.set_response_paramsâ   sx   € ð *Ôà)Ôà'=Ô$ä)ØØ�J‰JØØÜ0Ø#/Ô/Ø)Ø+Ø'Ø)Ø#ô
ˆŒð �:�:ˆ:Ø#Ÿz™z¨3ÐˆD”*Ø×Ñ˜tÖ$ñ r&   c                ó   <€ V ^8„  d   QhRR/# r9   rR   )r!   r"   s   "€r#   r$   r%     s   ø€ ÷ -ñ -˜tñ -r&   c                óh   € V P                   e$   V P                   P                  4        R V n         R # R # rF   )r2   Úcancelr>   s   &r#   r\   ÚResponseHandler._drop_timeout  s-   € Ø×$Ñ$Ò0Ø×%Ñ%×,Ñ,Ô.Ø(,ˆDÖ%ñ 1r&   c                ó   <€ V ^8„  d   QhRR/# r9   rR   )r!   r"   s   "€r#   r$   r%     s   ø€ ÷ 
-ñ 
- Tñ 
-r&   c                óä   € V P                   pV P                  e   V P                  P                  4        V'       d-   V P                  P	                  WP
                  4      V n        R # R V n        R # rF   )r1   r2   r®   r<   Ú
call_laterÚ_on_read_timeout)r6   Útimeouts   & r#   rŒ   Ú#ResponseHandler._reschedule_timeout  sX   € Ø×$Ñ$ˆØ×$Ñ$Ò0Ø×%Ñ%×,Ñ,Ô.çØ(,¯
©
×(=Ñ(=Ø×.Ñ.ó)ˆDÖ%ð )-ˆDÖ%r&   c                ó   <€ V ^8„  d   QhRR/# r9   rR   )r!   r"   s   "€r#   r$   r%     s   ø€ ÷ #ñ #˜tñ #r&   c                ó&   € V P                  4        R # rF   )rŒ   r>   s   &r#   Ústart_timeoutÚResponseHandler.start_timeout  s   € Ø× Ñ Ö"r&   c                ó.   <€ V ^8„  d   QhRS[ R,          /# r9   ©r¥   )r!   r"   s   "€r#   r$   r%     s   ø€ ÷ "ñ "™e d�lñ "r&   c                ó   € V P                   # rF   ©r1   r>   s   &r#   rž   ÚResponseHandler.read_timeout  s   € à×!Ñ!Ð!r&   c                ó2   <€ V ^8„  d   QhRS[ R,          RR/# )r   rž   Nr   r»   )r!   r"   s   "€r#   r$   r%   !  s   ø€ ÷ *ñ *©°­ð *¸$ñ *r&   c                ó   € Wn         R # rF   r½   )r6   rž   s   &&r#   rž   r¾      s   € à)Ör&   c                ó   <€ V ^8„  d   QhRR/# r9   rR   )r!   r"   s   "€r#   r$   r%   $  s   ø€ ÷ .ñ . $ñ .r&   c                óŠ   € \        R 4      pV P                  V4       V P                  e   \        V P                  V4       R# R# )z#Timeout on reading data from socketN)r   r   r+   )r6   rj   s   & r#   r³   Ú ResponseHandler._on_read_timeout$  s8   € Ü Ð!FÓGˆØ×Ñ˜3ÔØ�=‰=Ò$Ü˜$Ÿ-™-¨Ö-ñ %r&   c                ó$   <€ V ^8„  d   QhRS[ RR/# )r   r—   r   N)Úbytes)r!   r"   s   "€r#   r$   r%   *  s   ø€ ÷ H%ñ H%¡%ð H%¨Dñ H%r&   c                ó  € V'       d   V P                  4        V P                  em   V P                  e   V P                  4        V P                  P                  V4      w  r#V'       d(   R V n        R V n        V'       d   V P                  V4       R # V P                  '       g   V P                  f   V ;P                  V,          un        R #  V P                  P                  V4      w  rEpYPn        R pT Fx  w  r˜T	P&                  '       d   RT n        Y€n        T P*                  '       g   T	P                  \,        9   d   T P                  T	\.        3^ 4       Ke  T P                  Y˜3^ 4       Kz  	  Te7   T\.        Jd   TP1                  T P2                  4       MT P3                  4        T'       d   T'       d   T P                  T4       R # R # R #   \         d©   pT P                  e   T P                  P                  4        \        T\        4      '       g   h \        T\        4      '       d.   \        TP                  TP                   TP"                  R7      pM
\        4       pT P%                  Yv4        R p?R # R p?ii ; i)N)ÚcodeÚmessageÚheadersT)rŒ   r-   r.   Ú	feed_datar+   r–   rG   rp   r0   rl   rZ   r[   rq   rn   r   rÇ   rÈ   rÉ   r   rO   r*   r,   r   r   Úon_eofr\   )
r6   r—   ÚeofÚtailÚmessagesrH   r{   rj   r“   rÈ   s
   &&        r#   r–   ÚResponseHandler.data_received*  sý  € ÷ Ø×$Ñ$Ô&ð ×ÑÒ+Ø×%Ñ%Ò1Ø×&Ñ&Ô(Ø×,Ñ,×6Ñ6°tÓ<‰IˆCßØ $�”Ø'+�Ô$çØ×&Ñ& tÔ,Ùà�>�>ˆ>˜TŸ\™\Ò1à�JŠJ˜$Õ�JÙð	Ø'+§|¡|×'=Ñ'=¸dÓ'CÑ$ˆH ð* "Œà'+ˆÛ (ÑˆGØ×#×#Ð#Ø%)�Ô"à#ŒMà×!×!Ð! W§\¡\Ô5LÔ%LØ—‘ ¬Ð7¸Ö;à—‘ Ð1°1Ö5ñ !)ð Òð
 œmÓ+Ø—‘˜t×1Ñ1Õ2à×"Ñ"Ô$çŸØ×Ñ˜tÖ$ñ ‰8øôY ô 	Ø�~‰~Ò)ð —‘×$Ñ$Ô&Ü˜n¬i×8Ò8Øä˜.Ô*=×>Ò>Ü)Ø'×,Ñ,Ø*×2Ñ2Ø*×2Ñ2ô‘ô *Ó+�Ø×Ñ˜sÔ3Ýûð%	ús   ÃG ÇJÇBJÊJ)r4   r5   r.   rM   rp   r+   r-   r1   r2   rt   r*   r,   r0   r3   r/   rG   rZ   )TrF   )!Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r)   Úpropertyr?   rH   rO   rU   r[   rb   rg   rv   r‚   r†   r‹   r   r   r˜   r   rª   r\   rŒ   r¸   rž   Úsetterr³   r–   Ú__static_attributes__Ú__classdictcell__Ú__classcell__)r~   r"   s   @@r#   r   r      s“  ù‡ € ÙB÷-ð -ð, ÷ó ðð" ÷ó ðð ÷	
ó ð	
÷"ð "÷!ð !÷!ð !÷Nð N÷I.ó I.÷Vð ÷ó ÷#õ #ð $1÷.õ .÷%ò %ð*$%ð *.ð$%ð #ð	$%ð
  %ð$%ð !%ð$%ð &*ð$%ð /ð$%ð )*ð$%ð "ð$%ð #ð$%ð ÷$%ò $%÷L-ð -÷

-ð 
-÷#ð #ð ÷"ó ð"ð ×Ñ÷*ó ð*÷.ð .÷H%÷ H%ð H%r&   r   ) r   Ú
contextlibr   Útypingr   r   Úbase_protocolr   Úclient_exceptionsr   r	   r
   r   r   Úhelpersr   r   r   r   r   r   Úhttpr   r   Úhttp_exceptionsr   Ústreamsr   r   r   Útupler   rR   r&   r#   Ú<module>rã      sS   ðÛ Ý ß  å '÷õ ÷÷ ÷ 9Ý 0ß ;Ñ ;ôX%�l I¨eÐ4FÈÐ4TÕ.UÕ$Vö X%r&   