o `gV@s$UddlZddlZddlZddlmZmZmZmZmZm Z m Z m Z m Z ddl mZddlmZmZmZmZmZddlmZdZe dZGd d d eZGd d d eeZGd ddZGdddZGdddeZGdddeZeZ eee!d<GdddeeZ"Gddde"eZ#dS)N) AwaitableCallableDequeFinalGenericListOptionalTupleTypeVar) BaseProtocol) _EXC_SENTINELBaseTimerContext TimerNoop set_exception set_result)internal_logger) EMPTY_PAYLOAD EofStream StreamReader DataQueue_Tc@seZdZdZdS)rzeof stream indication.N)__name__ __module__ __qualname____doc__rrJ/var/www/html/propose/venv/lib/python3.10/site-packages/aiohttp/streams.pyr$src@sFeZdZdZdegeefddfddZd dd Zdefd d Z dS) AsyncStreamIterator read_funcr returnNcC ||_dSNr)selfr rrr__init__, zAsyncStreamIterator.__init__AsyncStreamIterator[_T]cC|Sr#rr$rrr __aiter__/zAsyncStreamIterator.__aiter__cs8z |IdH}Wn tytw|dkrt|SN)r rStopAsyncIterationr$rvrrr __anext__2s zAsyncStreamIterator.__anext__)r!r') rrr __slots__rrrr%r*r1rrrrr(s  rc@s:eZdZdZd ddZd dd Zdeeeffd d Z dS)ChunkTupleAsyncStreamIterator_streamstreamrr!NcCr"r#r4)r$r6rrrr%@r&z&ChunkTupleAsyncStreamIterator.__init__cCr(r#rr)rrrr*Cr+z'ChunkTupleAsyncStreamIterator.__aiter__cs"|jIdH}|dkrt|S)Nr-F)r5 readchunkr.r/rrrr1Fs z'ChunkTupleAsyncStreamIterator.__anext__)r6rr!N)r!r3) rrrr2r%r*r bytesboolr1rrrrr3<s   r3c@sXeZdZdZdeefddZdedeefddZdeefdd Z de fd d Z d S) AsyncStreamReaderMixinrr!cC t|jSr#)rreadliner)rrrr*Qr&z AsyncStreamReaderMixin.__aiter__ncstfddS)z>Returns an asynchronous iterator that yields chunks of size n.cs Sr#)readrr>r$rrVs z5AsyncStreamReaderMixin.iter_chunked..)rr$r>rr@r iter_chunkedTsz#AsyncStreamReaderMixin.iter_chunkedcCr<)z3Yield all available data as soon as it is received.)rreadanyr)rrriter_anyXs zAsyncStreamReaderMixin.iter_anycCst|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. )r3r)rrr iter_chunks\sz"AsyncStreamReaderMixin.iter_chunksN) rrrr2rr9r*intrCrEr3rFrrrrr;Ms r;c @seZdZdZdZddddededeedee j d df d d Z d e fd d Z d eeeffddZd eefddZefdeded dfddZdegdfd dfddZdEddZd efddZd efddZdEdd Zd!ed dfd"d#ZdFd!ed%ed dfd&d'ZdEd(d)ZdEd*d+Zd,e d dfd-d.Z d efd/d0Z!dGd2ed efd3d4Z"dHd6ed efd7d8Z#d efd9d:Z$d eeeffd;d<Z%d6ed efd=d>Z&dHd6ed efd?d@Z'd6ed efdAdBZ(d6ed efdCdDZ)dS)Ira*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_loop_size_cursor_http_chunk_splits_buffer_buffer_offset_eof_waiter _eof_waiter _exception_timer_eof_callbacks _eof_counter total_bytesN)timerloopprotocollimitrYrZr!cCs||_||_|d|_|durt}||_d|_d|_d|_t |_ d|_ d|_ d|_d|_d|_|dur:tn||_g|_d|_d|_dS)NrF)rHrIrJasyncioget_event_looprKrLrMrN collectionsdequerOrPrQrRrSrTrrUrVrWrX)r$r[r\rYrZrrrr%s&   zStreamReader.__init__cCs|jjg}|jr|d|j|jr|d|jdkr(|d|j|jf|jr3|d|j|jr>|d|jdd |S) Nz%d byteseofizlow=%d high=%dzw=%rze=%r<%s> ) __class__rrLappendrQrIrJrRrTjoin)r$inforrr__repr__s   zStreamReader.__repr__cCs |j|jfSr#)rIrJr)rrrget_read_buffer_limits z#StreamReader.get_read_buffer_limitscC|jSr#rTr)rrr exceptionzStreamReader.exceptionexc exc_causecCsX||_|j|j}|durd|_t||||j}|dur*d|_t|||dSdSr#)rTrVclearrRrrSr$rprqwaiterrrrrs  zStreamReader.set_exceptioncallbackcCsB|jrz|WdStytdYdSw|j|dSNException in eof callback)rQ ExceptionrrnrVrfr$rurrron_eofs  zStreamReader.on_eofc Csd|_|j}|durd|_t|d|j}|dur!d|_t|d|jD]}z|Wq$ty9tdYq$w|jdS)NTrw) rQrRrrSrVrxrrnrr)r$rtcbrrrfeed_eofs      zStreamReader.feed_eofcCrl)z&Return True if 'feed_eof' was called.rQr)rrris_eofszStreamReader.is_eofcC|jo|j S)z=Return True if the buffer is empty and 'feed_eof' was called.rQrOr)rrrat_eofszStreamReader.at_eofcsH|jrdS|jdus J|j|_z |jIdHWd|_dSd|_wr#)rQrSrK create_futurer)rrrwait_eofs zStreamReader.wait_eofdatacCsxtjdtdd|s dS|jr|jd|jd|jd<d|_|jt|7_|jt|8_|j|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) warningswarnDeprecationWarningrPrOrLlenrM appendleftrW)r$rrrr unread_datas  zStreamReader.unread_datarsizecCs|jrJd|s dSt|}|j|7_|j||j|7_|j}|dur2d|_t|d|j|jkrC|j j sE|j dSdSdS)Nzfeed_data after feed_eof) rQrrLrOrfrXrRrrJrH_reading_paused pause_reading)r$rrdata_lenrtrrr feed_datas  zStreamReader.feed_datacCs&|jdur|jr tdg|_dSdS)Nz@Called begin_http_chunk_receiving when some data was already fed)rNrX RuntimeErrorr)rrrbegin_http_chunk_receiving!s  z'StreamReader.begin_http_chunk_receivingcCsh|jdur td|jr|jdnd}|j|krdS|j|j|j}|dur2d|_t|ddSdS)NzFCalled end_chunk_receiving without calling begin_chunk_receiving firstr)rNrrXrfrRr)r$posrtrrrend_http_chunk_receiving)s  z%StreamReader.end_http_chunk_receiving func_namecs|jjs td|jdurtd||j}|_z$|j |IdHWdn1s0wYWd|_dSWd|_dSd|_w)NzConnection closed.zH%s() called while another coroutine is already waiting for incoming data)rH connectedrrRrKrrU)r$rrtrrr_waitGs"   zStreamReader._waitcs|IdHSr#) readuntilr)rrrr=\szStreamReader.readline separatorc st|}|dkr td|jdur|jd}d}d}|rm|jr[|r[|j}|jd||d}||r<|||dnd}||7}|t|7}|rMd}||jkrVtd|jr[|s"|jra |S|rk| d IdH|s|S) Nrz,Separator should be at least one-byte stringr-Tr rFz Chunk too bigr) r ValueErrorrTrOrPfind_read_nowait_chunkrJrQr) r$rseplenchunk chunk_size not_enoughoffseticharrrrrr_s<     zStreamReader.readuntilrr>cs|jdur |j |jr%|js%t|ddd|_|jdkr%tjddd|s)dS|dkrEg} |IdH}|s:n||q0d |S|jsY|jsY| d IdH|jsY|jrK| |S) NTrWrr zEMultiple access to StreamReader in eof state, might be infinite loop.) stack_infor-r?) rTrQrOgetattrrWrwarningrDrfrgr _read_nowait)r$r>blocksblockrrrr?s4       zStreamReader.readcsD|jdur |j|js|js|dIdH|js|jr|dS)NrDr)rTrOrQrrr)rrrrDs   zStreamReader.readanycs |jdur |j|jr1|jd}||jkrdS||jkr)|||jdfStd|js |jr;|ddfS|j r@dS| d IdHq) aReturns 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. TNrr-TzESkipping HTTP chunk end due to data consumption beyond chunk boundaryrFr7r8) rTrNpoprMrrrrOrrQr)r$rrrrr8s(     zStreamReader.readchunkcsx|jdur |jg}|dkr7||IdH}|s(d|}t|t|||||t|8}|dksd|S)Nrr-)rTr?rgr^IncompleteReadErrorrrf)r$r>rrpartialrrr readexactlys     zStreamReader.readexactlycCs2|jdur|j|jr|jstd||S)Nz9Called while some coroutine is waiting for incoming data.)rTrRdonerrrBrrr read_nowaits  zStreamReader.read_nowaitcCs|jd}|j}|dkr$t|||kr$||||}|j|7_n|r5|j||d}d|_n|j}t|}|j|8_|j|7_|j}|rf|d|jkrf|d|rf|d|jksX|j|jkru|j j ru|j |S)Nrr) rOrPrpopleftrLrMrNrrIrHrresume_reading)r$r> first_bufferrrr chunk_splitsrrrrs(      zStreamReader._read_nowait_chunkcCs^|jg}|jr&||}|||dkr#|t|8}|dkr#n|js |r-d|SdS)z6Read not more than n bytes, or whole buffer if n == -1rrr-)rUassert_timeoutrOrrfrrg)r$r>chunksrrrrrs    zStreamReader._read_nowaitr!Nr)rr)*rrrrr2r rGrrr^AbstractEventLoopr%strrir rj BaseExceptionrnr rrrzr|r:r~rrr9rrrrrr=rr?rDr8rrrrrrrrres\        $* "rc@s"eZdZdZd+ddZdefddZdeefdd Z e fd ed eddfd d Z de gdfddfddZ d+ddZdefddZdefddZd+ddZd,dededdfddZdefddZd-dedefd!d"Zdefd#d$Zdeeeffd%d&Zdedefd'd(Zd-dedefd)d*ZdS).EmptyStreamReader_read_eof_chunkr!NcCs d|_dSNFrr)rrrr%)r&zEmptyStreamReader.__init__cCs d|jjS)Nrc)rerr)rrrri,rkzEmptyStreamReader.__repr__cCdSr#rr)rrrrn/r+zEmptyStreamReader.exceptionrprqcCrr#r)r$rprqrrrr2szEmptyStreamReader.set_exceptionrucCs,z|WdStytdYdSwrv)rxrrnryrrrrz9s   zEmptyStreamReader.on_eofcCrr#rr)rrrr|?r+zEmptyStreamReader.feed_eofcCdSNTrr)rrrr~Br+zEmptyStreamReader.is_eofcCrrrr)rrrrEr+zEmptyStreamReader.at_eofcsdSr#rr)rrrrHzEmptyStreamReader.wait_eofrrr>cCrr#r)r$rr>rrrrKr+zEmptyStreamReader.feed_datacdSr,rr)rrrr=NrzEmptyStreamReader.readlinercrr,rrBrrrr?QrzEmptyStreamReader.readcrr,rr)rrrrDVrzEmptyStreamReader.readanycs|js d|_dSdS)NTr7rrr)rrrr8Ys zEmptyStreamReader.readchunkcstd|r,)r^rrBrrrr`s zEmptyStreamReader.readexactlycCrr,rrBrrrrcr+zEmptyStreamReader.read_nowaitrrr)rrrr2r%rrirrrnr rrrzr|r:r~rrr9rGrr=r?rDr r8rrrrrrr%s2    rrc@seZdZdZdejddfddZdefddZde fd d Z de fd d Z de e fd dZefde de ddfddZddededdfddZdddZdefddZdeefddZdS) rz>DataQueue is a general-purpose blocking queue with one reader.rZr!NcCs&||_d|_d|_d|_t|_dSr)rKrQrRrTr`rarO)r$rZrrrr%ms zDataQueue.__init__cCr<r#)rrOr)rrr__len__tr&zDataQueue.__len__cCrlr#r}r)rrrr~wrozDataQueue.is_eofcCrr#rr)rrrrzszDataQueue.at_eofcCrlr#rmr)rrrrn}rozDataQueue.exceptionrprqcCs4d|_||_|j}durd|_t|||dSdSr)rQrTrRrrsrrrrs zDataQueue.set_exceptionrrrcCs6|j||f|j}durd|_t|ddSdSr#)rOrfrRr)r$rrrtrrrrs zDataQueue.feed_datacCs,d|_|j}durd|_t|ddSdSr)rQrRr)r$rtrrrr|s zDataQueue.feed_eofc s|js*|js*|jr J|j|_z|jIdHWntjtjfy)d|_w|jr6|j\}}|S|j dur>|j t r#) rOrQrRrKrr^CancelledError TimeoutErrorrrTr)r$r_rrrr?s     zDataQueue.readcCr<r#)rr?r)rrrr*r&zDataQueue.__aiter__rr)rrrrr^rr%rGrr:r~rrrrnr rrrr|r?rr*rrrrrjs&  rcs^eZdZdZdededejddffdd Zdd e d eddffd d Z de fddZ Z S)FlowControlDataQueuezFlowControlDataQueue 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. r[r\rZr!Ncs(tj|dd|_||_|d|_dS)N)rZrr])superr%rLrH_limit)r$r[r\rZrerrr%szFlowControlDataQueue.__init__rrrcsFt|||j|7_|j|jkr|jjs!|jdSdSdSr#)rrrLrrHrrr$rrrrrrs zFlowControlDataQueue.feed_datac s|js*|js*|jr J|j|_z|jIdHWntjtjfy)d|_w|jrL|j\}}|j |8_ |j |j krJ|j j rJ|j |S|jdurT|jtr#)rOrQrRrKrr^rrrrLrrHrrrTrrrrrr?s&     zFlowControlDataQueue.readr) rrrrr rGr^rr%rrr? __classcell__rrrrrsr)$r^r`rtypingrrrrrrrr r base_protocolr helpersr rrrrlogr__all__rrxrrr3r;rrr__annotations__rrrrrrs* ,  CBA