+
    ~jp]                       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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)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       d/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.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+   0   s      4 r    c                    V # r-   r   r/   s   &r!   	__aiter__AsyncStreamIterator.__aiter__0       r    c                    < V ^8  d   QhRS[ /# r%   r'   r   )r(   r)   s   "r!   r*   r+   3   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__3   sF     	%~~''B 9$$	 ( 	%$$	%s#   A- +- A- ?Ar.   N
r   r   r   r   	__slots__r0   r5   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__A   s      ~ $ r    c                    Wn         R # r-   _stream)r/   rI   s   &&r!   r0   &ChunkTupleAsyncStreamIterator.__init__A   s    r    c                   < V ^8  d   QhRR/# )r%   r'   rG   r   )r(   r)   s   "r!   r*   rJ   D   s      : r    c                    V # r-   r   r4   s   &r!   r5   'ChunkTupleAsyncStreamIterator.__aiter__D   r7   r    c                6   < V ^8  d   QhRS[ S[S[3,          /# r9   r
   bytesbool)r(   r)   s   "r!   r*   rJ   G   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)rM   	readchunkr=   r>   s   & r!   r@   'ChunkTupleAsyncStreamIterator.__anext__G   s2     <<))++$$	 ,s   646rL   NrB   rE   s   @r!   rG   rG   =   s(     I   r    rG   c                   l   a  ] tR t^Nt 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[,          /# r9   r#   rT   )r(   r)   s   "r!   r*   #AsyncStreamReaderMixin.__annotate__R   s     2 2.u5 2r    c                ,    \        V P                  4      # r-   )r#   readliner4   s   &r!   r5    AsyncStreamReaderMixin.__aiter__R   s    "4==11r    c                6   < V ^8  d   QhRS[ RS[S[,          /# r%   nr'   )intr#   rT   )r(   r)   s   "r!   r*   r^   U   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)rd   r/   s   r!   <lambda>5AsyncStreamReaderMixin.iter_chunked.<locals>.<lambda>W   s    499Q<r    )r#   r/   rd   s   ffr!   iter_chunked#AsyncStreamReaderMixin.iter_chunkedU   s    "#788r    c                0   < V ^8  d   QhRS[ S[,          /# r9   r]   )r(   r)   s   "r!   r*   r^   Y   s     1 1-e4 1r    c                ,    \        V P                  4      # )z3Yield all available data as soon as it is received.)r#   readanyr4   s   &r!   iter_anyAsyncStreamReaderMixin.iter_anyY   s    "4<<00r    c                    < V ^8  d   QhRS[ /# r9   rG   )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.
