+
    PV-j:1  ã                   ó¸  € R t ^ RIt^ RIt^ RIt^ RIHtHtHtHtH	t	H
t
HtHt ^ RIHt ^RIHt ^RIHt ^RIHt ^RIHt ^RIHt Rt]P4                  R8¼  d   ^ RIHt M^ RIHt ]]]RR3,          tRt R]P4                  u;8*  ;'       d    R8  Mu t!]P4                  R8  t"]!;'       g    ]"t# ! R R
]4      t$]$! ^^ 4      t%]$! ^^4      t&]]].]R,          3,          ,          t']]R.]R,          3,          ,          t( ! R R	]4      t)]PT                  ! R4      t+R R lt,R R lt-]-t. ^ RI/H0t0 ]0P\                  t1]'       g   ]1t.R# R#   ]2 d     R# i ; i)z"Http related parsers and protocol.N)ÚTYPE_CHECKINGÚAnyÚ	AwaitableÚCallableÚIterableÚListÚ
NamedTupleÚOptional)ÚCIMultiDict)ÚAbstractStreamWriter©ÚBaseProtocol)ÚClientConnectionResetError)ÚZLibCompressor)ÚNO_EXTENSIONSÚStreamWriterÚHttpVersion©ÚBuffer)ÚUnionzmemoryview[int]zmemoryview[bytes]i   c                   ó,   a € ] tR t^.t o V 3R ltRtV tR# )r   c                ó2   <€ V ^8„  d   Qh/ S[ ;R&   S[ ;R&   # )é   ÚmajorÚminor)Úint)ÚformatÚ__classdict__s   "€Úd/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/aiohttp/http_writer.pyÚ__annotate__ÚHttpVersion.__annotate__.   s   ø‡ ‚ Ù�Jñ á�Jò ó    © N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__annotate_func__Ú__static_attributes__Ú__classdictcell__©r   s   @r   r   r   .   s   ø‡ ‡ „ r!   úCIMultiDict[str]c                   óv  a € ] tR t^;t o RtRtRt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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V 3R lR ltRRR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)V 3R! lR" lltV 3R# lR$ ltV 3R% ltR&tV tR# )*r   NFc          
      óJ   <€ V ^8„  d   QhRS[ RS[P                  RS[RS[RR/# )r   ÚprotocolÚloopÚon_chunk_sentÚon_headers_sentÚreturnN)r   ÚasyncioÚAbstractEventLoopÚ_T_OnChunkSentÚ_T_OnHeadersSent)r   r   s   "€r   r   ÚStreamWriter.__annotate__B   sC   ø€ ÷ ,ñ ,áð,ñ ×'Ñ'ð,ñ &ð	,ñ
 *ð,ð 
ñ,r!   c                óR   € Wn         W n        W0n        W@n        R V n        RV n        R # )NF)Ú	_protocolr/   Ú_on_chunk_sentÚ_on_headers_sentÚ_headers_bufÚ_headers_written)Úselfr.   r/   r0   r1   s   &&&&&r   Ú__init__ÚStreamWriter.__init__B   s*   € ð "ŒØŒ	Ø.;ÔØ2AÔØ*.ˆÔØ&+ˆÖr!   c                óB   <€ V ^8„  d   QhRS[ P                  R,          /# ©r   r2   N)r3   Ú	Transport)r   r   s   "€r   r   r7   Q   s   ø€ ÷ (ñ (™7×,Ñ,¨tÕ3ñ (r!   c                ó.   € V P                   P                  # ©N)r9   Ú	transport©r>   s   &r   rF   ÚStreamWriter.transportP   s   € à�~‰~×'Ñ'Ð'r!   c                ó    <€ V ^8„  d   QhRS[ /# )r   r2   r   )r   r   s   "€r   r   r7   U   s   ø€ ÷ ñ ™,ñ r!   c                ó   € V P                   # rE   )r9   rG   s   &r   r.   ÚStreamWriter.protocolT   s   € à�~‰~Ðr!   c                ó   <€ V ^8„  d   QhRR/# rB   r"   )r   r   s   "€r   r   r7   X   s   ø€ ÷ ñ  ñ r!   c                ó   € R V n         R# )TN)ÚchunkedrG   s   &r   Úenable_chunkingÚStreamWriter.enable_chunkingX   s	   € ØˆŽr!   c                ó8   <€ V ^8„  d   QhRS[ RS[R,          RR/# )r   ÚencodingÚstrategyNr2   )Ústrr   )r   r   s   "€r   r   r7   [   s.   ø€ ÷ Nñ NÙðNÙ36¸µ:ðNà	ñNr!   c                ó(   € \        WR 7      V n        R# ))rR   rS   N)r   Ú	_compress)r>   rR   rS   s   &&&r   Úenable_compressionÚStreamWriter.enable_compression[   s   € ô (°ÔMˆŽr!   c                ó$   <€ V ^8„  d   QhRS[ RR/# ©r   Úchunkr2   Nr   )r   r   s   "€r   r   r7   `   s   ø€ ÷ ñ ™Fð  tñ r!   c                ó  € \        V4      pV ;P                  V,          un        V ;P                  V,          un        V P                  P                  pVe   VP                  4       '       d   \        R4      hVP                  V4       R # )Nú!Cannot write to closing transport)ÚlenÚbuffer_sizeÚoutput_sizer9   rF   Ú
is_closingr   Úwrite)r>   r[   ÚsizerF   s   &&  r   Ú_writeÚStreamWriter._write`   sh   € Ü�5‹zˆØ×Ò˜DÕ ÕØ×Ò˜DÕ ÕØ—N‘N×,Ñ,ˆ	ØÒ 	× 4Ñ 4× 6Ò 6Ü,Ð-PÓQÐQØ�‰˜Ör!   c                ó4   <€ V ^8„  d   QhRS[ S[,          RR/# )r   Úchunksr2   N)r   r   )r   r   s   "€r   r   r7   i   s    ø€ ÷ )ñ )¡(©6Õ"2ð )°tñ )r!   c                ó®  € ^ pV F  pV\        V4      ,          pK  	  V ;P                  V,          un        V ;P                  V,          un        V P                  P                  pVe   VP                  4       '       d   \        R4      h\        '       g   V\        8  d#   VP                  RP                  V4      4       R# VP                  V4       R# )é    Nr]   r!   )r^   r_   r`   r9   rF   ra   r   ÚSKIP_WRITELINESÚMIN_PAYLOAD_FOR_WRITELINESrb   ÚjoinÚ
writelines)r>   rg   rc   r[   rF   s   &&   r   Ú_writelinesÚStreamWriter._writelinesi   s    € ØˆÛˆEØ”C˜“JÕŠDñ à×Ò˜DÕ ÕØ×Ò˜DÕ ÕØ—N‘N×,Ñ,ˆ	ØÒ 	× 4Ñ 4× 6Ò 6Ü,Ð-PÓQÐQß‹?˜dÔ%?Ô?Ø�O‰O˜CŸH™H VÓ,Ö-à× Ñ  Ö(r!   c                ó$   <€ V ^8„  d   QhRS[ RR/# rZ   r   )r   r   s   "€r   r   r7   w   s   ø€ ÷ :ñ :©Fð :°tñ :r!   c                óh   € \        V4      R R2P                  R4      pV P                  W!R34       R# )z+Write a chunk with proper chunked encoding.Úxú
Úasciió   
N)r^   Úencodern   )r>   r[   Úchunk_len_pres   && r   Ú_write_chunked_payloadÚ#StreamWriter._write_chunked_payloadw   s2   € ä˜u›: a˜.¨Ð-×4Ñ4°WÓ=ˆØ×Ñ˜-°Ð8Ö9r!   c                ó*   <€ V ^8„  d   QhRS[ RS[RR/# )r   r[   Úis_eofr2   N)r   Úbool)r   r   s   "€r   r   r7   |   s"   ø€ ÷ %ñ %±ð %Áð %Èñ %r!   c                óð  € RV n         V P                  pRV n        \        '       d   Vf   Q hV P                  '       g0   V'       d   V P	                  W134       R# V P                  V4       R# V'       dS   \        V4      R R2P                  R4      pV'       d   V P	                  W4VR34       R# V P	                  W4VR34       R# V'       d   V P	                  VR34       R# V P                  V4       R# )	zASend buffered headers with payload, coalescing into single write.TNrr   rs   rt   ó   
0

ru   ó   0

)r=   r<   r   rN   rn   rd   r^   rv   )r>   r[   r{   Úheaders_bufrw   s   &&&  r   Ú_send_headers_with_payloadÚ'StreamWriter._send_headers_with_payload|   s×   € ð !%ˆÔØ×'Ñ'ˆØ ˆÔç‹=ð Ò*Ð*Ð*à�|�|ˆ|çØ× Ñ  +Ð!5Ô6ñ ð —‘˜KÔ(Ù÷ Ü" 5›z¨!˜n¨DÐ1×8Ñ8¸ÓAˆMßØ× Ñ  +¸eÐEUÐ!VÖWà× Ñ  +¸eÀWÐ!MÖNßØ×Ñ˜k¨<Ð8Ö9à�K‰K˜Ö$r!   ÚdrainTÚLIMITi   c                ó0   <€ V ^8„  d   QhRS[ RS[RS[RR/# )r   r[   rƒ   r„   r2   N)r   r|   r   )r   r   s   "€r   r   r7   œ   s-   ø€ ÷ 1#ñ 1#Ùð1#Ù'+ð1#Ù;>ð1#à	ñ1#r!   c             ƒ  ó  "  € V P                   e   V P                  V4      G Rj  x€L
  \        V\        4      '       d,   VP                  \	        V4      8w  d   VP                  R4      pV P                  e.   V P                  P                  V4      G Rj  x€L
 pV'       g   R# V P                  eV   \	        V4      pV P                  V8¼  d   V P                  V,
          V n        M VRV P                   p^ V n        V'       g   R# V P                  '       d_   V P                  '       gM   V P                  VR4       V'       d1   V P                  V8”  d    ^ V n        V P                  4       G Rj  x€L
  R# V'       dt   V P                  '       d   V P                  V4       MV P!                  V4       V'       d5   V P                  V8”  d"   ^ V n        V P                  4       G Rj  x€L
  R# R# R# R#  ELÑ ELb L‰ L5i)z¢
Writes chunk of data to a stream.

write_eof() indicates end of stream.
writer can't be used after write_eof() method being called.
write() return drain future.
NÚcF)r:   Ú
isinstanceÚ
memoryviewÚnbytesr^   ÚcastrV   ÚcompressÚlengthr<   r=   r�   r_   rƒ   rN   rx   rd   )r>   r[   rƒ   r„   Ú	chunk_lens   &&$$ r   rb   ÚStreamWriter.writeœ   s„  é € ð ×ÑÒ*Ø×%Ñ% eÓ,×,Ð,ä�eœZ×(Ò(Ø�|‰|œs 5›zÔ)àŸ
™
 3›�à�>‰>Ò%ØŸ.™.×1Ñ1°%Ó8×8ˆEßÙà�;‰;Ò"Ü˜E›
ˆIØ�{‰{˜iÔ'Ø"Ÿk™k¨IÕ5�•à˜m §¡Ð,�Ø�”ßÙð ××Ð T×%:×%:Ð%:Ø×+Ñ+¨E°5Ô9ß˜×)Ñ)¨EÔ1Ø#$�Ô Ø—j‘j“l×"Ð"ÙçØ�|�|ˆ|Ø×+Ñ+¨EÕ2à—‘˜EÔ"ç˜×)Ñ)¨EÔ1Ø#$�Ô Ø—j‘j“l×"Ò"ñ 2‰uñ ò= -ò 9ñ& #ñ #ùsw   ‚#H ¥G6¦A1H ÂG9ÂH Â$A"H ÄH ÄH Ä-H Å+H Å2G<Å3H ÆH Æ*H Æ>+H Ç)G>Ç*H Ç9H Ç<H Ç>H c                ó(   <€ V ^8„  d   QhRS[ RRRR/# )r   Ústatus_lineÚheadersr+   r2   N©rT   )r   r   s   "€r   r   r7   Ï   s%   ø€ ÷ 	 ñ 	 Ùð	 Ø);ð	 à	ñ	 r!   c              ƒ  ó�   "  € V P                   e   V P                  V4      G Rj  x€L
  \        W4      pRV n        W0n        R#  L5i)zWrite headers to the stream.NF)r;   Ú_serialize_headersr=   r<   )r>   r‘   r’   Úbufs   &&& r   Úwrite_headersÚStreamWriter.write_headersÏ   sD   é € ð × Ñ Ò,Ø×'Ñ'¨Ó0×0Ð0ä  Ó6ˆØ %ˆÔØÖñ	 1ùs   ‚#A¥A¦Ac                ó   <€ V ^8„  d   QhRR/# rB   r"   )r   r   s   "€r   r   r7   Ú   s   ø€ ÷ !ñ !˜dñ !r!   c                óÌ   € V P                   '       d   V P                  '       d   R# RV n        V P                   pRV n         \        '       d   Vf   Q hV P                  V4       R# )z3Force sending buffered headers if not already sent.NT)r<   r=   r   rd   ©r>   r€   s   & r   Úsend_headersÚStreamWriter.send_headersÚ   sT   € à× × Ð  D×$9×$9Ð$9Ùà $ˆÔØ×'Ñ'ˆØ ˆÔç‹=àÒ*Ð*Ð*à�‰�KÖ r!   c                ó   <€ V ^8„  d   QhRR/# rB   r"   )r   r   s   "€r   r   r7   é   s   ø€ ÷ ñ ˜ñ r!   c                ó¶  € V P                   '       d   R# V P                  '       dw   V P                  '       ge   RV n        V P                  pRV n        \        '       d   Vf   Q hV P                  '       d   V P                  VR34       MGV P                  V4       M5V P                  '       d$   V P                  '       d   V P                  R4       RV n         R# )z&Indicate that the message is complete.NTr   )Ú_eofr<   r=   r   rN   rn   rd   r›   s   & r   Úset_eofÚStreamWriter.set_eofé   s¤   € à�9�9ˆ9Ùð ××Ð T×%:×%:Ð%:Ø$(ˆDÔ!Ø×+Ñ+ˆKØ $ˆDÔç‹}à"Ò.Ð.Ð.ð �|�|ˆ|Ø× Ñ  +¨|Ð!<Õ=à—‘˜KÕ(Ø�\�\ˆ\˜d×3×3Ð3à�K‰K˜Ô%àˆŽ	r!   c                ó$   <€ V ^8„  d   QhRS[ RR/# rZ   )Úbytes)r   r   s   "€r   r   r7     s   ø€ ÷ Lñ L¡Uð L°Tñ Lr!   c              ƒ  óÄ  "  € V P                   '       d   R # V'       d(   V P                  e   V P                  V4      G R j  x€L
  V P                  '       Edè   . p^ pV'       dH   V P                  P                  V4      G R j  x€L
 ;p'       d   \	        V4      pVP                  V4       V P                  P                  4       pV\	        V4      ,          pVP                  V4       V'       g   Q hV P                  '       d¢   V P                  '       g�   RV n        V P                  pR V n        V P                  '       d.   VR R2P                  R4      pV P                  Wg.VORN54       MV P                  V.VO54       V P                  4       G R j  x€L
  RV n         R # V P                  '       d.   VR R2P                  R4      pV P                  V.VORN54       M:\	        V4      ^8”  d   V P                  V4       MV P                  V^ ,          4       V P                  4       G R j  x€L
  RV n         R # V P                  '       dF   V P                  '       g4   V P                  VR4       V P                  4       G R j  x€L
  RV n         R # V P                  '       dl   V'       d2   V P                  \	        V4      R R2P                  R4      VR34       MV P                  R4       V P                  4       G R j  x€L
  RV n         R # V'       d*   V P                  V4       V P                  4       G R j  x€L
  RV n         R #  EL ELÎ EL¼ EL% LÐ LU L5i)NTrr   rs   rt   r~   r   )r    r:   rV   rŒ   r^   ÚappendÚflushr<   r=   rN   rv   rn   rƒ   rd   r�   )r>   r[   rg   Ú
chunks_lenÚcompressed_chunkÚflush_chunkr€   rw   s   &&      r   Ú	write_eofÚStreamWriter.write_eof  sÏ  é € Ø�9�9ˆ9Ùç�T×(Ñ(Ò4Ø×%Ñ% eÓ,×,Ð,ð �>�>‰>Ø"$ˆFØˆJß°D·N±N×4KÑ4KÈEÓ4R×.RÐRÐ*ÖRÜ Ð!1Ó2�
Ø—‘Ð.Ô/àŸ.™.×.Ñ.Ó0ˆKØœ#˜kÓ*Õ*ˆJØ�M‰M˜+Ô&ßÐ�:ð × × Ð ¨×)>×)>Ð)>Ø(,�Ô%Ø"×/Ñ/�Ø$(�Ô!à—<—<�<à'1°! n°DÐ$9×$@Ñ$@ÀÓ$I�MØ×$Ñ$Ø$ÐO°fÐOÐ>NÑOõð
 ×$Ñ$ kÐ%;°FÑ%;Ô<Ø—j‘j“l×"Ð"Ø �”	Ùð �|�|ˆ|Ø#-¨a .°Ð 5× <Ñ <¸WÓ E�Ø× Ñ  -Ð!K°&Ð!KÐ:JÑ!KÕLÜ�V“˜q”Ø× Ñ  Õ(à—‘˜F 1�IÔ&Ø—*‘*“,×ÐØˆDŒIÙð ××Ð T×%:×%:Ð%:à×+Ñ+¨E°4Ô8Ø—*‘*“,×ÐØˆDŒIÙð �<�<ˆ<ßà× Ñ Ü˜E›
 1�~ TÐ*×1Ñ1°'Ó:¸EÐCSÐTõð —‘˜LÔ)Ø—*‘*“,×ÐØˆDŒIÙçØ�K‰K˜ÔØ—*‘*“,×ÐàˆŽ	òO -ò /Sò0 #ò ñ ñ ñ ùsÎ   ‚M Ÿ"M ÁMÁM ÁM Á%M ÂMÂM ÂA4M ÄM Ä+M ÅAM ÆMÆM Æ8A:M È2MÈ3M ÉM É$%M Ê	MÊ
M Ê)M Ê1AM ÌMÌM Ì$M Í MÍM ÍM ÍM ÍM ÍM ÍM ÍM c                ó   <€ V ^8„  d   QhRR/# rB   r"   )r   r   s   "€r   r   r7   R  s   ø€ ÷ 
+ñ 
+˜Tñ 
+r!   c              ƒ  ó¢   "  € V P                   pVP                  e/   VP                  '       d   VP                  4       G Rj  x€L
  R# R# R#  L
5i)z_Flush the write buffer.

The intended use is to write

  await w.write(data)
  await w.drain()
N)r9   rF   Ú_pausedÚ_drain_helper)r>   r.   s   & r   rƒ   ÚStreamWriter.drainR  sD   é € ð —>‘>ˆØ×ÑÒ)¨h×.>×.>Ð.>Ø×(Ñ(Ó*×*Ò*ñ /?Ñ)Ù*ùs   ‚,A¯AÁAÁAc                óf   <€ V ^8„  d   Qh/ S[ R,          ;R&   S[;R&   S[;R&   S[R,          ;R&   # )r   Nr�   rN   r    rV   )r   r|   r   )r   r   s   "€r   r   r7   ;   s@   ø‡ ‚ á�$�JÑñ ñ Ññ ñ Ññ	 ñ
  Õ$Ñ+ò r!   )rV   r    r<   r=   r:   r;   r9   r_   rN   r�   r/   )NN)ÚdeflateN)r!   )r#   r$   r%   r&   r�   rN   r    rV   r?   ÚpropertyrF   r.   rO   rW   rd   rn   rx   r�   rb   r—   rœ   r¡   r«   rƒ   r'   r(   r)   r*   s   @r   r   r   ;   sâ   ø‡ € à€FØ€GØ€DØ'+€I÷,ò ,ð ÷(ó ð(ð ÷ó ð÷ð ÷Nò N÷
ð ÷)ð )÷:ð :÷
%ð %ð@1#Ø.2ð1#ØAH÷1#ò 1#÷f	 ð 	 ÷!ð !÷ð ÷6Lò L÷\
+ð 
+÷o ƒ r!   z[\x00-\x08\x0a-\x1f\x7f]c                ó0   € V ^8„  d   QhR\         R\         /# )r   Ústringr2   r“   )r   s   "r   r   r   d  s   € ÷ ñ œð ¤ñ r!   c                 óJ   € \         P                  V 4      e   \        R4      hV # )NzSForbidden control character detected in headers. Potential header injection attack.)Ú_FORBIDDEN_HEADER_CHARS_REÚsearchÚ
ValueError)r¶   s   &r   Ú_safe_headerr»   d  s,   € Ü!×(Ñ(¨Ó0Ò<Üð1ó
ð 	
ð €Mr!   c                ó4   € V ^8„  d   QhR\         RRR\        /# )r   r‘   r’   r+   r2   )rT   r¤   )r   s   "r   r   r   m  s"   € ÷  ñ  ¤sð  Ð5Gð  ÌEñ  r!   c                 ó´   € \        V 4       R  VP                  4        4       pV R,           RP                  V4      ,           R,           pVP                  R4      # )c              3   ój   "  € T F)  w  r\        V4      R ,           \        V4      ,           x € K+  	  R# 5i)z: N)r»   )Ú.0ÚkÚvs   &  r   Ú	<genexpr>Ú(_py_serialize_headers.<locals>.<genexpr>o  s'   é € ÐXÉÁÀ”< “? TÕ)¬L¸«O×;Ò;Ëùs   ‚13rs   z

zutf-8)r»   Úitemsrl   rv   )r‘   r’   Úheaders_genÚlines   &&  r   Ú_py_serialize_headersrÇ   m  sF   € Ü�ÔÙXÈÏÉÌÓX€KØ˜Õ &§+¡+¨kÓ":Õ:¸ZÕG€DØ�;‰;�wÓÐr!   )r   r   ÚHttpVersion10ÚHttpVersion11)é   é   )rÊ   é   ri   )rÊ   rÌ   r   )rÊ   rË   é	   )3Ú__doc__r3   ÚreÚsysÚtypingr   r   r   r   r   r   r   r	   Ú	multidictr
   Úabcr   Úbase_protocolr   Úclient_exceptionsr   Úcompression_utilsr   Úhelpersr   Ú__all__Úversion_infoÚcollections.abcr   r   r¤   Ú	bytearrayrk   ÚIS_PY313_BEFORE_313_2ÚIS_PY_BEFORE_312_9rj   r   rÈ   rÉ   r5   r6   r   Úcompiler¸   r»   rÇ   r•   Úaiohttp._http_writerÚ_http_writerÚ_c_serialize_headersÚImportErrorr"   r!   r   Ú<module>rã      si  ðÙ (ã Û 	Û 
÷	÷ 	ó 	õ "å %Ý 'Ý 9Ý -Ý "à
K€à×Ñ�wÔÞ&åà�5˜)Ð%6Ð8KÐKÕL€Fð "Ð Ø" c×&6Ñ&6×CÔC¸ÔCÐ Ø×%Ñ%¨
Ñ2Ð Ø'×=Ð=Ð+=€ô�*ô ñ
 ˜A˜qÓ!€Ù˜A˜qÓ!€ð ˜( F 8¨Y°t­_Ð#<Õ=Õ>€Ø˜HÐ&8Ð%9¸9ÀT½?Ð%JÕKÕLÐ ôa+Ð'ô a+ðL	  ŸZšZÐ(CÓDÐ õõ ð +Ð ð	Ý/à'×:Ñ:ÐßØ1Òñ øàô 	Úð	ús   Ä.E ÅE ÅEÅE