+
    PV-j?^  ã                   ó„  a € R t$0 t ^ RIt^ RIt^ RIt^ RIt^ RIHtHt ^ RIH	t	H
t
Ht ^RIHt ^RIHtHtHtHtHtHt ^RIHt ^RIHt Rt]! R4      t ! R R]4      t ! R R]
],          4      t ! R R4      t ! R R	4      t ! R R]4      t ] ! 4       t!] ^ k  ! R R
]
],          4      t" ! R R]"],          4      t#R# )é    N)Ú	AwaitableÚCallable)ÚFinalÚGenericÚTypeVar)ÚBaseProtocol)Ú_EXC_SENTINELÚDEFAULT_CHUNK_SIZEÚBaseTimerContextÚ	TimerNoopÚset_exceptionÚ
set_result)ÚLineTooLong)Úinternal_loggerÚ	EofStreamÚStreamReaderÚ	DataQueueÚ_Tc                   ó   € ] tR t^tRtRtR# )r   zeof stream indication.© N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Ú__static_attributes__r   ó    Ú`/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/aiohttp/streams.pyr   r      s   † Ý r   c                   óZ   a € ] tR t^"t o R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# )	ÚAsyncStreamIteratorc                óH   <€ V ^8„  d   QhRS[ . S[S[,          3,          RR/# )é   Ú	read_funcÚreturnN)r   r   r   )ÚformatÚ__classdict__s   "€r   Ú__annotate__Ú AsyncStreamIterator.__annotate__&   s)   ø€ ÷ #ñ #¡(¨2©y¹­}Ð+<Õ"=ð #À$ñ #r   c                ó   € Wn         R # ©N©r#   )Úselfr#   s   &&r   Ú__init__ÚAsyncStreamIterator.__init__&   s   € Ø"Žr   c                ó   <€ V ^8„  d   QhRR/# )r"   r$   zAsyncStreamIterator[_T]r   )r%   r&   s   "€r   r'   r(   )   s   ø€ ÷ ñ Ð4ñ r   c                ó   € V # r*   r   ©r,   s   &r   Ú	__aiter__ÚAsyncStreamIterator.__aiter__)   ó   € Øˆr   c                ó    <€ V ^8„  d   QhRS[ /# ©r"   r$   ©r   )r%   r&   s   "€r   r'   r(   ,   s   ø€ ÷ ñ ¡ñ r   c              ƒ  óˆ   "  €  V P                  4       G R j  x€L
 pTR8X  d   \        hT#  L  \         d    \        hi ; i5i©Nr   )r#   r   ÚStopAsyncIteration©r,   Úrvs   & r   Ú	__anext__ÚAsyncStreamIterator.__anext__,   sF   é € ð	%Ø—~‘~Ó'×'ˆBð �Œ9Ü$Ð$Øˆ	ñ (øÜô 	%Ü$Ð$ð	%üs#   ‚A„- —+˜- œA«- ­?¿Ar+   N©
r   r   r   r   Ú	__slots__r-   r2   r=   r   Ú__classdictcell__©r&   s   @r   r    r    "   s(   ø‡ € à€I÷#ð #÷ð ÷ö r   r    c                   óZ   a € ] tR t^6t o R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# )	ÚChunkTupleAsyncStreamIteratorc                ó"   <€ V ^8„  d   QhRRRR/# )r"   Ústreamr   r$   Nr   )r%   r&   s   "€r   r'   Ú*ChunkTupleAsyncStreamIterator.__annotate__:   s   ø€ ÷ ñ ˜~ð °$ñ r   c                ó   € Wn         R # r*   ©Ú_stream)r,   rF   s   &&r   r-   Ú&ChunkTupleAsyncStreamIterator.__init__:   s   € ØŽr   c                ó   <€ V ^8„  d   QhRR/# )r"   r$   rD   r   )r%   r&   s   "€r   r'   rG   =   s   ø€ ÷ ñ Ð:ñ r   c                ó   € V # r*   r   r1   s   &r   r2   Ú'ChunkTupleAsyncStreamIterator.__aiter__=   r4   r   c                ó6   <€ V ^8„  d   QhRS[ S[S[3,          /# r6   ©ÚtupleÚbytesÚbool)r%   r&   s   "€r   r'   rG   @   s   ø€ ÷ ñ ¡¡u©d {Õ!3ñ r   c              ƒ  óp   "  € V P                   P                  4       G R j  x€L
 pVR8X  d   \        hV#  L5i)N©r   F)rJ   Ú	readchunkr:   r;   s   & r   r=   Ú'ChunkTupleAsyncStreamIterator.__anext__@   s2   é € Ø—<‘<×)Ñ)Ó+×+ˆØ�ÔÜ$Ð$Øˆ	ñ ,ùs   ‚6 4¡6rI   Nr?   rB   s   @r   rD   rD   6   s(   ø‡ € à€I÷ð ÷ð ÷ö r   rD   c                   ó€  a € ] tR t^Gt o RtRDt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	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]3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V 3R! lR" lt]V 3R# lR$ l4       tV 3R% lR& ltREV 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/R/V 3R0 lR1 lltRFR2R/V 3R3 lR4 llltRGV 3R5 lR6 lltV 3R7 lR8 lt V 3R9 lR: lt!V 3R; lR< lt"RGV 3R= lR> llt#V 3R? lR@ lt$V 3RA lRB lt%RCt&V t'R# )Hr   a
  An enhancement of asyncio.StreamReader.

Supports asynchronous iteration by line, chunk or as available::

    async for line in reader:
        ...
    async for chunk in reader.iter_chunked(1024):
        ...
    async for slice in reader.iter_any():
        ...

