/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__
Edit: /usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/streams.cpython-36.pyc (18605B)
3
8%EgQ @ s U d dl Z d dlZd dlZd dlmZmZmZmZmZm Z m
Z
m Z ddl m
Z
ddlmZmZmZ ddlmZ ddlmZ dZe d
ZG dd d eZG dd dee ZG dd dZG dd dZ G dd
d
e Z G dd de Z e Z ee G dd d ee Z G dd d e e Z!dS ) N) AwaitableCallableDequeGenericListOptionalTupleTypeVar ) BaseProtocol)BaseTimerContext
set_exception
set_result)internal_logger)Final
EMPTY_PAYLOAD EofStream StreamReader DataQueueFlowControlDataQueue_Tc @ s e Zd ZdZdS )r zeof stream indication.N)__name__
__module__ __qualname____doc__ r r ;/usr/local/lib64/python3.6/site-packages/aiohttp/streams.pyr s c @ sD e Zd Zeg ee f ddddZddddZedd d
ZdS ) AsyncStreamIteratorN) read_funcreturnc C s
|| _ d S )N)r )selfr r r r __init__ s z AsyncStreamIterator.__init__zAsyncStreamIterator[_T])r c C s | S )Nr )r r r r __aiter__ s z AsyncStreamIterator.__aiter__c s< y| j I d H }W n tk
r* tY nX |dkr8t|S )N )r r StopAsyncIteration)r rvr r r __anext__! s
z AsyncStreamIterator.__anext__) r r r r r r r! r" r& r r r r r s r c @ s@ e Zd ZdddddZd dddZeeef dd d
ZdS ) ChunkTupleAsyncStreamIteratorr N)streamr c C s
|| _ d S )N)_stream)r r( r r r r! , s z&ChunkTupleAsyncStreamIterator.__init__)r c C s | S )Nr )r r r r r" / s z'ChunkTupleAsyncStreamIterator.__aiter__c s | j j I d H }|dkr t|S )Nr# F)r# F)r) readchunkr$ )r r% r r r r& 2 s z'ChunkTupleAsyncStreamIterator.__anext__) r r r r! r" r bytesboolr& r r r r r' + s r' c @ sR e Zd Zee dddZeee dddZee dddZe dd d
Z
d S ) AsyncStreamReaderMixin)r c C s
t | jS )N)r readline)r r r r r" : s z AsyncStreamReaderMixin.__aiter__)nr c s t fddS )zzReturns an asynchronous iterator that yields chunks of size n.
Python-3.5 available for Python 3.5+ only
c s
j S )N)readr )r/ r r r
C s z5AsyncStreamReaderMixin.iter_chunked..)r )r r/ r )r/ r r iter_chunked= s z#AsyncStreamReaderMixin.iter_chunkedc C s
t | jS )zoYield all available data as soon as it is received.
Python-3.5 available for Python 3.5+ only
)r readany)r r r r iter_anyF s z AsyncStreamReaderMixin.iter_anyc C s t | S )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.
Python-3.5 available for Python 3.5+ only
)r' )r r r r iter_chunksM s z"AsyncStreamReaderMixin.iter_chunksN) r r r r r+ r" intr2 r4 r' r5 r r r r r- 9 s r- c @ s e Zd ZdZdZdddeeee ee j
ddddZ e dd d
Z
eeef dd d Zee dd
dZeddddZeg df ddddZddddZedddZedddZdddd Zedd d d Zd@eedd d!d"Z ddd#d$Z ddd%d&Z e dd'd(d)Z edd*d+Z dAeed-d.d/Z!dCeed1d2d3Z"edd4d5Z#eeef dd6d7Z$eed1d8d9Z%dEeed1d:d;Z&eed1dd?Z(dS )Fr 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():
...
r N)timerloop)protocollimitr7 r8 r c C sv || _ || _|d | _|d kr&tj }|| _d| _d| _d | _t j
| _ d| _ d| _
d | _d | _d | _|| _g | _d S )N r F) _protocol
_low_water _high_waterasyncioget_event_loop_loop_size_cursor_http_chunk_splits collectionsdeque_buffer_buffer_offset_eof_waiter _eof_waiter
_exception_timer_eof_callbacks)r r9 r: r7 r8 r r r r! h s"
zStreamReader.__init__)r c C s | j jg}| jr |jd| j | jr0|jd | jd
krP|jd| j| jf | jrf|jd| j | jr||jd| j dd j | S ) Nz%d byteseofr; zlow=%d high=%dzw=%rze=%rz<%s> i )
__class__r rB appendrI r= r> rJ rL join)r infor r r __repr__ s
zStreamReader.__repr__c C s | j | jfS )N)r= r> )r r r r get_read_buffer_limits s z#StreamReader.get_read_buffer_limitsc C s | j S )N)rL )r r r r exception s zStreamReader.exception)excr c C sP || _ | jj | j}|d k r.d | _t|| | j}|d k rLd | _t|| d S )N)rL rN clearrJ r
rK )r rY waiterr r r r
s
zStreamReader.set_exception)callbackr c C sB | j r2y
| W q> tk
r. tjd Y q>X n | jj| d S )NzException in eof callback)rI Exceptionr rX rN rS )r r\ r r r on_eof s
zStreamReader.on_eofc C s d| _ | j}|d k r$d | _t|d | j}|d k rBd | _t|d x8| jD ].}y
| W qJ tk
rv tjd Y qJX qJW | jj d S )NTzException in eof callback) rI rJ r rK rN r] r rX rZ )r r[ cbr r r feed_eof s
zStreamReader.feed_eofc C s | j S )z&Return True if 'feed_eof' was called.)rI )r r r r is_eof s zStreamReader.is_eofc C s | j o | j S )z=Return True if the buffer is empty and 'feed_eof' was called.)rI rG )r r r r at_eof s zStreamReader.at_eofc sB | j r
d S | jd kst| jj | _z| jI d H W d d | _X d S )N)rI rK AssertionErrorrA
create_future)r r r r wait_eof s zStreamReader.wait_eof)datar c C sx t jdtdd |sdS | jr>| jd | jd | jd< d| _| jt|7 _| jt|8 _| jj| d| _ dS )zDrollback reading some data from stream, inserting it to buffer head.zJunread_data() is deprecated and will be removed in future releases (#3260)r; )
stacklevelNr )
warningswarnDeprecationWarningrH rG rB lenrC
appendleft _eof_counter)r rf r r r unread_data s zStreamReader.unread_data)rf sizer c C s | j std|sd S | jt|7 _| jj| | jt|7 _| j}|d k rfd | _t|d | j| j kr| j
j r| j
j d S )Nzfeed_data after feed_eof)
rI rc rB rk rG rS total_bytesrJ r r> r< _reading_paused
pause_reading)r rf ro r[ r r r feed_data s
zStreamReader.feed_datac C s" | j d kr | jrtdg | _ d S )Nz?Called begin_http_chunk_receiving whensome data was already fed)rD rp RuntimeError)r r r r begin_http_chunk_receiving s
z'StreamReader.begin_http_chunk_receivingc C sd | j d krtd| j r"| j d nd}| j|kr4d S | j j| j | j}|d k r`d | _t|d d S )NzFCalled end_chunk_receiving without calling begin_chunk_receiving firstr
r )rD rt rp rS rJ r )r posr[ r r r end_http_chunk_receiving s
z%StreamReader.end_http_chunk_receiving) func_namer c sf | j d k rtd| | jj }| _ z2| jrL| j |I d H W d Q R X n
|I d H W d d | _ X d S )NzH%s() called while another coroutine is already waiting for incoming data)rJ rt rA rd rM )r ry r[ r r r _wait! s
zStreamReader._waitc s | j I d H S )N) readuntil)r r r r r. 6 s zStreamReader.readline
) separatorr c s t |}|dkrtd| jd k r(| jd}d}d}x|rxn| jr|r| j}| jd j||d }| j|rr|| nd }||7 }|t |7 }|rd}|| jkr rI rz ) r r} seplenchunk
chunk_sizeZ
not_enoughoffsetZicharrf r r r r{ 9 s0
zStreamReader.readuntilr
)r/ r c s | j d k r| j | jrH| j rHt| ddd | _| jdkrHtjddd |sPdS |dk rg }x"| j I d H }|srP |j| q^W dj |S x$| j r| j r| j
d I d H qW | j |S )
Nrm r r
zEMultiple access to StreamReader in eof state, might be infinite loop.T)
stack_infor# r0 ) rL rI rG getattrrm r warningr3 rS rT rz _read_nowait)r r/ blocksblockr r r r0 [ s*
zStreamReader.readc s@ | j d k r| j x$| j r4| j r4| jdI d H qW | jdS )Nr3 r
rv )rL rG rI rz r )r r r r r3 s
zStreamReader.readanyc s x| j dk r| j xL| jr^| jjd}|| jkr4d S || jkrR| j|| j dfS tjd qW | jrt| jd
dfS | j r~d S | j
dI dH qW dS ) 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.
Nr r# TzESkipping HTTP chunk end due to data consumption beyond chunk boundaryr
Fr* )r# Trv )r# F) rL rD poprC r r r rG r rI rz )r rw r r r r* s
zStreamReader.readchunkc st | j d k r| j g }xT|dkrh| j|I d H }|sPdj|}tj|t|| |j| |t|8 }qW dj|S )Nr r# )rL r0 rT r? IncompleteReadErrorrk rS )r r/ r r partialr r r readexactly s
zStreamReader.readexactlyc C s4 | j d k r| j | jr*| jj r*td| j|S )Nz9Called while some coroutine is waiting for incoming data.)rL rJ donert r )r r/ r r r read_nowait s
zStreamReader.read_nowaitc C s | j d }| j}|dkrHt|| |krH|||| }| j|7 _n,|rj| j j ||d }d| _n
| j j }| jt|8 _| jt|7 _| j}x |r|d | jk r|jd qW | j| jk r| j j
r| j j |S )Nr r
rv ) rG rH rk popleftrB rC rD r r= r< rq resume_reading)r r/ Z first_bufferr rf Z chunk_splitsr r r r s$
z StreamReader._read_nowait_chunkc C sT g }x<| j r@| j|}|j| |dkr|t|8 }|dkrP qW |rPdj|S dS )z6Read not more than n bytes, or whole buffer if n == -1r
r r# rv )rG r rS rk rT )r r/ chunksr r r r r s
zStreamReader._read_nowait)r )r| rv )rv rv )rv ))r r r r rp r r6 r r r? AbstractEventLoopr! strrV r rW
BaseExceptionrX r
r r^ r` r, ra rb re r+ rn rs ru rx rz r. r{ r0 r3 r* r r r r r r r r r X s8 "* "c @ s e Zd ZddddZee dddZedddd Zeg df dd
d d Z ddd
dZ
e dddZ e dddZ
ddddZd'eeddddZedddZd)eed d d Zedd d Zeee f dd!d"Zeed d#d$Zd+eed d%d&ZdS ),EmptyStreamReaderN)r c C s d S )Nr )r r r r r! s zEmptyStreamReader.__init__c C s d S )Nr )r r r r rX s zEmptyStreamReader.exception)rY r c C s d S )Nr )r rY r r r r
s z EmptyStreamReader.set_exception)r\ r c C s. y
| W n t k
r( tjd Y nX d S )NzException in eof callback)r] r rX )r r\ r r r r^ s
zEmptyStreamReader.on_eofc C s d S )Nr )r r r r r` s zEmptyStreamReader.feed_eofc C s dS )NTr )r r r r ra s zEmptyStreamReader.is_eofc C s dS )NTr )r r r r rb s zEmptyStreamReader.at_eofc s d S )Nr )r r r r re s zEmptyStreamReader.wait_eofr )rf r/ r c C s d S )Nr )r rf r/ r r r rs s zEmptyStreamReader.feed_datac s dS )Nr# r )r r r r r. s zEmptyStreamReader.readliner
)r/ r c s dS )Nr# r )r r/ r r r r0 s zEmptyStreamReader.readc s dS )Nr# r )r r r r r3 " s zEmptyStreamReader.readanyc s dS )Nr# T)r# Tr )r r r r r* % s zEmptyStreamReader.readchunkc s t jd|d S )Nr# )r? r )r r/ r r r r ( s z EmptyStreamReader.readexactlyc C s dS )Nr# r )r r/ r r r r + s z EmptyStreamReader.read_nowait)r rv )rv rv )rv )r r r r! r r rX r
r r^ r` r, ra rb re r+ r6 rs r. r0 r3 r r* r r r r r r r s r c @ s e Zd ZdZejddddZedddZe dd d
Z
e dd d Z e e
dd
dZe
ddddZd eeddddZddddZedddZee dddZdS ) r z>DataQueue is a general-purpose blocking queue with one reader.N)r8 r c C s, || _ d| _d | _d | _d| _tj | _d S )NFr )rA rI rJ rL rB rE rF rG )r r8 r r r r! 5 s zDataQueue.__init__)r c C s
t | jS )N)rk rG )r r r r __len__= s zDataQueue.__len__c C s | j S )N)rI )r r r r ra @ s zDataQueue.is_eofc C s | j o | j S )N)rI rG )r r r r rb C s zDataQueue.at_eofc C s | j S )N)rL )r r r r rX F s zDataQueue.exception)rY r c C s. d| _ || _| j}|d k r*d | _t|| d S )NT)rI rL rJ r
)r rY r[ r r r r
I s zDataQueue.set_exceptionr )rf ro r c C s@ | j |7 _ | jj||f | j}|d k r s4 ( &4I