+
    TŎir\                       a  R t$0 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Ht ^RIHt ^RIHtHtHtHt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 ! R R]4      t ] ! 4       t!] ^ k  ! R R]	],          4      t" ! R R]"],          4      t#R# )    N)		AwaitableCallableDequeFinalGenericListOptionalTupleTypeVar)BaseProtocol)_EXC_SENTINELBaseTimerContext	TimerNoopset_exception
set_result)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       ^/Users/ahmad/.openclaw/workspace/scripts/.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)     # #(2y}+<"= #$ #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*   2   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__2   sF     	%~~''B 9$$	 ( 	%$$	%s#   A- +- A- ?Ar-   N
r   r   r   r   	__slots__r/   r4   r?   r   __classdictcell__r(   s   @r    r"   r"   (   s(     I# #  r   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# )	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.   rH   s   &&r    r/   &ChunkTupleAsyncStreamIterator.__init__@   s    r   c                   < V ^8  d   QhRR/# )r$   r&   rF   r   )r'   r(   s   "r    r)   rI   C   s      : r   c                    V # r,   r   r3   s   &r    r4   'ChunkTupleAsyncStreamIterator.__aiter__C   r6   r   c                6   < V ^8  d   QhRS[ S[S[3,          /# r8   r
   bytesbool)r'   r(   s   "r    r)   rI   F   s      ud{!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)rL   	readchunkr<   r=   s   & r    r?   'ChunkTupleAsyncStreamIterator.__anext__F   s2     <<))++$$	 ,s   646rK   NrA   rD   s   @r    rF   rF   <   s(     I   r   rF   c                   l   a  ] tR t^Mt 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R	t	V t