ÚtimerNÚloopc          
      óf   <€ V ^8„  d   QhRS[ RS[RS[R,          RS[P                  R,          RR/# )r"   ÚprotocolÚlimitrY   NrZ   r$   )r   Úintr   ÚasyncioÚAbstractEventLoop)r%   r&   s   "€r   r'   ÚStreamReader.__annotate__l   sM   ø€ ÷  7ñ  7áð 7ñ ð 7ñ
   $Õ&ð 7ñ ×'Ñ'¨$Õ.ð 7ð 
ñ 7r   c               óÞ  € Wn         W n        V^,          V n        Vf   \        P                  ! 4       p\        ^V^,          4      V n        V P                  ^,          V n        W@n        ^ V n	        ^ V n
        RV n        \        P                  ! 4       V n        ^ V n        RV n        RV n        RV n        RV n        Vf   \)        4       MTV n        . V n        ^ V n        ^ V n        RV n        R# )r"   NF)Ú	_protocolÚ
_low_waterÚ_high_waterr_   Úget_event_loopÚmaxÚ_high_water_chunksÚ_low_water_chunksÚ_loopÚ_sizeÚ_cursorÚ_http_chunk_splitsÚcollectionsÚdequeÚ_bufferÚ_buffer_offsetÚ_eofÚ_waiterÚ_eof_waiterÚ
_exceptionr   Ú_timerÚ_eof_callbacksÚ_eof_counterÚtotal_bytesÚtotal_compressed_bytes)r,   r\   r]   rY   rZ   s   &&&$$r   r-   ÚStreamReader.__init__l   sÔ   € ð "ŒØŒØ  1�9ˆÔØŠ<Ü×)Ò)Ó+ˆDô #& a¨°"­Ó"5ˆÔØ!%×!8Ñ!8¸AÕ!=ˆÔØŒ
ØˆŒ
ØˆŒØAEˆÔÜ1<×1BÒ1BÓ1DˆŒØˆÔØˆŒ	Ø48ˆŒØ8<ˆÔØ04ˆŒØ%*¢]”i”k¸ˆŒØ8:ˆÔØˆÔØˆÔØ26ˆÖ#r   c                ó    <€ V ^8„  d   QhRS[ /# r6   ©Ústr)r%   r&   s   "€r   r'   ra   Ž   s   ø€ ÷ 'ñ '™#ñ 'r   c                ód  € V P                   P                  .pV P                  '       d#   VP                  R V P                  ,          4       V P                  '       d   VP                  R4       V P
                  \        8w  d/   VP                  RV P
                  V P                  3,          4       V P                  '       d#   VP                  RV P                  ,          4       V P                  '       d#   VP                  RV P                  ,          4       RRP                  V4      ,          # )z%d bytesÚeofzlow=%d high=%dzw=%rze=%rú<%s>Ú )Ú	__class__r   rk   Úappendrr   rd   r
   re   rs   ru   Újoin)r,   Úinfos   & r   Ú__repr__ÚStreamReader.__repr__Ž   sÄ   € Ø—‘×'Ñ'Ð(ˆØ�:�:ˆ:Ø�K‰K˜
 T§Z¡ZÕ/Ô0Ø�9�9ˆ9Ø�K‰K˜ÔØ�?‰?Ô0Ô0Ø�K‰KÐ(¨D¯O©O¸T×=MÑ=MÐ+NÕNÔOØ�<�<ˆ<Ø�K‰K˜ §¡Õ-Ô.Ø�?�?ˆ?Ø�K‰K˜ §¡Õ0Ô1Ø˜Ÿ™ ›Õ&Ð&r   c                ó0   <€ V ^8„  d   QhRS[ S[,          /# r6   ©r    rR   )r%   r&   s   "€r   r'   ra   œ   s   ø€ ÷ 2ñ 2Ñ.©uÕ5ñ 2r   c                ó,   € \        V P                  4      # r*   )r    Úreadliner1   s   &r   r2   ÚStreamReader.__aiter__œ   s   € Ü" 4§=¡=Ó1Ð1r   c                ó6   <€ V ^8„  d   QhRS[ RS[S[,          /# ©r"   Únr$   )r^   r    rR   )r%   r&   s   "€r   r'   ra   Ÿ   s!   ø€ ÷ 9ñ 9™cð 9Ñ&9¹%Õ&@ñ 9r   c                óH   a a€ S P                  S4       \        VV 3R l4      # )z>Returns an asynchronous iterator that yields chunks of size n.c                  ó&   <€ SP                  S 4      # r*   )Úread)r�   r,   s   €€r   Ú<lambda>Ú+StreamReader.iter_chunked.<locals>.<lambda>¢   s   ø€ ¨4¯9©9°Q¬<r   )Úset_read_chunk_sizer    ©r,   r�   s   ffr   Úiter_chunkedÚStreamReader.iter_chunkedŸ   s   ù€ à× Ñ  Ô#Ü"Õ#7Ó8Ð8r   c                ó0   <€ V ^8„  d   QhRS[ S[,          /# r6   rŠ   )r%   r&   s   "€r   r'   ra   ¤   s   ø€ ÷ 1ñ 1Ñ-©eÕ4ñ 1r   c                ó,   € \        V P                  4      # )z3Yield all available data as soon as it is received.)r    Úreadanyr1   s   &r   Úiter_anyÚStreamReader.iter_any¤   s   € ä" 4§<¡<Ó0Ð0r   c                ó    <€ V ^8„  d   QhRS[ /# r6   ©rD   )r%   r&   s   "€r   r'   ra   ¨   s   ø€ ÷ 3ñ 3Ñ:ñ 3r   c                ó   € \        V 4      # )zœYield chunks of data as they are received by the server.

The yielded objects are tuples
of (bytes, bool) as returned by the StreamReader.readchunk method.
r    r1   s   &r   Úiter_chunksÚStreamReader.iter_chunks¨   s   € ô -¨TÓ2Ð2r   c                ó6   <€ V ^8„  d   QhRS[ S[S[3,          /# r6   )rQ   r^   )r%   r&   s   "€r   r'   ra   °   s   ø€ ÷ 3ñ 3©©c±3¨h­ñ 3r   c                ó2   € V P                   V P                  3# r*   ©rd   re   r1   s   &r   Úget_read_buffer_limitsÚ#StreamReader.get_read_buffer_limits°   s   € Ø—‘ ×!1Ñ!1Ð2Ð2r   c                ó$   <€ V ^8„  d   QhRS[ RR/# ©r"   r�   r$   N©r^   )r%   r&   s   "€r   r'   ra   ³   s   ø€ ÷ %ñ %¡Sð %¨Tñ %r   c                óR   € WP                   8”  d   Wn         V^,          V n        R# R# )z7Raise buffer limits to match the consumer's chunk size.Nr¦   r—   s   &&r   r–   Ú StreamReader.set_read_chunk_size³   s"   € à�‰ÔØŒOØ  1�uˆDÖñ r   c                ó.   <€ V ^8„  d   QhRS[ R,          /# ©r"   r$   N©ÚBaseException)r%   r&   s   "€r   r'   ra   ¹   ó   ø€ ÷ ñ ™=¨4Õ/ñ r   c                ó   € V P                   # r*   ©ru   r1   s   &r   Ú	exceptionÚStreamReader.exception¹   ó   € Ø�‰Ðr   c                ó*   <€ V ^8„  d   QhRS[ RS[ RR/# ©r"   ÚexcÚ	exc_causer$   Nr°   )r%   r&   s   "€r   r'   ra   ¼   s)   ø€ ÷ 2ñ 2áð2ñ !ð2ð 
ñ	2r   c                óÖ   € Wn         V P                  P                  4        V P                  pVe   R V n        \	        W1V4       V P
                  pVe   R V n        \	        W1V4       R # R # r*   )ru   rw   Úclearrs   r   rt   ©r,   rº   r»   Úwaiters   &&& r   r   ÚStreamReader.set_exception¼   sc   € ð
 ŒØ×Ñ×!Ñ!Ô#à—‘ˆØÒØˆDŒLÜ˜& yÔ1à×!Ñ!ˆØÒØ#ˆDÔÜ˜& yÖ1ñ r   c                ó6   <€ V ^8„  d   QhRS[ . R3,          RR/# ©r"   ÚcallbackNr$   ©r   )r%   r&   s   "€r   r'   ra   Î   s$   ø€ ÷ 1ñ 1™x¨¨D¨Õ1ð 1°dñ 1r   c                óÄ   € V P                   '       d    V! 4        R# V P                  P                  V4       R#   \         d    \        P                  ! R 4        R# i ; i©úException in eof callbackN)rr   Ú	Exceptionr   rµ   rw   r„   ©r,   rÃ   s   &&r   Úon_eofÚStreamReader.on_eofÎ   sN   € Ø�9�9ˆ9ðGÙ–
ð ×Ñ×&Ñ& xÖ0øô ô GÜ×)Ò)Ð*E×FðGús   ”: º!AÁAc                ó   <€ V ^8„  d   QhRR/# r¯   r   )r%   r&   s   "€r   r'   ra   ×   s   ø€ ÷ $ñ $˜$ñ $r   c                ó’  € R V n         V P                  pVe   RV n        \        VR4       V P                  pVe   RV n        \        VR4       V P                  P                  RR7       V P                   F  p V! 4        K  	  V P                  P                  4        R#   \         d    \        P                  ! R4        KO  i ; i)TNF)Úresume_parserrÇ   )rr   rs   r   rt   rc   Úresume_readingrw   rÈ   r   rµ   r½   )r,   r¿   Úcbs   &  r   Úfeed_eofÚStreamReader.feed_eof×   s´   € ØˆŒ	à—‘ˆØÒØˆDŒLÜ�v˜tÔ$à×!Ñ!ˆØÒØ#ˆDÔÜ�v˜tÔ$ð 	�‰×%Ñ%°EÐ%Ô:à×%Ô%ˆBðGÙ–ñ &ð 	×Ñ×!Ñ!Ö#øô ô GÜ×)Ò)Ð*E×FðGús   Á:B!Â!!CÃCc                ó    <€ V ^8„  d   QhRS[ /# r6   ©rS   )r%   r&   s   "€r   r'   ra   ï   s   ø€ ÷ ñ ™ñ r   c                ó   € V P                   # )z&Return True if  'feed_eof' was called.©rr   r1   s   &r   Úis_eofÚStreamReader.is_eofï   s   € à�y‰yÐr   c                ó    <€ V ^8„  d   QhRS[ /# r6   rÔ   )r%   r&   s   "€r   r'   ra   ó   s   ø€ ÷ .ñ .™ñ .r   c                óL   € V P                   ;'       d    V P                  '       * # )z=Return True if the buffer is empty and 'feed_eof' was called.©rr   rp   r1   s   &r   Úat_eofÚStreamReader.at_eofó   s   € à�y‰y×-Ð- §¡Ô-Ð-r   c                ó   <€ V ^8„  d   QhRR/# r¯   r   )r%   r&   s   "€r   r'   ra   ÷   s   ø€ ÷ 	$ñ 	$ ñ 	$r   c              ƒ  óè   "  € V P                   '       d   R # V P                  e   Q hV P                  P                  4       V n         V P                  G R j  x€L
  R V n        R #  L  R T n        i ; i5ir*   )rr   rt   rj   Úcreate_futurer1   s   &r   Úwait_eofÚStreamReader.wait_eof÷   sb   é € Ø�9�9ˆ9Ùà×ÑÒ'Ð'Ð'ØŸ:™:×3Ñ3Ó5ˆÔð	$Ø×"Ñ"×"Ð"à#ˆDÖñ #øà#ˆDÕüs0   ‚AA2ÁA& ÁA$ÁA& Á	A2Á$A& Á&	A/Á/A2c                ó    <€ V ^8„  d   QhRS[ /# r6   r«   )r%   r&   s   "€r   r'   ra     s   ø€ ÷ +ñ +¡ñ +r   c                óN   € V P                   f   V P                  # V P                   # r*   )rz   ry   r1   s   &r   Útotal_raw_bytesÚStreamReader.total_raw_bytes  s&   € à×&Ñ&Ò.Ø×#Ñ#Ð#Ø×*Ñ*Ð*r   c                ó$   <€ V ^8„  d   QhRS[ RR/# )r"   Údatar$   N©rR   )r%   r&   s   "€r   r'   ra     s   ø€ ÷ ñ ¡ð ¨$ñ r   c                ó¬  € \         P                  ! R\        ^R7       V'       g   R# V P                  '       d5   V P                  ^ ,          V P                  R V P                  ^ &   ^ V n        V ;P
                  \        V4      ,          un        V ;P                  \        V4      ,          un        V P                  P                  V4       ^ V n	        R# )zDrollback reading some data from stream, inserting it to buffer head.zJunread_data() is deprecated and will be removed in future releases (#3260))Ú
stacklevelN)
ÚwarningsÚwarnÚDeprecationWarningrq   rp   rk   Úlenrl   Ú
appendleftrx   )r,   rè   s   &&r   Úunread_dataÚStreamReader.unread_data  s–   € ä�Šð=äØõ		
÷ Ùà××ÐØ"Ÿl™l¨1�o¨d×.AÑ.AÐ.CÐDˆD�L‰L˜‰OØ"#ˆDÔØ�
Š
”c˜$“iÕ�
Ø�Šœ˜D›	Õ!�Ø�‰×Ñ Ô%ØˆÖr   c                ó,   <€ V ^8„  d   QhRS[ RS[RS[/# )r"   rè   Úsizer$   ©rR   r^   rS   )r%   r&   s   "€r   r'   ra     s"   ø€ ÷ ñ ™eð ©3ð ±tñ r   c                ó¬  € V P                   '       d   Q R 4       hV'       g   R# \        V4      pV ;P                  V,          un        V P                  P	                  V4       V ;P
                  V,          un        V P                  pVe   RV n        \        VR4       V P                  V P                  8”  d   V P                  P                  4        R# )zfeed_data after feed_eofFN)rr   rï   rk   rp   r„   ry   rs   r   re   rc   Úpause_reading)r,   rè   rô   Údata_lenr¿   s   &&&  r   Ú	feed_dataÚStreamReader.feed_data  s›   € Ø—9—9�9Ð8Ð8Ó8ˆ}çÙä�t“9ˆØ�
Š
�hÕ�
Ø�‰×Ñ˜DÔ!Ø×Ò˜HÕ$Õà—‘ˆØÒØˆDŒLÜ�v˜tÔ$à�:‰:˜×(Ñ(Ô(Ø�N‰N×(Ñ(Ô*Ùr   c                ó   <€ V ^8„  d   QhRR/# r¯   r   )r%   r&   s   "€r   r'   ra   0  s   ø€ ÷ :ñ :¨Dñ :r   c                ó”   € V P                   f:   V P                  '       d   \        R4      h\        P                  ! 4       V n         R # R # )Nz@Called begin_http_chunk_receiving when some data was already fed)rm   ry   ÚRuntimeErrorrn   ro   r1   s   &r   Úbegin_http_chunk_receivingÚ'StreamReader.begin_http_chunk_receiving0  sB   € Ø×"Ñ"Ò*Ø××ÐÜ"ØVóð ô '2×&7Ò&7Ó&9ˆDÖ#ñ +r   c                ó   <€ V ^8„  d   QhRR/# r¯   r   )r%   r&   s   "€r   r'   ra   8  s   ø€ ÷ "%ñ "%¨$ñ "%r   c                ó¼  € V P                   f   \        R4      hV P                   '       d   V P                   R,          M^ pV P                  V8X  d   R # V P                   P                  V P                  4       \	        V P                   4      V P
                  8”  d   V P                  P                  4        V P                  pVe   R V n        \        VR 4       R # R # )NzFCalled end_chunk_receiving without calling begin_chunk_receiving firstéÿÿÿÿ)
rm   rý   ry   r„   rï   rh   rc   r÷   rs   r   )r,   Úposr¿   s   &  r   Úend_http_chunk_receivingÚ%StreamReader.end_http_chunk_receiving8  s¾   € Ø×"Ñ"Ò*Üð.óð ð .2×-D×-DÐ-Dˆd×%Ñ% bÖ)È!ˆà×Ñ˜sÔ"ñ à×Ñ×&Ñ& t×'7Ñ'7Ô8ô
 ˆt×&Ñ&Ó'¨$×*AÑ*AÔAØ�N‰N×(Ñ(Ô*ð —‘ˆØÒØˆDŒLÜ�v˜tÖ$ñ r   c                ó$   <€ V ^8„  d   QhRS[ RR/# )r"   Ú	func_namer$   Nr}   )r%   r&   s   "€r   r'   ra   \  s   ø€ ÷  ñ  ¡Sð  ¨Tñ  r   c              ƒ  ó|  "  € V P                   P                  '       g   \        R 4      hV P                  e   \        RV,          4      hV P                  P                  4       ;q n         V P                  ;_uu_ 4        VG Rj  x€L
  RRR4       RV n        R#  L  + '       g   i     L; i  RT n        i ; i5i)zConnection closed.NzH%s() called while another coroutine is already waiting for incoming data)rc   Ú	connectedrý   rs   rj   rà   rv   )r,   r  r¿   s   && r   Ú_waitÚStreamReader._wait\  sš   é € Ø�~‰~×'×'Ð'ÜÐ3Ó4Ð4ð �<‰<Ò#Üð4Ø6?õ@óð ð
 !%§
¡
× 8Ñ 8Ó :Ð:ˆ”ð	 Ø——“Ø—�÷ ð  ˆDŽLñ ÷ —ûð  ˆD�LüsH   ‚A(B<Á+B0 Á?BÂBÂBÂ
B0 Â	B<ÂBÂB-	Â(B0 Â0	B9Â9B<Úmax_line_lengthc                ó4   <€ V ^8„  d   QhRS[ R,          RS[/# ©r"   r  Nr$   ©r^   rR   )r%   r&   s   "€r   r'   ra   q  s   ø€ ÷ >ñ >±°tµð >Áuñ >r   c             ƒ  óB   "  € V P                  VR 7      G Rj  x€L
 #  L5i))Úmax_sizeN)Ú	readuntil©r,   r  s   &$r   rŒ   ÚStreamReader.readlineq  s   é € Ø—^‘^¨_�^Ó=×=Ð=Ñ=ùs   ‚˜™r  c                ó:   <€ V ^8„  d   QhRS[ RS[R,          RS[ /# )r"   Ú	separatorr  Nr$   )rR   r^   )r%   r&   s   "€r   r'   ra   t  s)   ø€ ÷ %ñ %Ùð%Ù58¸4µZð%á	ñ%r   c             ƒ  óÈ  "  € \        V4      pV^ 8X  d   \        R4      hV P                  e   V P                  hRp^ pRpT;'       g    V P                  pV'       Ed    V P                  '       d³   V'       d«   V P
                  pV P                  ^ ,          P                  W4      ^,           pT P                  V'       d   W‡,
          V,           ^,
          MR	4      p	WI,          pV\        V	4      ,          pV'       d   RpWR8”  g   Kª  \        VR,          R,           V4      hV P                  '       d    V# V'       g   Kì  V P                  R4      G Rj  x€L
  EK  V#  L	5i)
r   z,Separator should be at least one-byte stringNr   TF:Néd   Ns   ...r  r  )rï   Ú
ValueErrorru   re   rp   rq   ÚfindÚ_read_nowait_chunkr   rr   r
  )
r,   r  r  ÚseplenÚchunkÚ
chunk_sizeÚ
not_enoughÚoffsetÚicharrè   s
   &&$       r   r  ÚStreamReader.readuntilt  s%  é € ô �Y“ˆØ�QŒ;ÜÐKÓLÐLà�?‰?Ò&Ø—/‘/Ð!àˆØˆ
Øˆ
Ø×/Ð/˜t×/Ñ/ˆçˆjØ—,—,�,§:Ø×,Ñ,�ØŸ™ Q�×,Ñ,¨YÓ?À!ÕC�à×.Ñ.ß38�E•N VÕ+¨aÖ/¸bó�ð •�Øœc $›iÕ'�
ßØ!&�JàÖ(Ü% e¨D¥k°FÕ&:¸HÓEÐEà�y�yˆyØð
 ˆ÷ ‰zØ—j‘j Ó-×-Ó-àˆñ .ùs=   ‚AE"Á	E"ÁE"Á1E"Á9BE"Ä	+E"Ä5E"ÅE"ÅE Å
E"c                ó&   <€ V ^8„  d   QhRS[ RS[/# r�   r  )r%   r&   s   "€r   r'   ra   ›  s   ø€ ÷ '$ñ '$™Cð '$©ñ '$r   c              ƒ  óÆ  "  € V P                   e   V P                   h V P                  '       dU   V P                  '       gC   \        V R^ 4      ^,           V n        V P                  ^8”  d   \
        P                  ! RRR7       V'       g   R# V^ 8  dh   V P                  \        P                  4       . p V P                  4       G R j  x€L
 pV'       g   MVP                  V4       K5  RP                  V4      # V P                  V4       V P                  '       g.   V P                  '       g   V P                  R4      G R j  x€L
  K?  V P                  V4      #  L’ L5i)NTrx   zEMultiple access to StreamReader in eof state, might be infinite loop.)Ú
stack_infor   r“   )ru   rr   rp   Úgetattrrx   r   Úwarningr–   ÚsysÚmaxsizerœ   r„   r…   r
  Ú_read_nowait)r,   r�   ÚblocksÚblocks   &&  r   r“   ÚStreamReader.read›  s  é € Ø�?‰?Ò&Ø—/‘/Ð!ð Ø�y�yˆy §§ Ü$+¨D°.À!Ó$DÀqÕ$H�Ô!Ø×$Ñ$ qÔ(Ü#×+Ò+ð2à#'õ÷ ÙàˆqŒ5à×$Ñ$¤S§[¡[Ô1ØˆFØØ"Ÿl™l›n×,�ßØØ—‘˜eÖ$Ø—8‘8˜FÓ#Ð#à× Ñ  Ô#ð —,—,�, t§y§y yØ—*‘*˜VÓ$×$Ò$à× Ñ  Ó#Ð#ñ -ñ %ùsH   ‚-E!°E!ÁA	E!Â>E!Ã
EÃE!ÃAE!ÄE!Ä1E!ÅEÅE!ÅE!c                ó    <€ V ^8„  d   QhRS[ /# r6   ré   )r%   r&   s   "€r   r'   ra   Ä  s   ø€ ÷ 
%ñ 
%™uñ 
%r   c              ƒ  óâ   "  € V P                   e   V P                   hV P                  '       g.   V P                  '       g   V P                  R4      G R j  x€L
  K?  V P	                  R4      #  L5i)Nrœ   r  )ru   rp   rr   r
  r*  r1   s   &r   rœ   ÚStreamReader.readanyÄ  sT   é € Ø�?‰?Ò&Ø—/‘/Ð!ð
 —,—,�, t§y§y yØ—*‘*˜YÓ'×'Ò'à× Ñ  Ó$Ð$ñ (ùs   ‚,A/¯A/ÁA/ÁA-ÁA/c                ó6   <€ V ^8„  d   QhRS[ S[S[3,          /# r6   rP   )r%   r&   s   "€r   r'   ra   Ð  s   ø€ ÷  *ñ  *¡¡u©d {Õ!3ñ  *r   c              ƒ  óþ  "  €  V P                   e   V P                   hV P                  '       dx   V P                  P                  4       pWP                  8X  d   R# WP                  8”  d$   V P	                  WP                  ,
          4      R3# \
        P                  ! R4       K‰  V P                  '       d   V P                  R4      R3# V P                  '       d   R# V P                  R4      G Rj  x€L
  Kø   L5i)	zßReturns a tuple of (data, end_of_http_chunk).

When chunked transfer
encoding is used, end_of_http_chunk is a boolean indicating if the end
of the data corresponds to the end of a HTTP chunk , otherwise it is
always False.
TNzESkipping HTTP chunk end due to data consumption beyond chunk boundaryFrV   ©r   Tr  rU   )ru   rm   Úpopleftrl   r*  r   r'  rp   r  rr   r
  )r,   r  s   & r   rV   ÚStreamReader.readchunkÐ  sÎ   é € ð Ø�‰Ò*Ø—o‘oÐ%à×)×)Ð)Ø×-Ñ-×5Ñ5Ó7�ØŸ,™,Ô&Ø&Ð&ØŸ™Ô%Ø ×-Ñ-¨c·L±LÕ.@ÓAÀ4ÐHÐHÜ×'Ò'ð8öð
 �|�|ˆ|Ø×/Ñ/°Ó3°UÐ;Ð;ð �y�yˆyð $Ð#à—*‘*˜[Ó)×)Ô)ùs#   ‚-C=°BC=Â9$C=ÃC=Ã4C;Ã5C=c                ó&   <€ V ^8„  d   QhRS[ RS[/# r�   r  )r%   r&   s   "€r   r'   ra   ò  s   ø€ ÷  ñ  ¡3ð  ©5ñ  r   c              ƒ  ór  "  € V P                   e   V P                   h. pV^ 8”  d   V P                  V4      G R j  x€L
 pV'       g9   RP                  V4      p\        P                  ! V\        V4      V,           4      hVP                  V4       V\        V4      ,          pK…  RP                  V4      #  Lz5ir9   )ru   r“   r…   r_   ÚIncompleteReadErrorrï   r„   )r,   r�   r+  r,  Úpartials   &&   r   ÚreadexactlyÚStreamReader.readexactlyò  s�   é € Ø�?‰?Ò&Ø—/‘/Ð!à ˆØ�!ŒeØŸ)™) A›,×&ˆEßØŸ(™( 6Ó*�Ü×1Ò1°'¼3¸w»<È!Õ;KÓLÐLØ�M‰M˜%Ô Ø”�U“�OŠAà�x‰x˜ÓÐñ 'ùs   ‚8B7ºB5»B7ÁA/B7c                ó&   <€ V ^8„  d   QhRS[ RS[/# r�   r  )r%   r&   s   "€r   r'   ra     s   ø€ ÷ $ñ $™Sð $©%ñ $r   c                óÒ   € V P                   e   V P                   hV P                  '       d,   V P                  P                  4       '       g   \        R4      hV P	                  V4      # )Nz9Called while some coroutine is waiting for incoming data.)ru   rs   Údonerý   r*  r—   s   &&r   Úread_nowaitÚStreamReader.read_nowait  sV   € ð
 �?‰?Ò&Ø—/‘/Ð!à�<�<ˆ< §¡× 1Ñ 1× 3Ò 3ÜØKóð ð × Ñ  Ó#Ð#r   c                ó&   <€ V ^8„  d   QhRS[ RS[/# r�   r  )r%   r&   s   "€r   r'   ra     s   ø€ ÷ ñ ¡Cð ©Eñ r   c                ó  € V P                   ^ ,          pV P                  pVR8w  d<   \        V4      V,
          V8”  d%   W#W1,            pV ;P                  V,          un        MHV'       d'   V P                   P                  4        W#R p^ V n        MV P                   P                  4       p\        V4      pV ;P                  V,          un        V ;P
                  V,          un        V P                  pV'       d+   V^ ,          V P
                  8  d   VP                  4        K2  V P                  V P                  8  dM   V P                  e%   \        V P                  4      V P                  8  d   V P                  P                  4        V# )r   Nr  )rp   rq   rï   r4  rk   rl   rm   rd   ri   rc   rÏ   )r,   r�   Úfirst_bufferr   rè   rø   Úchunk_splitss   &&     r   r  ÚStreamReader._read_nowait_chunk  s   € Ø—|‘| A•ˆØ×$Ñ$ˆØ�Œ7”s˜<Ó(¨6Õ1°AÔ5Ø¨­Ð4ˆDØ×Ò 1Õ$ÖçØ�L‰L× Ñ Ô"Ø Ð(ˆDØ"#ˆDÕð —<‘<×'Ñ'Ó)ˆDä�t“9ˆØ�
Š
�hÕ�
Ø�Š˜Õ �à×.Ñ.ˆç˜|¨A�°·±Ô=Ø× Ñ Ö"à�:‰:˜Ÿ™Ô'Ø×#Ñ#Ò+Ü�4×*Ñ*Ó+¨d×.DÑ.DÔDà�N‰N×)Ñ)Ô+Øˆr   c                ó&   <€ V ^8„  d   QhRS[ RS[/# r�   r  )r%   r&   s   "€r   r'   ra   /  s   ø€ ÷ 3ñ 3™cð 3¡eñ 3r   c                óò  € V P                   P                  4        VR8X  df   \        V P                  4      pV^8X  d   V P	                  R4      # RP                  \        V4       Uu. uF  q0P	                  R4      NK  	  up4      # . pV P                  '       d?   V P	                  V4      pVP                  V4       V\        V4      ,          pV^ 8X  g   KO   V'       d   RP                  V4      # R# u upi )z6Read not more than n bytes, or whole buffer if n == -1r   r  )rv   Úassert_timeoutrï   rp   r  r…   Úranger„   )r,   r�   ÚcountÚ_Úchunksr  s   &&    r   r*  ÚStreamReader._read_nowait/  sÉ   € à�‰×"Ñ"Ô$à�Œ7ô ˜Ÿ™Ó%ˆEØ˜ŒzØ×.Ñ.¨rÓ2Ð2Ø—8‘8Ä%ÈÄ,ÓOÁ,¸Q×4Ñ4°RÖ8Á,ÑOÓPÐPà ˆØ�l�lˆlØ×+Ñ+¨AÓ.ˆEØ�M‰M˜%Ô Ø”�U“�OˆAØ�AŽvØç#)ˆs�x‰x˜ÓÐ2¨sÐ2ùò Ps   Á'C4)rp   rq   rl   rr   rw   rx   rt   ru   re   rh   rm   rj   rd   ri   rc   rk   rv   rs   ry   rz   )rc   rd   re   ri   rh   rj   rk   rl   rm   rp   rq   rr   rs   rt   ru   rv   rw   rx   ry   rz   ©r   )ó   
©r  )(r   r   r   r   r   r@   r-   r‡   r2   r˜   r�   r¢   r§   r–   rµ   r	   r   rÊ   rÑ   r×   rÜ   rá   Úpropertyrå   rñ   rù   rþ   r  r
  rŒ   r  r“   rœ   rV   r:  r?  r  r*  r   rA   rB   s   @r   r   r   G   st  ø‡ € ñð€Ið. 7ð
 *.ð 7ð 26÷ 7ò  7÷D'ð '÷2ð 2÷9ð 9÷
1ð 1÷3ð 3÷3ð 3÷%ð %÷ð ð $1÷2ò 2÷$1ð 1÷$ð $÷0ð ÷.ð .÷	$ð 	$ð ÷+ó ð+÷
ð ÷(ò ÷(:ð :÷"%ð "%÷H ð  ð*>¸d÷ >ò >ñ%ØBF÷%ó %÷N'$ò '$÷R
%ð 
%÷ *ð  *÷D ð  ÷$ò $÷ð ÷>3ö 3r   c                   óp  a € ] tR tRt o R'tV 3R lR ltV 3R lR ltV 3R lR lt]3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V 3R lR ltR(V 3R lR lltV 3R lR ltRR/V 3R lR l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)V 3R$ lR% lltR&tV tR# )*ÚEmptyStreamReaderiF  c                ó   <€ V ^8„  d   QhRR/# r¯   r   )r%   r&   s   "€r   r'   ÚEmptyStreamReader.__annotate__J  s   ø€ ÷ ñ ˜$ñ r   c                ó"   € R V n         ^ V n        R# ©FN©Ú_read_eof_chunkry   r1   s   &r   r-   ÚEmptyStreamReader.__init__J  s   € Ø$ˆÔØˆÖr   c                ó    <€ V ^8„  d   QhRS[ /# r6   r}   )r%   r&   s   "€r   r'   rU  N  s   ø€ ÷ 0ñ 0™#ñ 0r   c                ó<   € R V P                   P                  ,          # )r�   )rƒ   r   r1   s   &r   r‡   ÚEmptyStreamReader.__repr__N  s   € Ø˜Ÿ™×/Ñ/Õ/Ð/r   c                ó.   <€ V ^8„  d   QhRS[ R,          /# r¯   r°   )r%   r&   s   "€r   r'   rU  Q  s   ø€ ÷ ñ ™=¨4Õ/ñ r   c                ó   € R # r*   r   r1   s   &r   rµ   ÚEmptyStreamReader.exceptionQ  ó   € Ùr   c                ó*   <€ V ^8„  d   QhRS[ RS[ RR/# r¹   r°   )r%   r&   s   "€r   r'   rU  T  s)   ø€ ÷ ñ áðñ !ðð 
ñ	r   c                ó   € R # r*   r   )r,   rº   r»   s   &&&r   r   ÚEmptyStreamReader.set_exceptionT  s   € ñ
 	r   c                ó6   <€ V ^8„  d   QhRS[ . R3,          RR/# rÂ   rÄ   )r%   r&   s   "€r   r'   rU  [  s(   ø€ ÷ Cñ C™x¨¨D¨Õ1ð C°dñ Cr   c                óf   €  V! 4        R#   \          d    \        P                  ! R 4        R# i ; irÆ   )rÈ   r   rµ   rÉ   s   &&r   rÊ   ÚEmptyStreamReader.on_eof[  s-   € ð	CÙŽJøÜô 	CÜ×%Ò%Ð&A×Bð	Cús   ‚ ‹!0¯0c                ó   <€ V ^8„  d   QhRR/# r¯   r   )r%   r&   s   "€r   r'   rU  a  s   ø€ ÷ ñ ˜$ñ r   c                ó   € R # r*   r   r1   s   &r   rÑ   ÚEmptyStreamReader.feed_eofa  s   € Ùr   c                ó    <€ V ^8„  d   QhRS[ /# r6   rÔ   )r%   r&   s   "€r   r'   rU  d  ó   ø€ ÷ ñ ™ñ r   c                ó   € R # ©Tr   r1   s   &r   r×   ÚEmptyStreamReader.is_eofd  ra  r   c                ó    <€ V ^8„  d   QhRS[ /# r6   rÔ   )r%   r&   s   "€r   r'   rU  g  rl  r   c                ó   € R # rn  r   r1   s   &r   rÜ   ÚEmptyStreamReader.at_eofg  ra  r   c                ó   <€ V ^8„  d   QhRR/# r¯   r   )r%   r&   s   "€r   r'   rU  j  s   ø€ ÷ ñ  ñ r   c              ƒ  ó   "  € R # 5ir*   r   r1   s   &r   rá   ÚEmptyStreamReader.wait_eofj  s   é € Ùùó   ‚c                ó,   <€ V ^8„  d   QhRS[ RS[RS[/# )r"   rè   r�   r$   rõ   )r%   r&   s   "€r   r'   rU  m  s"   ø€ ÷ ñ ™eð ©ð ±Dñ r   c                ó   € R # )Fr   )r,   rè   r�   s   &&&r   rù   ÚEmptyStreamReader.feed_datam  s   € Ùr   c                ó$   <€ V ^8„  d   QhRS[ RR/# rª   r«   )r%   r&   s   "€r   r'   rU  p  s   ø€ ÷ ñ ¡Sð ¨Tñ r   c                ó   € R # r*   r   r—   s   &&r   r–   Ú%EmptyStreamReader.set_read_chunk_sizep  s   € Ùr   r  Nc                ó4   <€ V ^8„  d   QhRS[ R,          RS[/# r  r  )r%   r&   s   "€r   r'   rU  s  s   ø€ ÷ ñ ±°tµð Áuñ r   c             ƒ  ó   "  € R # 5i©r   r   r  s   &$r   rŒ   ÚEmptyStreamReader.readlines  ó   é € Ùùrv  c                ó&   <€ V ^8„  d   QhRS[ RS[/# r�   r  )r%   r&   s   "€r   r'   rU  v  s   ø€ ÷ ñ ™Cð ©ñ r   c              ƒ  ó   "  € R # 5ir  r   r—   s   &&r   r“   ÚEmptyStreamReader.readv  r�  rv  c                ó    <€ V ^8„  d   QhRS[ /# r6   ré   )r%   r&   s   "€r   r'   rU  {  s   ø€ ÷ ñ ™uñ r   c              ƒ  ó   "  € R # 5ir  r   r1   s   &r   rœ   ÚEmptyStreamReader.readany{  r�  rv  c                ó6   <€ V ^8„  d   QhRS[ S[S[3,          /# r6   rP   )r%   r&   s   "€r   r'   rU  ~  s   ø€ ÷ ñ ¡¡u©d {Õ!3ñ r   c              ƒ  óD   "  € V P                   '       g
   R V n         R# R# 5i)TrU   r3  ©rY  r1   s   &r   rV   ÚEmptyStreamReader.readchunk~  s%   é € Ø×#×#Ð#Ø#'ˆDÔ ØÐàÐùs   ‚ c                ó&   <€ V ^8„  d   QhRS[ RS[/# r�   r  )r%   r&   s   "€r   r'   rU  …  s   ø€ ÷ 2ñ 2¡3ð 2©5ñ 2r   c              ƒ  ó8   "  € \         P                  ! R V4      h5ir  )r_   r8  r—   s   &&r   r:  ÚEmptyStreamReader.readexactly…  s   é € Ü×)Ò)¨#¨qÓ1Ð1ùs   ‚c                ó&   <€ V ^8„  d   QhRS[ RS[/# r�   r  )r%   r&   s   "€r   r'   rU  ˆ  s   ø€ ÷ ñ ™Sð ©%ñ r   c                ó   € R # r  r   r—   s   &&r   r?  ÚEmptyStreamReader.read_nowaitˆ  s   € Ùr   rX  rŠ  rN  rP  )r   r   r   r   r@   r-   r‡   rµ   r	   r   rÊ   rÑ   r×   rÜ   rá   rù   r–   rŒ   r“   rœ   rV   r:  r?  r   rA   rB   s   @r   rS  rS  F  sÇ   ø‡ € à$€I÷ð ÷0ð 0÷ð ð $1÷ò ÷Cð C÷ð ÷ð ÷ð ÷ð ÷ò ÷ð ð¸d÷ ò ÷ò ÷
ð ÷ð ÷2ð 2÷÷ ð r   rS  c                   óâ   a € ] tR tRt o R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	]
3V 3R lR l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# )r   i�  z>DataQueue is a general-purpose blocking queue with one reader.c                ó8   <€ V ^8„  d   QhRS[ P                  RR/# )r"   rZ   r$   N)r_   r`   )r%   r&   s   "€r   r'   ÚDataQueue.__annotate__’  s%   ø€ ÷ Nñ N™W×6Ñ6ð N¸4ñ Nr   c                óp   € Wn         R V n        RV n        RV n        \        P
                  ! 4       V n        R# rW  )rj   rr   rs   ru   rn   ro   rp   )r,   rZ   s   &&r   r-   ÚDataQueue.__init__’  s,   € ØŒ
ØˆŒ	Ø48ˆŒØ04ˆŒÜ:E×:KÒ:KÓ:MˆŽr   c                ó    <€ V ^8„  d   QhRS[ /# r6   r«   )r%   r&   s   "€r   r'   r”  ™  s   ø€ ÷ !ñ !™ñ !r   c                ó,   € \        V P                  4      # r*   )rï   rp   r1   s   &r   Ú__len__ÚDataQueue.__len__™  s   € Ü�4—<‘<Ó Ð r   c                ó    <€ V ^8„  d   QhRS[ /# r6   rÔ   )r%   r&   s   "€r   r'   r”  œ  s   ø€ ÷ ñ ™ñ r   c                ó   € V P                   # r*   rÖ   r1   s   &r   r×   ÚDataQueue.is_eofœ  s   € Ø�y‰yÐr   c                ó    <€ V ^8„  d   QhRS[ /# r6   rÔ   )r%   r&   s   "€r   r'   r”  Ÿ  s   ø€ ÷ .ñ .™ñ .r   c                óL   € V P                   ;'       d    V P                  '       * # r*   rÛ   r1   s   &r   rÜ   ÚDataQueue.at_eofŸ  s   € Ø�y‰y×-Ð- §¡Ô-Ð-r   c                ó.   <€ V ^8„  d   QhRS[ R,          /# r¯   r°   )r%   r&   s   "€r   r'   r”  ¢  r²   r   c                ó   € V P                   # r*   r´   r1   s   &r   rµ   ÚDataQueue.exception¢  r·   r   c                ó*   <€ V ^8„  d   QhRS[ RS[ RR/# r¹   r°   )r%   r&   s   "€r   r'   r”  ¥  s)   ø€ ÷ 	2ñ 	2áð	2ñ !ð	2ð 
ñ		2r   c                ój   € R V n         Wn        V P                  ;pe   RV n        \        W1V4       R# R# ©TN)rr   ru   rs   r   r¾   s   &&& r   r   ÚDataQueue.set_exception¥  s5   € ð
 ˆŒ	ØŒØ—l‘lÐ"ˆFÒ/ØˆDŒLÜ˜& yÖ1ñ 0r   c                ó*   <€ V ^8„  d   QhRS[ RS[RR/# ©r"   rè   rô   r$   N©r   r^   )r%   r&   s   "€r   r'   r”  °  s"   ø€ ÷ %ñ %™bð %©ð %°Dñ %r   c                óˆ   € V P                   P                  W34       V P                  ;pe   R V n        \        VR 4       R # R # r*   )rp   r„   rs   r   )r,   rè   rô   r¿   s   &&& r   rù   ÚDataQueue.feed_data°  s;   € Ø�‰×Ñ˜T˜LÔ)Ø—l‘lÐ"ˆFÒ/ØˆDŒLÜ�v˜tÖ$ñ 0r   c                ó   <€ V ^8„  d   QhRR/# r¯   r   )r%   r&   s   "€r   r'   r”  ¶  s   ø€ ÷ %ñ %˜$ñ %r   c                ó^   € R V n         V P                  ;pe   RV n        \        VR4       R# R# r¦  )rr   rs   r   )r,   r¿   s   & r   rÑ   ÚDataQueue.feed_eof¶  s.   € ØˆŒ	Ø—l‘lÐ"ˆFÒ/ØˆDŒLÜ�v˜tÖ$ñ 0r   c                ó    <€ V ^8„  d   QhRS[ /# r6   r7   )r%   r&   s   "€r   r'   r”  ¼  s   ø€ ÷ ñ ™Bñ r   c              ƒ  óè  "  € V P                   '       g[   V P                  '       gI   V P                  '       d   Q hV P                  P	                  4       V n         V P                  G R j  x€L
  V P                   '       d   V P                   P                  4       w  rV# V P                  e   V P                  h\        h LT  \
        P                  \
        P                  3 d
    R T n        h i ; i5ir*   )rp   rr   rs   rj   rà   r_   ÚCancelledErrorÚTimeoutErrorr4  ru   r   )r,   rè   rK  s   &  r   r“   ÚDataQueue.read¼  s¶   é € Ø�|�|ˆ| D§I§I IØ—|—|�|Ð#Ð#ØŸ:™:×3Ñ3Ó5ˆDŒLðØ—l‘l×"Ð"ð �<�<ˆ<Ø—l‘l×*Ñ*Ó,‰GˆDØˆKØ�?‰?Ò&Ø—/‘/Ð!Üˆñ #øÜ×*Ñ*¬G×,@Ñ,@ÐAô Ø#�”Øðüs?   ‚$C2§C2¹!C2ÁC Á*B?Á+C Á/C2Â>C2Â?C Ã.C/Ã/C2c                ó0   <€ V ^8„  d   QhRS[ S[,          /# r6   )r    r   )r%   r&   s   "€r   r'   r”  Ì  s   ø€ ÷ .ñ .Ñ.©rÕ2ñ .r   c                ó,   € \        V P                  4      # r*   )r    r“   r1   s   &r   r2   ÚDataQueue.__aiter__Ì  s   € Ü" 4§9¡9Ó-Ð-r   )rp   rr   ru   rj   rs   NrN  )r   r   r   r   r   r-   r™  r×   rÜ   rµ   r	   r   rù   rÑ   r“   r2   r   rA   rB   s   @r   r   r   �  ss   ø‡ € ÙH÷Nð N÷!ð !÷ð ÷.ð .÷ð ð $1÷	2ò 	2÷%ò %÷%ð %÷ð ÷ .ö .r   c                   óp   a a€ ] tR tRt oRtV3R lV 3R lltR
V3R lV 3R llltV3R lR ltR	tVt	V ;t
# )ÚFlowControlDataQueueiÐ  z¢FlowControlDataQueue resumes and pauses an underlying stream.

It is a destination for parsed data.

This class is deprecated and will be removed in version 4.0.
c                óD   <€ V ^8„  d   QhRS[ RS[RS[P                  RR/# )r"   r\   r]   rZ   r$   N)r   r^   r_   r`   )r%   r&   s   "€r   r'   Ú!FlowControlDataQueue.__annotate__Ø  s3   ø€ ÷  ñ  Ù$ð Ù-0ð Ù;B×;TÑ;Tð à	ñ r   c               ó^   <€ \         SV `  VR 7       ^ V n        Wn        V^,          V n        R# ))rZ   N)Úsuperr-   rk   rc   Ú_limit)r,   r\   r]   rZ   rƒ   s   &&&$€r   r-   ÚFlowControlDataQueue.__init__Ø  s,   ø€ ô 	‰Ñ˜dÐÔ#ØˆŒ
Ø!ŒØ˜a•iˆŽr   c                ó*   <€ V ^8„  d   QhRS[ RS[RR/# r©  rª  )r%   r&   s   "€r   r'   r»  à  s"   ø€ ÷ +ñ +™bð +©ð +°Dñ +r   c                ó  <€ \         SV `  W4       V ;P                  V,          un        V P                  V P                  8”  d;   V P                  P
                  '       g   V P                  P                  4        R # R # R # r*   )r½  rù   rk   r¾  rc   Ú_reading_pausedr÷   )r,   rè   rô   rƒ   s   &&&€r   rù   ÚFlowControlDataQueue.feed_dataà  sV   ø€ Ü‰Ñ˜$Ô%Ø�
Š
�dÕ�
à�:‰:˜Ÿ™Ô#¨D¯N©N×,J×,JÐ,JØ�N‰N×(Ñ(Ö*ñ -KÑ#r   c                ó    <€ V ^8„  d   QhRS[ /# r6   r7   )r%   r&   s   "€r   r'   r»  ç  s   ø€ ÷ ñ ™Bñ r   c              ƒ  ó¼  "  € V P                   '       g[   V P                  '       gI   V P                  '       d   Q hV P                  P	                  4       V n         V P                  G R j  x€L
  V P                   '       d‰   V P                   P                  4       w  rV ;P                  V,          un	        V P                  V P                  8  d7   V P                  P                  '       d   V P                  P                  4        V# V P                  e   V P                  h\        h L¾  \
        P                  \
        P                  3 d
    R T n        h i ; i5ir*   )rp   rr   rs   rj   rà   r_   r²  r³  r4  rk   r¾  rc   rÂ  rÏ   ru   r   )r,   rè   rô   s   &  r   r“   ÚFlowControlDataQueue.readç  só   é € Ø�|�|ˆ| D§I§I IØ—|—|�|Ð#Ð#ØŸ:™:×3Ñ3Ó5ˆDŒLðØ—l‘l×"Ð"ð �<�<ˆ<ØŸ™×-Ñ-Ó/‰JˆDØ�JŠJ˜$Õ�JØ�z‰z˜DŸK™KÔ'¨D¯N©N×,J×,JÐ,JØ—‘×-Ñ-Ô/ØˆKØ�?‰?Ò&Ø—/‘/Ð!Üˆñ #øÜ×*Ñ*¬G×,@Ñ,@ÐAô Ø#�”ØðüsF   ‚$E§E¹!EÁD+ Á*D)Á+D+ Á/EÂA+EÃ-<EÄ)D+ Ä+.EÅE)r¾  rc   rk   rs   rN  )r   r   r   r   r   r-   rù   r“   r   rA   Ú__classcell__)rƒ   r&   s   @@r   r¹  r¹  Ð  s-   ù‡ € ñ÷ ó  ÷+õ +÷÷ ð r   r¹  c                óV   € V ^8„  d   Qh/ ^ \         9   d   \        \        ,          ;R&   # )r"   ÚEMPTY_PAYLOAD)Ú__conditional_annotations__r   r   )r%   s   "r   r'   r'      s   € ‡�÷V 9Ò 8Œu”\Õ"Ñ 8òW r   )rÉ  r   r   r   )%rÊ  r_   rn   r(  rì   Úcollections.abcr   r   Útypingr   r   r   Úbase_protocolr   Úhelpersr	   r
   r   r   r   r   Úhttp_exceptionsr   Úlogr   Ú__all__r   rÈ   r   r    rD   r   rS  rÉ  r   r¹  r'   )rÊ  s   @r   Ú<module>rÒ     s´   øðß €Û Û 
Û ß /ß *Ñ *å '÷÷ õ )Ý  ð€ñ ˆTƒ]€ô!�	ô !ô˜' "�+ô ÷(ñ ÷"|3ñ |3ô~C˜ô CñL &7Ó%8€Ó 8ô>.�˜•ô >.ôB(˜9 R�=ö (r   