rt   r4   s   &r!   iter_chunks"AsyncStreamReaderMixin.iter_chunks]   s     -T22r    r   N)r   r   r   r   rC   r5   rl   rq   rv   r   rD   rE   s   @r!   r[   r[   N   s2     I2 29 91 13 3r    r[   c                   &  a  ] tR t^ft o RtR: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	]
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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%R/V 3R& lR' lltR<R(R/V 3R) lR* llltR=V 3R+ lR, lltV 3R- lR. ltV 3R/ lR0 ltV 3R1 lR2 ltR=V 3R3 lR4 lltV 3R5 lR6 ltV 3R7 lR8 lt R9t!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limitry   rz   r'   N)r   re   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}   ry   rz   s   &&&$$r!   r0   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[ /# r9   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,          /# r9   )r
   re   )r(   r)   s   "r!   r*   r      s     3 3c3h 3r    c                2    V P                   V P                  3# r-   )r   r   r4   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[,          /# r9   r	   BaseException)r(   r)   s   "r!   r*   r            8M2 r    c                    V P                   # r-   r   r4   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[ /# r9   rU   )r(   r)   s   "r!   r*   r      s       r    c                    V P                   # )z&Return True if  'feed_eof' was called.r   r4   s   &r!   is_eofStreamReader.is_eof   s    yyr    c                    < V ^8  d   QhRS[ /# r9   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   r4   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_futurer4   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[ /# r9   re   )r(   r)   s   "r!   r*   r     s     + + +r    c                N    V P                   f   V P                  # V P                   # r-   )r   r   r4   s   &r!   total_raw_bytesStreamReader.total_raw_bytes  s&    &&.###***r    c                $   < V ^8  d   QhRS[ RR/# )r%   datar'   NrT   )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rT   re   )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   4  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   r4   s   &r!   begin_http_chunk_receiving'StreamReader.begin_http_chunk_receiving4  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   c  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._waitc  s     ~~'''344 <<#46?@ 
 !%

 8 8 ::	    DL    DLsH   A(B<+B0 ?BBB
B0 	B<BB-	(B0 0	B99B<max_line_lengthc                6   < V ^8  d   QhRS[ S[,          RS[/# r%   r  r'   r	   re   rT   )r(   r)   s   "r!   r*   r   x  s     > ># >% >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.readlinex  s     ^^_^====s   r  c                <   < V ^8  d   QhRS[ RS[S[,          RS[ /# )r%   	separatorr  r'   )rT   r	   re   )r(   r)   s   "r!   r*   r   {  s)     % %%5=c]%	%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:Nd   Ns   ...r  r  )r   
ValueErrorr   r   r   r   find_read_nowait_chunkr   r   r  )
r/   r  r  seplenchunk
chunk_size
not_enoughoffseticharr   s
   &&$       r!   r  StreamReader.readuntil{  s%     YQ;KLL??&//!

//t//j,,,:,,Q,,Y?!C..38ENV+a/b c$i'
!&J(%eDkF&:HEEyyy
  zjj--- .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[/# rc   re   rT   )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    rh   )r   r   r   getattrr   r   warningrp   r   r   r  _read_nowait)r/   rd   blocksblocks   &&  r!   rh   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[ /# r9   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)Nrp   r  )r   r   r   r  r*  r4   s   &r!   rp   StreamReader.readany  sT     ??&//!
 ,,,tyyy**Y'''  $$ (s   ,A/A/A/A-A/c                6   < V ^8  d   QhRS[ S[S[3,          /# r9   rS   )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 boundaryFrX   r    Tr  rW   )r   r   popleftr   r*  r   r)  r   r  r   r  )r/   r  s   & r!   rX   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[/# rc   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   rh   r   r~   IncompleteReadErrorr   r   )r/   rd   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[/# rc   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*  rk   s   &&r!   read_nowaitStreamReader.read_nowait	  sV    
 ??&//!<<< 1 1 3 3K    ##r    c                &   < V ^8  d   QhRS[ RS[/# rc   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   r4  r   r   r   r   r   r   r   r   )r/   rd   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[/# rc   r%  )r(   r)   s   "r!   r*   r   ;  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/   rd   chunksr  s   &&  r!   r*  StreamReader._read_nowait;  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   rC   r0   r   r   r   r   r   r   r   r   r   r   propertyr   r   r   r   r  r  r`   r  rh   rp   rX   r:  r?  r  r*  r   rD   rE   s   @r!   r   r   f   sC    I. :
 -1 : 59 :  :D' '3 3  $12 2$1 1$ $0 . .	$ 	$ + +
 (+ +&: :%% %%N   *> > >%EI% %N($ ($T
% 
% *  *D   $ $! !F3 3r    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]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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# )(EmptyStreamReaderiK  c                   < V ^8  d   QhRR/# r   r   )r(   r)   s   "r!   r*   EmptyStreamReader.__annotate__O  s      $ r    c                "    R V n         ^ V n        R# FN_read_eof_chunkr   r4   s   &r!   r0   EmptyStreamReader.__init__O  s    $r    c                    < V ^8  d   QhRS[ /# r9   r   )r(   r)   s   "r!   r*   rR  S  s     0 0# 0r    c                <    R V P                   P                  ,          # )r   )r   r   r4   s   &r!   r   EmptyStreamReader.__repr__S  s    ////r    c                0   < V ^8  d   QhRS[ S[,          /# r9   r   )r(   r)   s   "r!   r*   rR  V  s      8M2 r    c                    R # r-   r   r4   s   &r!   r   EmptyStreamReader.exceptionV      r    c                *   < V ^8  d   QhRS[ RS[ RR/# r   r   )r(   r)   s   "r!   r*   rR  Y  s)       ! 
	r    c                    R # r-   r   )r/   r   r   s   &&&r!   r   EmptyStreamReader.set_exceptionY  s    
 	r    c                6   < V ^8  d   QhRS[ . R3,          RR/# r   r   )r(   r)   s   "r!   r*   rR  `  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*   rR  f  s      $ r    c                    R # r-   r   r4   s   &r!   r   EmptyStreamReader.feed_eoff      r    c                    < V ^8  d   QhRS[ /# r9   r   )r(   r)   s   "r!   r*   rR  i         r    c                    R # Tr   r4   s   &r!   r   EmptyStreamReader.is_eofi  r^  r    c                    < V ^8  d   QhRS[ /# r9   r   )r(   r)   s   "r!   r*   rR  l  rj  r    c                    R # rl  r   r4   s   &r!   r   EmptyStreamReader.at_eofl  r^  r    c                   < V ^8  d   QhRR/# r   r   )r(   r)   s   "r!   r*   rR  o  s       r    c                   "   R # 5ir-   r   r4   s   &r!   r   EmptyStreamReader.wait_eofo  s        c                *   < V ^8  d   QhRS[ RS[RR/# )r%   r   rd   r'   Nr   )r(   r)   s   "r!   r*   rR  r  s"      e  D r    c                    R # r-   r   )r/   r   rd   s   &&&r!   r   EmptyStreamReader.feed_datar  rh  r    r  Nc                6   < V ^8  d   QhRS[ S[,          RS[/# r  r  )r(   r)   s   "r!   r*   rR  u  s      # % r    c                  "   R # 5ir    r   r  s   &$r!   r`   EmptyStreamReader.readlineu       rt  c                &   < V ^8  d   QhRS[ RS[/# rc   r%  )r(   r)   s   "r!   r*   rR  x  s      C  r    c                   "   R # 5irz  r   rk   s   &&r!   rh   EmptyStreamReader.readx  r|  rt  c                    < V ^8  d   QhRS[ /# r9   r   )r(   r)   s   "r!   r*   rR  }  s      u r    c                   "   R # 5irz  r   r4   s   &r!   rp   EmptyStreamReader.readany}  r|  rt  c                6   < V ^8  d   QhRS[ S[S[3,          /# r9   rS   )r(   r)   s   "r!   r*   rR    s      ud{!3 r    c                D   "   V P                   '       g
   R V n         R# R# 5i)TrW   r3  rV  r4   s   &r!   rX   EmptyStreamReader.readchunk  s%     ####'D s    c                &   < V ^8  d   QhRS[ RS[/# rc   r%  )r(   r)   s   "r!   r*   rR    s     2 23 25 2r    c                8   "   \         P                  ! R V4      h5irz  )r~   r8  rk   s   &&r!   r:  EmptyStreamReader.readexactly  s     ))#q11s   c                &   < V ^8  d   QhRS[ RS[/# rc   r%  )r(   r)   s   "r!   r*   rR    s      S % r    c                    R # rz  r   rk   s   &&r!   r?  EmptyStreamReader.read_nowait  s    r    rU  r  rK  rM  )r   r   r   r   rC   r0   r   r   r   r   r   r   r   r   r   r   r`   rh   rp   rX   r:  r?  r   rD   rE   s   @r!   rP  rP  K  s     $I 0 0  $1 C C        
  2 2  r    rP  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%     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# rT  )r   r   r   r   r   r   r   )r/   rz   s   &&r!   r0   DataQueue.__init__  s,    
	7;37.9.?.?.Ar    c                    < V ^8  d   QhRS[ /# r9   r   )r(   r)   s   "r!   r*   r    s     ! ! !r    c                ,    \        V P                  4      # r-   )r   r   r4   s   &r!   __len__DataQueue.__len__  s    4<<  r    c                    < V ^8  d   QhRS[ /# r9   r   )r(   r)   s   "r!   r*   r    s       r    c                    V P                   # r-   r   r4   s   &r!   r   DataQueue.is_eof  s    yyr    c                    < V ^8  d   QhRS[ /# r9   r   )r(   r)   s   "r!   r*   r    s     . . .r    c                L    V P                   ;'       d    V P                  '       * # r-   r   r4   s   &r!   r   DataQueue.at_eof  s    yy----r    c                0   < V ^8  d   QhRS[ S[,          /# r9   r   )r(   r)   s   "r!   r*   r    r   r    c                    V P                   # r-   r   r4   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   re   )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[ /# r9   r:   )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TimeoutErrorr4  r   r   )r/   r   _s   &  r!   rh   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[,          /# r9   )r#   r   )r(   r)   s   "r!   r*   r    s     . ..r2 .r    c                ,    \        V P                  4      # r-   )r#   rh   r4   s   &r!   r5   DataQueue.__aiter__  s    "499--r    )r   r   r   r   r   NrK  )r   r   r   r   r   r0   r  r   r   r   r   r   r   r   rh   r5   r   rD   rE   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}   rz   r'   N)r   re   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)superr0   r   r   _limit)r/   r|   r}   rz   r   s   &&&$r!   r0   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[ /# r9   r:   )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  r4  r   r  r   r   r   r   r   )r/   r   r   s   &  r!   rh   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   rK  )r   r   r   r   r   r0   r   rh   r   rD   __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    Z 9 8u\" 8[ 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   http_exceptionsr   logr   __all__r   r   r   r#   rG   r[   r   rP  r  r   r  r*   )r  s   @r!   <module>r     s      
 
 
 (  )   T]!	 !'"+ ( "3 30b3) b3J@ @F &7%8 8>. >.B(9R= (r    