Ë
|
¸^ih_ ã ón U d dl Z d dlZd dlZd dlmZmZmZmZmZm Z m
|
Z
|
m Z m Z ddl mZ ddlmZmZmZmZmZ ddlmZ dZ e d« Z G d d
|
e« Z G d d ee « Z G d d« Z G d d« Z G d de « Z G d de « Z e « Z ee e!d< G d dee « Z" G d de"e « Z#y)é N) Ú AwaitableÚCallableÚDequeÚFinalÚGenericÚListÚOptionalÚTupleÚTypeVaré )Ú BaseProtocol)Ú _EXC_SENTINELÚBaseTimerContextÚ TimerNoopÚ set_exceptionÚ
|
set_result)Úinternal_logger)Ú EMPTY_PAYLOADÚ EofStreamÚ StreamReaderÚ DataQueueÚ_Tc ó e Zd ZdZy)r zeof stream indication.N)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__© ó õb H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/streams.pyr r $ s Ú r r c óD e Zd ZdZdeg ee f ddfdZddZdefdZ y) ÚAsyncStreamIterator©Ú read_funcr$ ÚreturnNc ó || _ y ©Nr# )Úselfr$ s r Ú__init__z AsyncStreamIterator.__init__, s Ø"r c ó | S r' r ©r( s r Ú __aiter__z AsyncStreamIterator.__aiter__/ ó Ø r c ó K | j « d { }|dk( rt |S 7 # t $ r t w xY ww©Nr )r$ r ÚStopAsyncIteration©r( Úrvs r Ú __anext__z AsyncStreamIterator.__anext__2 sG è ø ð %Ø~~Ó'×'Bð 9Ü$Ð $Ø ð (ùÜò %Ü$Ð $ð %üs >+ )+ >©+ «;»>)r% zAsyncStreamIterator[_T])
|
r r r Ú __slots__r r r r) r, r3 r r r r" r" ( s9 à Ið# (¨2¨y¸©}Ð+<Ñ"=ð #À$ó #óð ô r r" c ó6 e Zd ZdZddZddZdeeef fdZ y) Ú ChunkTupleAsyncStreamIterator©Ú_streamr% Nc ó || _ y r' r7 )r( Ústreams r r) z&ChunkTupleAsyncStreamIterator.__init__@ s Ø r c ó | S r' r r+ s r r, z'ChunkTupleAsyncStreamIterator.__aiter__C r- r c ól K | j j « d { }|dk( rt |S 7 w)N©r F)r8 Ú readchunkr0 r1 s r r3 z'ChunkTupleAsyncStreamIterator.__anext__F s3 è ø Ø<<×)Ñ)Ó+× +Ø Ò Ü$Ð $Ø ð ,ús 4 2¡4)r: r r% N)r% r6 )
|
r r r r4 r) r, r
|
ÚbytesÚboolr3 r r r r6 r6 < s& à Ió óð u¨d {Ñ!3ô r r6 c óV e Zd ZdZdee fdZdedee fdZdee fdZ de
|
fdZ y) ÚAsyncStreamReaderMixinr r% c ó, t | j « S r' )r" Úreadliner+ s r r, z AsyncStreamReaderMixin.__aiter__Q s Ü" 4§=¡=Ó1Ð1r Únc ó$ t fd« S )z>Returns an asynchronous iterator that yields chunks of size n.c ó& j « S r' )Úread)rE r( s r ú<lambda>z5AsyncStreamReaderMixin.iter_chunked.<locals>.<lambda>V s ø ¨4¯9©9°Q«< r )r" ©r( rE s ``r Ú iter_chunkedz#AsyncStreamReaderMixin.iter_chunkedT s ù ä"Ô#7Ó8Ð8r c ó, t | j « S )z3Yield all available data as soon as it is received.)r" Úreadanyr+ s r Úiter_anyz AsyncStreamReaderMixin.iter_anyX s ä" 4§<¡<Ó0Ð0r c ó t | « S )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.
|
)r6 r+ s r Ú iter_chunksz"AsyncStreamReaderMixin.iter_chunks\ s ô -¨TÓ2Ð2r N) r r r r4 r" r? r, ÚintrK rN r6 rP r r r rB rB M sQ àIð2Ð.¨uÑ5ó 2ð9cð 9Ð&9¸%Ñ&@ó 9ð1Ð-¨eÑ4ó 1ð3Ð :ô 3r rB c óÖ e Zd ZdZdZddddededee dee j d df
|
d
|
Z d e fd Z d eeef fd Zd ee fd Zefdeded dfdZdeg df d dfdZd+dZd efdZd efdZd+dZed efd« Z de d dfdZ d,de ded dfdZ d+d Z d+d Z!d e d dfd Z"d e fd Z#d-d!e d e fd"Z$d.d#ed e fd$Z%d e fd%Z&d ee ef fd&Z'd#ed e fd'Z(d.d#ed e fd(Z)d#ed e fd)Z*d#ed e fd*Z+y)/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():
|
...
|
|
)Ú _protocolÚ
|
_low_waterÚ _high_waterÚ_low_water_chunksÚ_high_water_chunksÚ_loopÚ_sizeÚ_cursorÚ_http_chunk_splitsÚ_bufferÚ_buffer_offsetÚ_eofÚ_waiterÚ _eof_waiterÚ
|
_exceptionÚ_timerÚ_eof_callbacksÚ _eof_counterÚ total_bytesÚtotal_compressed_bytesN)ÚtimerÚloopÚprotocolÚlimitrg rh r% c óÒ || _ || _ |dz | _ |t j « }t d|dz « | _ t d| j dz « | _ || _ d| _ d| _
|
d | _ t j « | _ d| _ d| _ d | _ d | _ d | _ |
|
t) « n|| _ g | _ d| _ d| _ d | _ y )Né é é r F)rS rT rU ÚasyncioÚget_event_loopÚmaxrW rV rX rY rZ r[ Ú collectionsÚdequer\ r] r^ r_ r` ra r rb rc rd re rf )r( ri rj rg rh s r r) zStreamReader.__init__ sá ð "Ø Ø 19ÔØ <Ü×)Ñ)Ó+Dä"% a¨°!©Ó"4Ô ô "% Q¨×(?Ñ(?À1Ñ(DÓ!EÔ Ø
|
Ø
|
Ø Ø8<Ô Ü%0×%6Ñ%6Ó%8 Ø ÔØ Ø7; Ø;?ÔØ37Ø%* ]ik¸ Ø8:ÔØ ÔØ ÔØ59Õ#r c ó | j j g}| j r |j d| j z « | j r|j d« | j
|
dk7 r*|j d| j
|
| j fz « | j r |j d| j z « | j r |j d| j z « ddj |« z S ) Nz%d bytesÚeofi zlow=%d high=%dzw=%rze=%rú<%s>ú )
|
Ú __class__r rY Úappendr^ rT rU r_ ra Újoin)r( Úinfos r Ú__repr__zStreamReader.__repr__¬ s» Ø×'Ñ'Ð(Ø ::Ø KK
|
T§Z¡ZÑ/Ô 0Ø 99Ø KKÔ Ø ??eÒ #Ø KKÐ(¨D¯O©O¸T×=MÑ=MÐ+NÑNÔ OØ <<Ø KK § ¡ Ñ-Ô .Ø ??Ø KK § ¡ Ñ0Ô 1Ø Ñ&Ð&r c ó2 | j | j fS r' )rT rU r+ s r Úget_read_buffer_limitsz#StreamReader.get_read_buffer_limitsº s Ø ×!1Ñ!1Ð2Ð2r c ó | j S r' ©ra r+ s r Ú exceptionzStreamReader.exception½ ó ØÐ r ÚexcÚ exc_causec óÐ || _ | j j « | j }|d | _ t |||« | j
|
}|d | _ t |||« y y r' )ra rc Úclearr_ r r` ©r( r r Úwaiters r r zStreamReader.set_exceptionÀ si ð
|
Ø ×Ñ×!Ñ!Ô#à Ø Ð Ø DLÜ & # yÔ 1à×!Ñ!Ø Ð Ø #DÔ Ü & # yÕ 1ð r Úcallbackc ó¬ | j r |« y | j j |« y # t $ r t j d« Y y w xY w©NúException in eof callback)r^ Ú Exceptionr r rc ry ©r( r s r Úon_eofzStreamReader.on_eofÒ sL Ø 99ð GÙ
|
ð × Ñ × &Ñ & xÕ 0øô ò GÜ ×)Ñ)Ð*EÖFð Gús 2 ² AÁAc ó¤ d| _ | j }|d | _ t |d « | j }|d | _ t |d « | j j
|
r| j j « | j D ]
|
} |« | j j « y # t $ r t j d« Y Hw xY w)NTr ) r^ r_ r r` rS Ú_reading_pausedÚresume_readingrc r r r r )r( r Úcbs r Úfeed_eofzStreamReader.feed_eofÛ sÁ Ø à Ø Ð Ø DLÜ vtÔ $à×!Ñ!Ø Ð Ø #DÔ Ü vtÔ $à >>× )Ò )Ø NN× )Ñ )Ô +à×%Ñ%ò GBð GÙð Gð ×Ñ×!Ñ!Õ#øô ò GÜ ×)Ñ)Ð*EÖFð Gús Â
|
B.Â. CÃCc ó | j S )z&Return True if 'feed_eof' was called.©r^ r+ s r Úis_eofzStreamReader.is_eofó s àyyÐr c ó8 | j xr | j S )z=Return True if the buffer is empty and 'feed_eof' was called.©r^ r\ r+ s r Úat_eofzStreamReader.at_eof÷ s àyyÒ- § ¡ Ð -Ð-r c óÔ K | j ry | j J | j j « | _ | j d { d | _ y 7 # d | _ w xY wwr' )r^ r` rX Ú create_futurer+ s r Úwait_eofzStreamReader.wait_eofû sa è ø Ø 99Ø à× Ñ Ð'Ð'Ð'Ø ::×3Ñ3Ó5Ôð $Ø×"Ñ"× "Ð "à #DÕ ð #ùà #DÕ üs. ;A(¾A Á AÁA ÁA(ÁA Á A%Á%A(c óJ | j | j S | j S r' )rf re r+ s r Útotal_raw_bytesz StreamReader.total_raw_bytes s& à × &Ñ &Ð .Ø×#Ñ#Ð #Ø×*Ñ*Ð*r Údatac óv t j dt d¬« |sy| j r0| j d | j d | j d< d| _ | xj
|
t |« z c_ | xj t |« z c_ | j j |« d| _ y)zDrollback reading some data from stream, inserting it to buffer head.zJunread_data() is deprecated and will be removed in future releases (#3260)rl )Ú
|
stacklevelNr )
|
ÚwarningsÚwarnÚDeprecationWarningr] r\ rY ÚlenrZ Ú
|
appendleftrd )r( r s r Ú unread_datazStreamReader.unread_data s ä ð =ä Øõ
|
ñ Ø à × Ò Ø "ll¨1o¨d×.AÑ.AÐ.CÐ DDLLOØ"#DÔ Ø
|
|
c$iÑ
|
Ø D Ñ! Ø × Ñ Ô%Ø Õr Úsizec ó¨ | j rJ d« |sy t |« }| xj |z c_ | j j |« | xj
|
|z c_ | j }|d | _ t |d « | j | j kD r2| j j s| j j « y y y )Nzfeed_data after feed_eof) r^ r¦ rY r\ ry re r_ r rU rS r Ú pause_reading)r( r r© Údata_lenr s r Ú feed_datazStreamReader.feed_data s« Ø99Ð8Ð 8Ó8}áØ ät9Ø
|
|
hÑ
|
Ø ×ÑDÔ!Ø ×ÒHÑ$Õà Ø Ð Ø DLÜ vtÔ $à ::×(Ñ(Ò (°· ± ×1OÒ1OØ NN× (Ñ (Õ *ð 2PÐ (r c ó~ | j 1| j r t d« t j « | _ y y )Nz@Called begin_http_chunk_receiving when some data was already fed)r[ re Ú RuntimeErrorrr rs r+ s r Úbegin_http_chunk_receivingz'StreamReader.begin_http_chunk_receiving3 s? Ø × "Ñ "Ð *Ø× Ò Ü"ØVóð ô '2×&7Ñ&7Ó&9DÕ #ð +r c ó¾ | j t d« | j r| j d nd}| j |k( ry | j j | j « t | j « | j
|
kD r0| j j s| j j « | j }|d | _ t |d « y y )NzFCalled end_chunk_receiving without calling begin_chunk_receiving firstéÿÿÿÿr ) r[ r¯ re ry r¦ rW rS r r« r_ r )r( Úposr s r Úend_http_chunk_receivingz%StreamReader.end_http_chunk_receiving; sÈ Ø × "Ñ "Ð *Ü ð.óð ð .2×-DÒ-Dd×%Ñ% bÒ)È!à × Ñ sÒ "ð à × Ñ ×&Ñ& t×'7Ñ'7Ô8ô ×'Ñ'Ó (¨4×+BÑ+BÒ BØNN×2Ò2à NN× (Ñ (Ô *ð Ø Ð Ø DLÜ vtÕ $ð r Ú func_namec óF K | j j s t d« | j t d|z « | j j « x}| _ | j 5 | d { d d d « d | _ y 7 # 1 sw Y xY w# d | _ w xY ww)NzConnection closed.zH%s() called while another coroutine is already waiting for incoming data)rS Ú connectedr¯ r_ rX r rb )r( rµ r s r Ú_waitzStreamReader._waitb s¡ è ø Ø~~×'Ò'Ü Ð 3Ó4Ð 4ð <<Ð #Ü ð4Ø6?ñ@óð ð
|
!%§
|
¡
|
× 8Ñ 8Ó :Ð: ð Øñ Ø ÷ ð DLð ø÷ ð ûð DLüsH A B!Á B Á,B Á2BÁ3B Á7B Á?B!ÂB Â BÂB Â B Â B!c ó> K | j « d { S 7 wr' )Ú readuntilr+ s r rD zStreamReader.readlinew s è ø Ø^^Ó%×%Ð%Ð%ús Ú separatorc ó K t |« }|dk( r t d« | j | j d}d}d}|rÇ| j r|r| j }| j d j ||« dz }| j |r ||z
|
|z dz
|
nd« }||z }|t |« z }|rd}|| j kD r t d« | j r|r| j r |S |r| j d « d { |rÇ|S 7 w)
|
Nr z,Separator should be at least one-byte stringr Tr r² Fz Chunk too bigrº )
|
r¦ Ú
|
ValueErrorra r\ r] ÚfindÚ_read_nowait_chunkrU r^ r¸ ) r( r» ÚseplenÚchunkÚ
|
chunk_sizeÚ
|
not_enoughÚoffsetÚicharr s r rº zStreamReader.readuntilz s è ø ÜY Ø Q;Ü Ð KÓLÐ Là ??Ð &Ø//Ð !àØ
|
Ø
|
áØ,,¡:Ø ×,Ñ,Ø Q×,Ñ,¨Y¸Ó?À!ÑCà×.Ñ.Ù38EFN VÑ+¨aÒ/¸bóð Øc $iÑ'
|
ÙØ!&Jà × 0Ñ 0Ò0Ü$ _Ó5Ð5ð ,,¢:ð yyØð
|
ñ Øjj Ó-×-Ð-ò) ð, ð .ús CD Ã%D Ã=DÃ>D ÄD rE c ó2 K | j | j | j rG| j s;t | dd« dz | _ | j dkD rt j dd¬« |sy|dk rAg } | j « d { }|sn|j |« -dj |« S | j s>| j s2| j d « d { | j s | j s2| j |« S 7
7 0w)
|
NTrd r r é zEMultiple access to StreamReader in eof state, might be infinite loop.)Ú
|
stack_infor rH ) ra r^ r\ Úgetattrrd r ÚwarningrM ry rz r¸ Ú _read_nowait)r( rE ÚblocksÚblocks r rH zStreamReader.read s è ø Ø ??Ð &Ø//Ð !ð Øyy § ¢ Ü$+¨D°.À!Ó$DÀqÑ$HÔ!Ø×$Ñ$ qÒ(Ü#×+Ñ+ð2à#'õñ Øà q5ð
|
FØØ "lln×,Ù ØØ eÔ$ð ð
|
88FÓ#Ð #ð
|
,, t§y¢yØ**VÓ$× $Ð $ð ,, t§y£yð × Ñ Ó#Ð#ð -øð %ús+ B DÂ DÂADÃ$DÃ% DÄDÄDc óô K | j | j | j s>| j s2| j d« d { | j s | j s2| j d« S 7 .w)NrM r² )ra r\ r^ r¸ rË r+ s r rM zStreamReader.readanyÈ sb è ø Ø ??Ð &Ø//Ð !ð
|
,, t§y¢yØ**YÓ'× 'Ð 'ð ,, t§y£yð × Ñ Ó$Ð$ð (ús AA8ÁA6Á A8Á%A8c óÚ K | j | j | j r{| j j « }|| j k( ry|| j kD r | j || j z
|
« dfS t j d« | j r{| j r| j d« dfS | j ry| j d« d{ å7 w) a 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.
|
TN©r TzESkipping HTTP chunk end due to data consumption beyond chunk boundaryr² Fr= r> ) ra r[ ÚpopleftrZ rË r rÊ r\ r¿ r^ r¸ )r( r³ s r r> zStreamReader.readchunkÔ sÝ è ø ð ØÐ*ØooÐ%à×)Ò)Ø×-Ñ-×5Ñ5Ó7Ø$,,Ò&Ø&Ø Ò%Ø × -Ñ -¨c°D·L±LÑ.@Ó AÀ4ÐHÐHÜ ×'Ñ'ð8ôð ×)Ó)ð ||Ø ×/Ñ/°Ó3°UÐ;Ð;ð yyð $à**[Ó)× )Ð )ð1 ð0 *ús B C+Â#A C+Ã#C)Ã$C+c óT K | j | j g }|dkD rs| j |« d { }|s3dj |« }t j |t |« |z « |j |« |t |« z }|dkD rsdj |« S 7 ow)Nr r )ra rH rz ro ÚIncompleteReadErrorr¦ ry )r( rE rÌ rÍ Úpartials r Ú readexactlyzStreamReader.readexactlyö s è ø Ø ??Ð &Ø//Ð !à Ø!eØ )) A,×&EÙØ (( 6Ó*Ü ×1Ñ1°'¼3¸w»<È!Ñ;KÓLÐLØ MM%Ô Ø UOAð !eð xxÓ Ð ð 'ús 4B(¶B&·A B(ÂB(c ó¶ | j | j | j r%| j j « s t d« | j |« S )Nz9Called while some coroutine is waiting for incoming data.)ra r_ Údoner¯ rË rJ s r Ú read_nowaitzStreamReader.read_nowait sQ ð
|
??Ð &Ø//Ð !à << § ¡ × 1Ñ 1Ô 3Ü ØKóð ð × Ñ Ó#Ð#r c ó | j d }| j }|dk7 r/t |« |z
|
|kD r ||||z }| xj |z c_ nC|r'| j j « ||d }d| _ n| j j « }t |« }| xj |z c_ | xj
|
|z c_ | j }|r7|d | j
|
k r%|j « |r|d | j
|
k r%| j j ra| j | j k rH| j "t | j « | j k r| j j « |S )Nr r² ) r\ r] r¦ rÑ rY rZ r[ rS r rT rV r )r( rE Ú first_bufferrÄ r r¬ Ú chunk_splitss r r¿ z StreamReader._read_nowait_chunk sK Ø|| A Ø×$Ñ$Ø 7s<Ó(¨6Ñ1°AÒ5Ø ¨°!©Ð4DØ × Ò 1Ñ $Ö á Ø LL× Ñ Ô "Ø Ð(DØ"#DÕ ð <<×'Ñ'Ó)Dät9Ø
|
|
hÑ
|
Ø Ñ à×.Ñ. á|¨A°· ± Ò =Ø × Ñ Ô "ñ |¨A°· ± Ó =ð NN× *Ò *Ø
|
|
T__Ò,à×'Ñ'Ð/Üt×.Ñ.Ó/°$×2HÑ2HÒHð NN× )Ñ )Ô +Ø r c ó | j j « g }| j rH| j |« }|j |« |dk7 r|t |« z }|dk( rn | j rH|rdj |« S dS )z6Read not more than n bytes, or whole buffer if n == -1r² r r )rb Úassert_timeoutr\ r¿ ry r¦ rz )r( rE ÚchunksrÁ s r rË zStreamReader._read_nowait7 sy à ×"Ñ"Ô$àØllØ×+Ñ+¨AÓ.EØ MM%Ô ØBwØSZØ6Øð llñ $*sxxÓ Ð2¨sÐ2r ©r% N©r )ó
|
©r² ),r r r r r4 r rQ r r ro ÚAbstractEventLoopr) Ústrr| r
|
r~ Ú BaseExceptionr r r r r r r@ r r r Úpropertyr r? r¨ r r° r´ r¸ rD rº rH rM r> rÕ rØ r¿ rË r r r r r e sû ñ ðIð8 -1Ø48ò :à ð :ð ð :ð
|
Ð(Ñ)ð :ð w×0Ñ0Ñ1ð :ð
|
ó :ðD '#ó 'ð 3¨¨c°3¨h©ó 3ð 8 MÑ2ó ð $1ñ2à ð2ð !ð2ð
|
ó 2ð$1x¨¨D¨Ñ 1ð 1°dó 1ó$ð0ó ð.ó .ó $ð ð+ ò +ó ð+ð
|
ð ¨$ó ñ(+eð +¨3ð +°tó +ó&:ó%%ðN Sð ¨Tó ð*& ó &ñ"¨ð "¸5ó "ñH($Cð ($¨ó ($ðT
|
%uó
|
%ð * u¨d {Ñ!3ó *ðD 3ð ¨5ó ñ $Sð $¨%ó $ð ! Cð !¨Eó !ðF 3cð 3 eô 3r r c ó e Zd ZdZddZdefdZdee fdZ e
|
fdededdfd Z d
|
e g df ddfd Z dd Zdefd ZdefdZddZddededdfdZdefdZddedefdZdefdZdeeef fdZdedefdZddedefdZ y) ÚEmptyStreamReader©Ú_read_eof_chunkr% Nc ó d| _ d| _ y )NFr )rê re r+ s r r) zEmptyStreamReader.__init__K s Ø $Ô Ø Õr c ó4 d| j j z S )Nrv )rx r r+ s r r| zEmptyStreamReader.__repr__O s Ø×/Ñ/Ñ/Ð/r c ó y r' r r+ s r r zEmptyStreamReader.exceptionR ó Ør r r c ó y r' r )r( r r s r r z EmptyStreamReader.set_exceptionU s ð
|
r r c ó\ |« y # t $ r t j d« Y y w xY wr )r r r r s r r zEmptyStreamReader.on_eof\ s- ð CÙ JøÜò CÜ × %Ñ %Ð&AÖ Bð Cús
|
+ª+c ó y r' r r+ s r r zEmptyStreamReader.feed_eofb ó Ø r c ó y©NTr r+ s r r zEmptyStreamReader.is_eofe rî r c ó yrô r r+ s r r zEmptyStreamReader.at_eofh rî r c ó K y wr' r r+ s r r zEmptyStreamReader.wait_eofk s è ø Øùó r rE c ó y r' r )r( r rE s r r zEmptyStreamReader.feed_datan rò r c ó K ywr/ r r+ s r rD zEmptyStreamReader.readlineq ó è ø Øùr÷ c ó K ywr/ r rJ s r rH zEmptyStreamReader.readt rú r÷ c ó K ywr/ r r+ s r rM zEmptyStreamReader.readanyy rú r÷ c ó4 K | j sd| _ yyw)NTr= rÐ ré r+ s r r> zEmptyStreamReader.readchunk| s è ø Ø×#Ò#Ø#'DÔ Ø àùs c ó6 K t j d|« wr/ )ro rÓ rJ s r rÕ z EmptyStreamReader.readexactly s è ø Ü×)Ñ)¨#¨qÓ1Ð1ùs c ó yr/ r rJ s r rØ z EmptyStreamReader.read_nowait s Ør rß rà râ ) r r r r4 r) rä r| r rå r r r r r r r@ r r r r? rQ r rD rH rM r
|
r> rÕ rØ r r r rè rè G s à$Ió ð0#ó 0ð8 MÑ2ó ð $1ñ à ð ð !ð ð
|
ó ðCx¨¨D¨Ñ 1ð C°dó Có ðó ðó óñ eð ¨ð °Dó ð ó ñCð ¨ó ð
|
uó ð u¨d {Ñ!3ó ð2 3ð 2¨5ó 2ñSð ¨%ô r rè r c ó¾ e Zd ZdZdej
|
ddfdZdefdZde fdZ
|
de fdZ de e fd Zefd
|
e d e ddfd Zdd ededdfdZddZdefdZdee fdZy)r z>DataQueue is a general-purpose blocking queue with one reader.rh r% Nc ón || _ d| _ d | _ d | _ t j
|
« | _ y )NF)rX r^ r_ ra rr rs r\ )r( rh s r r) zDataQueue.__init__ s. Ø
|
Ø Ø7; Ø37Ü.9×.?Ñ.?Ó.A r c ó, t | j « S r' )r¦ r\ r+ s r Ú__len__zDataQueue.__len__ s Ü4<<Ó Ð r c ó | j S r' r r+ s r r zDataQueue.is_eof s ØyyÐr c ó8 | j xr | j S r' r r+ s r r zDataQueue.at_eof s ØyyÒ- § ¡ Ð -Ð-r c ó | j S r' r r+ s r r zDataQueue.exception r r r r c óf d| _ || _ | j x}d | _ t |||« y y rô )r^ ra r_ r r s r r zDataQueue.set_exception£ s9 ð
|
Ø ØllÐ "FÐ /Ø DLÜ & # yÕ 1ð 0r r r© c ó | j j ||f« | j x}d | _ t |d « y y r' )r\ ry r_ r )r( r r© r s r r zDataQueue.feed_data® s= Ø ×ÑT 4LÔ)ØllÐ "FÐ /Ø DLÜ vtÕ $ð 0r c óV d| _ | j x}d | _ t |d « y y rô )r^ r_ r )r( r s r r zDataQueue.feed_eof´ s. Ø ØllÐ "FÐ /Ø DLÜ vtÕ $ð 0r c ó² K | j sN| j sB| j rJ | j j « | _ | j d { | j r | j j « \ }}|S | j | j t 7 M# t
|
j t
|
j f$ r d | _ w xY wwr' ) r\ r^ r_ rX r ro ÚCancelledErrorÚ TimeoutErrorrÑ ra r )r( r Ú_s r rH zDataQueue.readº s± è ø Ø|| D§I¢IØ||Ð #Ð#Ø ::×3Ñ3Ó5DLð Øll×"Ð"ð <<Øll×*Ñ*Ó,GD!ØKØ ??Ð &Ø//Ð !Üð #ùÜ×*Ñ*¬G×,@Ñ,@ÐAò Ø # Øð üs1 ACÁ B( ÁB&ÁB( Á A CÂ&B( Â(,CÃCc ó, t | j « S r' )r" rH r+ s r r, zDataQueue.__aiter__Ê s Ü" 4§9¡9Ó-Ð-r rà rß )r r r r ro rã r) rQ r r@ r r r rå r r r r r r rH r" r, r r r r r s¹ ÙHðBW× 6Ñ 6ð B¸4ó Bð!ó !ðó ð.ó .ð 8 MÑ2ó ð $1ñ 2à ð 2ð !ð 2ð
|
ó 2ñ%bð %¨ð %°Dó %ó %ð Bó ð .Ð.¨rÑ2ô .r r c ón e Zd ZdZdededej ddf fd Zd de d eddf fd
|
Z
|
de fd Z xZ S ) ÚFlowControlDataQueuez®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.
|
ri rj rh r% Nc óV t | |¬« d| _ || _ |dz | _ y )N)rh r rl )Úsuperr) rY rS Ú_limit)r( ri rj rh rx s r r) z FlowControlDataQueue.__init__Ö s. ø ô ÑdÐÔ#Ø
|
Ø!Øai r r r© c óæ t | ||« | xj |z c_ | j | j kD r2| j j
|
s| j j « y y y r' )r r rY r rS r r« )r( r r© rx s r r z FlowControlDataQueue.feed_dataÞ sU ø Ü Ñ$ Ô%Ø
|
|
dÑ
|
à :: Ò #¨D¯N©N×,JÒ,JØ NN× (Ñ (Õ *ð -KÐ #r c ón K | j sN| j sB| j rJ | j j « | _ | j d { | j r}| j j « \ }}| xj |z c_ | j | j k r0| j j r| j j « |S | j | j t 7 «# t
|
j t
|
j f$ r d | _ w xY wwr' )r\ r^ r_ rX r ro r r rÑ rY r rS r r ra r )r( r r© s r rH zFlowControlDataQueue.readå së è ø Ø|| D§I¢IØ||Ð #Ð#Ø ::×3Ñ3Ó5DLð Øll×"Ð"ð <<Ø ×-Ñ-Ó/JD$Ø JJ$Ñ JØzzDKKÒ'¨D¯N©N×,JÒ,JØ×-Ñ-Ô/ØKØ ??Ð &Ø//Ð !Üð #ùÜ×*Ñ*¬G×,@Ñ,@ÐAò Ø # Øð üs1 AD5Á D ÁDÁD Á B'D5ÄD Ä,D2Ä2D5rà ) r r r r r rQ ro rã r) r r rH Ú __classcell__)rx s @r r r Î sY ø ñð Ø$ð Ø-0ð Ø;B×;TÑ;Tð à õ ñ+bð +¨ð +°Dõ +ðB÷ r r )$ro rr r£ Útypingr r r r r r r r
|
r Ú base_protocolr Úhelpersr r r r r Úlogr Ú__all__r r r r" r6 rB r rè r Ú__annotations__r r r r r ú<module>r sÇ ðÜ Û Û ÷
|
÷
|
õ
|
õ (÷õ õ !ð ñ T]ô! ô !ô' "+ô ÷(ñ ÷"3ñ 3ô0_3Ð)ô _3ôD@ ô @ñF &7Ó%8 u\Ñ"Ó 8ô>. ô >.ôB(9 R=õ (r
|