R
# )AsyncStreamReaderMixinc                0   < V ^8  d   QhRS[ S[,          /# r8   r"   rS   )r'   r(   s   "r    r)   #AsyncStreamReaderMixin.__annotate__Q   s     2 2.u5 2r   c                ,    \        V P                  4      # r,   )r"   readliner3   s   &r    r4    AsyncStreamReaderMixin.__aiter__Q   s    "4==11r   c                6   < V ^8  d   QhRS[ RS[S[,          /# r$   nr&   )intr"   rS   )r'   r(   s   "r    r)   r]   T   s!     9 9c 9&9%&@ 9r   c                &   a a \        VV 3R l4      # )z>Returns an asynchronous iterator that yields chunks of size n.c                  &   < SP                  S 4      # r,   )read)rc   r.   s   r    <lambda>5AsyncStreamReaderMixin.iter_chunked.<locals>.<lambda>V   s    499Q<r   )r"   r.   rc   s   ffr    iter_chunked#AsyncStreamReaderMixin.iter_chunkedT   s    "#788r   c                0   < V ^8  d   QhRS[ S[,          /# r8   r\   )r'   r(   s   "r    r)   r]   X   s     1 1-e4 1r   c                ,    \        V P                  4      # )z3Yield all available data as soon as it is received.)r"   readanyr3   s   &r    iter_anyAsyncStreamReaderMixin.iter_anyX   s    "4<<00r   c                    < V ^8  d   QhRS[ /# r8   rF   )r'   r(   s   "r    r)   r]   \   s     3 3: 3r   c                    \        V 4      # )zYield 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.
rs   r3   s   &r    iter_chunks"AsyncStreamReaderMixin.iter_chunks\   s     -T22r   r   N)r   r   r   r   rB   r4   rk   rp   ru   r   rC   rD   s   @r    rZ   rZ   M   s2     I2 29 91 13 3r   rZ   c                     a  ] tR t^et o RtR8t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	]
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R9V 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: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R0 ltR;V 3R1 lR2 lltV 3R3 lR4 ltV 3R5 lR6 lt R7t!V t"R# )<r   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          
      j   < V ^8  d   QhRS[ RS[RS[S[,          RS[S[P
                  ,          RR/# )r$   protocollimitrx   ry   r&   N)r   rd   r	   r   asyncioAbstractEventLoop)r'   r(   s   "r    r)   StreamReader.__annotate__   sN      :  : :  :
 () : w001 : 
 :r   c                  Wn         W n        V^,          V n        Vf   \        P                  ! 4       p\        ^V^,          4      V n        \        ^V P                  ^,          4      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|   rx   ry   s   &&&$$r    r/   StreamReader.__init__   s     " 19<))+D"%a!"4 "%Q(?(?1(D!E

8<%0%6%6%8	7;;?37%*]ik8:59#r   c                    < V ^8  d   QhRS[ /# r8   str)r'   r(   s   "r    r)   r      s     ' '# 'r   c                \   V P                   P                  .pV P                  '       d#   VP                  R V P                  ,          4       V P                  '       d   VP                  R4       V P
                  R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> i   )
	__class__r   r   appendr   r   r   r   r   join)r.   infos   & r    __repr__StreamReader.__repr__   s    ''(:::KK
TZZ/0999KK??e#KK(DOOT=M=M+NNO<<<KK-.???KK01&&r   c                6   < V ^8  d   QhRS[ S[S[3,          /# r8   )r
   rd   )r'   r(   s   "r    r)   r      s     3 3c3h 3r   c                2    V P                   V P                  3# r,   )r   r   r3   s   &r    get_read_buffer_limits#StreamReader.get_read_buffer_limits   s    !1!122r   c                0   < V ^8  d   QhRS[ S[,          /# r8   r	   BaseException)r'   r(   s   "r    r)   r            8M2 r   c                    V P                   # r,   r   r3   s   &r    	exceptionStreamReader.exception       r   c                *   < V ^8  d   QhRS[ RS[ RR/# r$   exc	exc_causer&   Nr   )r'   r(   s   "r    r)   r      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,   )r   r   clearr   r   r   r.   r   r   waiters   &&& r    r   StreamReader.set_exception   sc    
 !!#DL&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)   r      s$     1 1xD1 1d 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)r   	Exceptionr   r   r   r   r.   r   s   &&r    on_eofStreamReader.on_eof   sN    999G
 &&x0  G))*EFGs   : !AAc                   < V ^8  d   QhRR/# r$   r&   Nr   )r'   r(   s   "r    r)   r      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
                  '       d   V P                  P                  4        V P                   F  p V! 4        K  	  V P                  P                  4        R#   \         d    \        P                  ! R4        KO  i ; i)TNr   )r   r   r   r   r   _reading_pausedresume_readingr   r   r   r   r   )r.   r   cbs   &  r    feed_eofStreamReader.feed_eof   s    	DLvt$!!#Dvt$>>)))NN))+%%BG & 	!!#  G))*EFGs   B;;!C C c                    < V ^8  d   QhRS[ /# r8   rT   )r'   r(   s   "r    r)   r      s       r   c                    V P                   # )z&Return True if  'feed_eof' was called.r   r3   s   &r    is_eofStreamReader.is_eof   s    yyr   c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   r      s     . . .r   c                L    V P                   ;'       d    V P                  '       * # )z=Return True if the buffer is empty and 'feed_eof' was called.r   r   r3   s   &r    at_eofStreamReader.at_eof   s    yy----r   c                   < V ^8  d   QhRR/# r   r   )r'   r(   s   "r    r)   r      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,   )r   r   r   create_futurer3   s   &r    wait_eofStreamReader.wait_eof   sb     999'''::335	$""""#D ##Ds0   AA2A& A$A& 	A2$A& &	A//A2c                    < V ^8  d   QhRS[ /# r8   rd   )r'   r(   s   "r    r)   r     s     + + +r   c                N    V P                   f   V P                  # V P                   # r,   )r   r   r3   s   &r    total_raw_bytesStreamReader.total_raw_bytes  s&    &&.###***r   c                $   < V ^8  d   QhRS[ RR/# )r$   datar&   NrS   )r'   r(   s   "r    r)   r     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DeprecationWarningr   r   r   lenr   
appendleftr   )r.   r   s   &&r    unread_dataStreamReader.unread_data  s    =		
 "ll1od.A.A.CDDLLO"#D

c$i
D	!%r   c                *   < V ^8  d   QhRS[ RS[RR/# r$   r   sizer&   NrS   rd   )r'   r(   s   "r    r)   r      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                  '       g   V P                  P                  4        R# R# R# )zfeed_data after feed_eofN)r   r   r   r   r   r   r   r   r   r   r   pause_reading)r.   r   r   data_lenr   s   &&&  r    	feed_dataStreamReader.feed_data   s    999888}t9

h
D!H$DLvt$::(((1O1O1ONN((* 2P(r   c                   < V ^8  d   QhRR/# r   r   )r'   r(   s   "r    r)   r   3  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)r   r   RuntimeErrorr   r   r3   s   &r    begin_http_chunk_receiving'StreamReader.begin_http_chunk_receiving3  sB    ""*"V  '2&7&7&9D# +r   c                   < V ^8  d   QhRR/# r   r   )r'   r(   s   "r    r)   r   ;  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  d7   V P                  P                  '       g   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)r   r   r   r   r   r   r   r   r   r   r   )r.   posr   s   &  r    end_http_chunk_receiving%StreamReader.end_http_chunk_receiving;  s    ""*.  .2-D-D-Dd%%b)!s" &&t'7'78 ''(4+B+BBNN222NN((* DLvt$ r   c                $   < V ^8  d   QhRS[ RR/# )r$   	func_namer&   Nr   )r'   r(   s   "r    r)   r   b  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)r   	connectedr   r   r   r   r   )r.   r  r   s   && r    _waitStreamReader._waitb  s     ~~'''344 <<#46?@ 
 !%

 8 8 ::	    DL    DLsH   A(B<+B0 ?BBB
B0 	B<BB-	(B0 0	B99B<c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   r   w  s     & & &r   c                >   "   V P                  4       G R j  xL
 #  L5ir,   )	readuntilr3   s   &r    r_   StreamReader.readlinew  s     ^^%%%%s   c                &   < V ^8  d   QhRS[ RS[ /# )r$   	separatorr&   r   )r'   r(   s   "r    r)   r   z  s     " " "5 "r   c                  "   \        V4      pV^ 8X  d   \        R4      hV P                  e   V P                  hRp^ pRpV'       d   V P                  '       d   V'       d   V P                  pV P                  ^ ,          P                  W4      ^,           pT P                  V'       d   Wv,
          V,           ^,
          MR4      pW8,          pV\        V4      ,          pV'       d   RpW@P                  8  g   K  \        R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   TFzChunk too bigr  r  )
r   
ValueErrorr   r   r   find_read_nowait_chunkr   r   r
  )	r.   r  seplenchunk
chunk_size
not_enoughoffseticharr   s	   &&       r    r  StreamReader.readuntilz  s	    YQ;KLL??&//!

,,,:,,Q,,Y?!C..38ENV+a/b c$i'
!&J 0 00$_55yyy
  zjj--- .s7   AEEE"BE<EE&E:E;
Ec                &   < V ^8  d   QhRS[ RS[/# rb   rd   rS   )r'   r(   s   "r    r)   r     s     ($ ($C ($ ($r   c                f  "   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  dI   . p V P                  4       G R j  xL
 pV'       g   MVP                  V4       K5  R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)NTr   zEMultiple access to StreamReader in eof state, might be infinite loop.)
stack_infor   rg   )r   r   r   getattrr   r   warningro   r   r   r
  _read_nowait)r.   rc   blocksblocks   &&  r    rg   StreamReader.read  s     ??&//! yyy$+D.!$Dq$H!$$q(#++2#' q5
 F"lln,e$88F##
 ,,,tyyy**V$$$  ## - %sG   -D1D1A	D1D1+D-,D186D1/D1D1D/D1/D1c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   r     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)Nro   r  )r   r   r   r
  r#  r3   s   &r    ro   StreamReader.readany  sT     ??&//!
 ,,,tyyy**Y'''  $$ (s   ,A/A/A/A-A/c                6   < V ^8  d   QhRS[ S[S[3,          /# r8   rR   )r'   r(   s   "r    r)   r     s      *  *ud{!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)	zReturns 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 boundaryFrW   r   Tr  rV   )r   r   popleftr   r#  r   r"  r   r  r   r
  )r.   r  s   & r    rW   StreamReader.readchunk  s      *oo%)))--557,,&&&% --cLL.@A4HH''8
 |||//3U;; yyy $#**[)))s#   -C=BC=9$C=C=4C;5C=c                &   < V ^8  d   QhRS[ RS[/# rb   r  )r'   r(   s   "r    r)   r     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r;   )r   rg   r   r}   IncompleteReadErrorr   r   )r.   rc   r$  r%  partials   &&   r    readexactlyStreamReader.readexactly  s     ??&//! !e))A,&E((6*11'3w<!;KLLMM% UOAxx 's   8B7B5B7A/B7c                &   < V ^8  d   QhRS[ RS[/# rb   r  )r'   r(   s   "r    r)   r     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.)r   r   doner   r#  rj   s   &&r    read_nowaitStreamReader.read_nowait  sV    
 ??&//!<<< 1 1 3 3K    ##r   c                &   < V ^8  d   QhRS[ RS[/# rb   r  )r'   r(   s   "r    r)   r     s     ! !C !E !r   c                T   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                  P                  '       dh   V P                  V P                  8  dM   V P                  e%   \        V P                  4      V P                  8  d   V P                  P                  4        V# )r   Nr  )r   r   r   r-  r   r   r   r   r   r   r   r   )r.   rc   first_bufferr  r   r   chunk_splitss   &&     r    r  StreamReader._read_nowait_chunk  s4   ||A$$7s<(61A54D1$LL  "(D"#D <<'')Dt9

h
 ..|A=  " NN***

T__,''/t../$2H2HH NN))+r   c                &   < V ^8  d   QhRS[ RS[/# rb   r  )r'   r(   s   "r    r)   r   7  s     3 3c 3e 3r   c                "   V P                   P                  4        . pV P                  '       dH   V P                  V4      pVP	                  V4       VR8w  g   K=  V\        V4      ,          pV^ 8X  g   KX   V'       d   RP                  V4      # R# )z6Read not more than n bytes, or whole buffer if n == -1r   r  )r   assert_timeoutr   r  r   r   r   )r.   rc   chunksr  s   &&  r    r#  StreamReader._read_nowait7  sp    ""$lll++A.EMM% BwSZ6#)sxx2s2r   )r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   )r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   )   
r  )#r   r   r   r   r   rB   r/   r   r   r   r   r   r   r   r   r   r   propertyr   r   r   r   r  r
  r_   r  rg   ro   rW   r3  r8  r  r#  r   rC   rD   s   @r    r   r   e   s4    I. :
 -1 : 59 :  :D' '3 3  $12 2$1 1$ $0 . .	$ 	$ + +
 (+ +&: :%% %%N   *& &" "H($ ($T
% 
% *  *D   $ $! !F3 3r   c                   V  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&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## )'EmptyStreamReaderiG  c                   < V ^8  d   QhRR/# r   r   )r'   r(   s   "r    r)   EmptyStreamReader.__annotate__K  s      $ r   c                "    R V n         ^ V n        R# FN_read_eof_chunkr   r3   s   &r    r/   EmptyStreamReader.__init__K  s    $r   c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   rK  O  s     0 0# 0r   c                <    R V P                   P                  ,          # )r   )r   r   r3   s   &r    r   EmptyStreamReader.__repr__O  s    ////r   c                0   < V ^8  d   QhRS[ S[,          /# r8   r   )r'   r(   s   "r    r)   rK  R  s      8M2 r   c                    R # r,   r   r3   s   &r    r   EmptyStreamReader.exceptionR      r   c                *   < V ^8  d   QhRS[ RS[ RR/# r   r   )r'   r(   s   "r    r)   rK  U  s)       ! 
	r   c                    R # r,   r   )r.   r   r   s   &&&r    r   EmptyStreamReader.set_exceptionU  s    
 	r   c                6   < V ^8  d   QhRS[ . R3,          RR/# r   r   )r'   r(   s   "r    r)   rK  \  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)   rK  b  s      $ r   c                    R # r,   r   r3   s   &r    r   EmptyStreamReader.feed_eofb      r   c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   rK  e         r   c                    R # Tr   r3   s   &r    r   EmptyStreamReader.is_eofe  rW  r   c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   rK  h  rc  r   c                    R # re  r   r3   s   &r    r   EmptyStreamReader.at_eofh  rW  r   c                   < V ^8  d   QhRR/# r   r   )r'   r(   s   "r    r)   rK  k  s       r   c                   "   R # 5ir,   r   r3   s   &r    r   EmptyStreamReader.wait_eofk  s        c                *   < V ^8  d   QhRS[ RS[RR/# )r$   r   rc   r&   Nr   )r'   r(   s   "r    r)   rK  n  s"      e  D r   c                    R # r,   r   )r.   r   rc   s   &&&r    r   EmptyStreamReader.feed_datan  ra  r   c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   rK  q  s       r   c                   "   R # 5ir   r   r3   s   &r    r_   EmptyStreamReader.readlineq       rm  c                &   < V ^8  d   QhRS[ RS[/# rb   r  )r'   r(   s   "r    r)   rK  t  s      C  r   c                   "   R # 5irs  r   rj   s   &&r    rg   EmptyStreamReader.readt  ru  rm  c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   rK  y  s      u r   c                   "   R # 5irs  r   r3   s   &r    ro   EmptyStreamReader.readanyy  ru  rm  c                6   < V ^8  d   QhRS[ S[S[3,          /# r8   rR   )r'   r(   s   "r    r)   rK  |  s      ud{!3 r   c                D   "   V P                   '       g
   R V n         R# R# 5i)TrV   r,  rO  r3   s   &r    rW   EmptyStreamReader.readchunk|  s%     ####'D s    c                &   < V ^8  d   QhRS[ RS[/# rb   r  )r'   r(   s   "r    r)   rK    s     2 23 25 2r   c                8   "   \         P                  ! R V4      h5irs  )r}   r1  rj   s   &&r    r3  EmptyStreamReader.readexactly  s     ))#q11s   c                &   < V ^8  d   QhRS[ RS[/# rb   r  )r'   r(   s   "r    r)   rK    s      S % r   c                    R # rs  r   rj   s   &&r    r8  EmptyStreamReader.read_nowait  s    r   rN  Nr~  rD  rF  )r   r   r   r   rB   r/   r   r   r   r   r   r   r   r   r   r   r_   rg   ro   rW   r3  r8  r   rC   rD   s   @r    rI  rI  G  s     $I 0 0  $1 C C       
  2 2  r   rI  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$   ry   r&   N)r}   r~   )r'   r(   s   "r    r)   DataQueue.__annotate__  s%     B BW66 B4 Br   c                p    Wn         R V n        RV n        RV n        \        P
                  ! 4       V n        R# rM  )r   r   r   r   r   r   r   )r.   ry   s   &&r    r/   DataQueue.__init__  s,    
	7;37.9.?.?.Ar   c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   r    s     ! ! !r   c                ,    \        V P                  4      # r,   )r   r   r3   s   &r    __len__DataQueue.__len__  s    4<<  r   c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   r    s       r   c                    V P                   # r,   r   r3   s   &r    r   DataQueue.is_eof  s    yyr   c                    < V ^8  d   QhRS[ /# r8   r   )r'   r(   s   "r    r)   r    s     . . .r   c                L    V P                   ;'       d    V P                  '       * # r,   r   r3   s   &r    r   DataQueue.at_eof  s    yy----r   c                0   < V ^8  d   QhRS[ S[,          /# r8   r   )r'   r(   s   "r    r)   r    r   r   c                    V P                   # r,   r   r3   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)r   r   r   r   r   s   &&& r    r   DataQueue.set_exception  s5    
 	ll"F/DL&y1 0r   c                *   < V ^8  d   QhRS[ RS[RR/# r   r   rd   )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,   )r   r   r   r   )r.   r   r   r   s   &&& r    r   DataQueue.feed_data  s;    TL)ll"F/DLvt$ 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  )r   r   r   )r.   r   s   & r    r   DataQueue.feed_eof  s.    	ll"F/DLvt$ 0r   c                    < V ^8  d   QhRS[ /# r8   r9   )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,   )r   r   r   r   r   r}   CancelledErrorTimeoutErrorr-  r   r   )r.   r   _s   &  r    rg   DataQueue.read  s     |||DIII|||##::335DLll"" <<<ll**,GD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[,          /# r8   )r"   r   )r'   r(   s   "r    r)   r    s     . ..r2 .r   c                ,    \        V P                  4      # r,   )r"   rg   r3   s   &r    r4   DataQueue.__aiter__  s    "499--r   )r   r   r   r   r   NrD  )r   r   r   r   r   r/   r  r   r   r   r   r   r   r   rg   r4   r   rC   rD   s   @r    r   r     ss     HB B! ! . .  $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  zFlowControlDataQueue 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|   ry   r&   N)r   rd   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# ))ry   N)superr/   r   r   _limit)r.   r{   r|   ry   r   s   &&&$r    r/   FlowControlDataQueue.__init__  s,     	d#
!ai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   r   r  r   r   r   )r.   r   r   r   s   &&&r    r   FlowControlDataQueue.feed_data  sV    $%

d
::#DNN,J,J,JNN((* -K#r   c                    < V ^8  d   QhRS[ /# r8   r9   )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,   )r   r   r   r   r   r}   r  r  r-  r   r  r   r   r   r   r   )r.   r   r   s   &  r    rg   FlowControlDataQueue.read  s     |||DIII|||##::335DLll"" <<<--/JDJJ$JzzDKK'DNN,J,J,J--/K??&//! #**G,@,@A #sF   $EE!ED+ *D)+D+ /EA+E-<E)D+ +.EE)r  r   r   r   rD  )r   r   r   r   r   r/   r   rg   r   rC   __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    R 9 8u\" 8S r   )r  r   r   r   )%r  r}   r   r   typingr   r   r   r   r   r   r	   r
   r   base_protocolr   helpersr   r   r   r   r   logr   __all__r   r   r   r"   rF   rZ   r   rI  r  r   r  r)   )r  s   @r    <module>r     s      
 
 
 (  ! T]!	 !'"+ ( "3 30_3) _3D@ @F &7%8 8>. >.B(9R= (r   