Ë
|
ê^i Î ã ó d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
|
Z
|
d dl Z d dl m Z d dlmZ d dlmZ d dlmZ e j* rddlmZ d dlZdd lm Z dd
|
lm Z dd l m Z dd l m!Z!m"Z"m#Z# dd l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ ddl0m1Z1m2Z2 ddl3m4Z4 e j* rddl5m6Z6 ejn e8« Z9 G d d« Z: G d de:« Z; G d d« Z< G d de:« Z=e G d de:« Z> ej~ dk\ rd d l@mAZA nd d lBmAZA d ZC G d d e:« ZD G d! d"e:« ZEd*d#ZF G d$ d%« ZG G d& d'ej « ZI G d( d)eI« Zy# e$ r d dlZY w xY w# e$ r dZY w xY w# e$ r d ZCY aw xY w)+é )Ú annotationsN)Úcontextmanager)Ú HTTPMessage)Ú HTTPResponse)Útimeouté )ÚBaseHTTPConnection)Úutil)Ú
|
_TYPE_BODY)ÚHTTPHeaderDict)Ú BaseSSLErrorÚHTTPConnectionÚ HTTPException) ÚBodyNotHttplibCompatibleÚ DecodeErrorÚDependencyWarningÚ HTTPErrorÚIncompleteReadÚInvalidChunkLengthÚ InvalidHeaderÚ ProtocolErrorÚReadTimeoutErrorÚResponseNotChunkedÚSSLError)Ú is_fp_closedÚis_response_to_head)ÚRetry)ÚHTTPConnectionPoolc ó0 e Zd ZdddZedd« ZddZy) ÚContentDecoderc ó t « ©N©ÚNotImplementedError©ÚselfÚdataÚ
|
max_lengths õc H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\urllib3/response.pyÚ
|
decompresszContentDecoder.decompress7 ó Ü!Ó#Ð#ó c ó t « r" r# ©r& s r) Úhas_unconsumed_tailz"ContentDecoder.has_unconsumed_tail: ó ä!Ó#Ð#r, c ó t « r" r# r. s r) ÚflushzContentDecoder.flush> r+ r, N©éÿÿÿÿ©r' Úbytesr( ÚintÚreturnr6 ©r8 Úbool©r8 r6 )Ú__name__Ú
|
__module__Ú __qualname__r* Úpropertyr/ r2 © r, r) r r 6 s ô$ð ò$ó ð$ô$r, r c ó8 e Zd ZddZdddZed d« Zd
|
dZy) ÚDeflateDecoderc ó` d| _ d| _ d| _ t j « | _ y )NTr, )Ú
|
_first_tryÚ_first_try_dataÚ _unfed_dataÚzlibÚ decompressobjÚ_objr. s r) Ú__init__zDeflateDecoder.__init__C s) Ø Ø "Ô Ø ÔÜ×&Ñ&Ó( r, c ó | j |z }d| _ |s| j j s|S |}|dk rd}n |dk( r|| _ y| j s4| j j | j j |z |¬« S | xj
|
|z c_ | j j ||¬« }|rd| _ d| _ |S # t j $ rd d| _ t j t j « | _ | j | j
|
|¬« d| _ cY S # d| _ w xY ww xY w)Nr, r ©r( F)
|
rF rI Úunconsumed_tailrD r* rE rG ÚerrorrH Ú MAX_WBITS)r& r' r( Úoriginal_max_lengthÚ decompresseds r) r* zDeflateDecoder.decompressI s? Ø× Ñ $Ñ&Ø ÔÙDII× 5Ò 5ØKØ (ÐØ Ò "ØJØ AÒ %ð
|
$DÔ Øð Ø99×'Ñ'Ø ×)Ñ)¨DÑ0¸Zð (ó ð ð
|
× Ò Ñ$Õ ð +Ø 99×/Ñ/°ÀÐ/ÓLLÙØ"'Ø'*Ô$Ø Ð øäzzò +Ø #DOÜ ×*Ñ*¬D¯N©N¨?Ó;DIð +ØØ×(Ñ(Ð5Hð 'ó ð (+×$ø sÕ$úð +ús%  .C à AEÄ D7Ä-EÄ7 E Å Ec ó t | j « xs. t | j j « xr | j S r" )r: rF rI rM rD r. s r) r/ z"DeflateDecoder.has_unconsumed_tails s8 äD×$Ñ$Ó%ò
|
Ü ×*Ñ*Ó +Ò C°D·O±OÐ0Cð
|
r, c ó6 | j j « S r" ©rI r2 r. s r) r2 zDeflateDecoder.flushy ó ØyyÓ Ð r, N©r8 ÚNoner3 r5 r9 r; ©r< r= r> rJ r* r? r/ r2 r@ r, r) rB rB B s& ó)ô (+ðT ò
|
ó ð
|
ô
|
!r, rB c ó e Zd ZdZdZdZy)ÚGzipDecoderStater r é N)r< r= r> Ú FIRST_MEMBERÚ OTHER_MEMBERSÚ SWALLOW_DATAr@ r, r) rZ rZ } s ØLØMØLr, rZ c ó8 e Zd ZddZdddZed d« Zd
|
dZy) Ú GzipDecoderc ó t j dt j z « | _ t j
|
| _ d| _ y )Né r, )rG rH rO rI rZ r\ Ú_stateÚ_unconsumed_tailr. s r) rJ zGzipDecoder.__init__ s2 Ü×&Ñ& r¬D¯N©NÑ':Ó; Ü&×3Ñ3 Ø #Õ r, c
|
ó t « }| j t j k( r t |« S |dk( r| xj
|
|z c_ y| j
|
|z }|s!| j j r t |« S || j j |t |t |« z
|
d« ¬« z }| j j xs | j j x| _ }|dkD rt |« |k\ r t |« S |s t |« S | j j r@t j | _ t j dt j" z « | _ ï# t j $ rJ | j }t j | _ d| _ |t j k( r t |« cY S w xY w)Nr r, rL rb )Ú bytearrayrc rZ r^ r6 rd rI Úeofr* ÚmaxÚlenrG rN r] rM Ú unused_datarH rO )r& r' r( ÚretÚprevious_states r) r* zGzipDecoder.decompress s ÜkØ ;;Ô*×7Ñ7Ò 7Ü:Ð à ?ð
|
× !Ò ! TÑ )Õ !Øð ×$Ñ$ tÑ+Ù Ü:Ð àð Øtyy×+Ñ+ؤS¨´c¸#³hÑ)>ÀÓ%Bð ,ó ñ ð ×)Ñ)ÒB¨T¯Y©Y×-BÑ-Bð DÔ ! Dð A~¤# c£(¨jÒ"8Øô SzÐñ Ü SzÐ!ð yy}}Ü .× <Ñ < Ü × .Ñ .¨r´D·N±NÑ/BÓ C ð7 øô
|
::ò Ø!%§¡ä .× ;Ñ ; Ø(+Ô%Ø!Ô%5×%CÑ%CÒCä :Ò%Øð ús Â6E0 Å0AG Ç G c ó, t | j « S r" )r: rd r. s r) r/ z GzipDecoder.has_unconsumed_tail» s äD×)Ñ)Ó*Ð*r, c ó6 | j j « S r" rT r. s r) r2 zGzipDecoder.flush¿ rU r, NrV r3 r5 r9 r; rX r@ r, r) r` r` s& ó$ô
|
0ðd ò+ó ð+ô!r, r` c óB e Zd ZddZdd dZdd
|
dZed d« Zd dZy) Ú BrotliDecoderc óè t j « | _ t | j d« r"t | d| j j
|
« y t | d| j j « y )Nr* Ú _decompress)ÚbrotliÚ DecompressorrI ÚhasattrÚsetattrr* Úprocessr. s r) rJ zBrotliDecoder.__init__É sL Ü ×+Ñ+Ó-DIÜtyy ,Ô/Üm¨T¯Y©Y×-AÑ-AÕBäm¨T¯Y©Y×->Ñ->Õ?r, c ó t « r" r# )r& r' Úoutput_buffer_limits r) rr zBrotliDecoder._decompressÑ s Ü%Ó'Ð 'r, c óÊ |dkD r| j ||¬« S | j |« S # t $ r. t j dt « | j |« cY S w xY w)Nr )ry z;Brotli >= 1.2.0 is required to prevent decompression bombs.)rr Ú TypeErrorÚwarningsÚwarnr r% s r) r* zBrotliDecoder.decompressÔ sk ð .Ø >Ø ×+Ñ+¨DÀjÐ+ÓQÐQà ×+Ñ+¨DÓ1Ð1øÜ ò .ô ØQÜ%ôð ×'Ñ'¨Ó-Ò-ð .ús + + «4A"Á!A"c óX | j j « S # t $ r Y yw xY w)NF)rI Úcan_accept_more_dataÚAttributeErrorr. s r) r/ z!BrotliDecoder.has_unconsumed_tailã s/ ð Ø 99×9Ñ9Ó;Ð;Ð;øÜ!ò Ù ð ús )¨)c ód t | j d« r| j j « S y)Nr2 r, )ru rI r2 r. s r) r2 zBrotliDecoder.flushê s$ Ütyy 'Ô*ØyyÓ(Ð(Ør, NrV r3 )r' r6 ry r7 r8 r6 r5 r9 r; ) r< r= r> rJ rr r* r? r/ r2 r@ r, r) rp rp Å s+ ó @ô (ô .ð
|
ò ó
|
ð ô r, rp )é é )ÚzstdTc ó8 e Zd ZddZdddZed d« Zd
|
dZy) Ú ZstdDecoderc ó6 t j « | _ y r" )r ÚZstdDecompressorrI r. s r) rJ zZstdDecoder.__init__û s Ü ×-Ñ-Ó/DIr, c óR |s | j sy| j j r2| j j |z }t j
|
« | _ | j j ||¬« }t |« }|g}| j j rÿ| j j ré|dk s||k rß| j j }| j j st j
|
« | _ | j j ||dkD r||z
|
nd¬« }t |« x}r|j |« ||z }n| j j rn8| j j r"| j j r |dk rÙ||k rßdj |« S )Nr, rL r r4 ) r/ rI rg rj r r r* ri Ú needs_inputÚappendÚjoin)r& r' r( ÚpartÚlengthÚ
|
data_partsrj Ú part_lengths r) r* zZstdDecoder.decompressþ sZ Ù × 8Ò 8ØØyy}}Øyy×,Ñ,¨tÑ3Ü × 1Ñ 1Ó 3 Ø99×'Ñ'¨¸Ð'ÓDDÜYFØ Jð ØII×)Ò)Ø !^ v°
|
Ò':à "ii× 3Ñ 3 Øyy×,Ò,Ü $× 5Ñ 5Ó 7DIØyy×+Ñ+Ø Ø8BÀQº
|
¨VÒ 3ÈBð ,ó ô #& d£)Ð+;Ð+Ø ×%Ñ% dÔ+ØkÑ)FØYY×*Ò*Øð ØII×)Ò)Ø !^ v°
|
Ó':ð 88JÓ'Ð 'r, c ó¢ | j j xs | j j xs t | j j « S r" )rI r rg r: rj r. s r) r/ z ZstdDecoder.has_unconsumed_tail s> à ×-Ñ-Ò>°·±· ± Ð?ò Ä4Ø ×%Ñ%óDð r, c óF | j j s t d« y)Nz Zstandard data is incompleter, )rI rg r r. s r) r2 zZstdDecoder.flush& s Ø99==Ü!Ð"@ÓAÐAØr, NrV r3 r5 r9 r; rX r@ r, r) r r ú s& ó 0ô (ðD
|
ò ó
|
ð ô
|
r, r Fc ó@ e Zd ZdZdZddZd dZd
|
d dZed d« Z y) Ú MultiDecodera
|
From RFC7231:
|
If one or more encodings have been applied to a representation, the
|
sender that applied the encodings MUST generate a Content-Encoding
|
header field that lists the content codings in the order in which
|
they were applied.
|
é c ó$ |j d« D cg c] }|j « }}t |« | j kD r$t dt |« d| j « |D cg c] }t |« c}| _ y c c}w c c}w )Nú,z)Too many content encodings in the chain: z > )ÚsplitÚstripri Úmax_decode_linksr Ú _get_decoderÚ _decoders)r& ÚmodesÚmÚ encodingsÚes r) rJ zMultiDecoder.__init__9 s Ø(-¯ © °CÓ(8Ö9 1QWWYÐ9 Ð9Ü y>D× 1Ñ 1Ò 1Ü Ø;Üy>Ð" # d×&;Ñ&;Ð%<ð>óð ð 4=Ö=¨a, q/Ò=ùò :ùò >s BÁ-B c ó< | j d j « S ©Nr )r r2 r. s r) r2 zMultiDecoder.flushB s Ø~~aÑ ×&Ñ&Ó(Ð(r, c óB |dk r-t | j « D ] }|j |« } |S t « } d}t | j « D ]& }|j ||t |« z
|
¬« }|s%d}( ||z }|rt |« |k\ r t |« S d}c)Nr TFrL r, )Úreversedr r* rf ri r6 )r& r' r( Údrk Úany_datas r) r* zMultiDecoder.decompressE s Ø ?Ü dnnÓ-ò *Ø|| DÓ)ð *àKäkð Ø HÜ dnnÓ-ò $Ø|| D°ZÄ#ÀcÃ(Ñ5J|ÓKÚØ #Hð $ð 4KCÙs 3x¨:Ò 5Ü SzÐ!ØDð r, c ó: t d | j D « « S )Nc 3 ó4 K | ] }|j y wr" )r/ )Ú.0r¥ s r) ú <genexpr>z3MultiDecoder.has_unconsumed_tail.<locals>.<genexpr>a s è ø ÒA¨Q1×(Õ(ÑAùs )Úanyr r. s r) r/ z MultiDecoder.has_unconsumed_tail_ s äÑA°$·.±.ÔAÓAÐAr, N)r Ústrr8 rW r; r3 r5 r9 )
|
r< r= r> Ú__doc__r rJ r2 r* r? r/ r@ r, r) r r , s4 ñð Ðó>ó)ôð4 òBó ñBr, r c ó¤ d| v r t | « S | dv r
|
t « S t | dk( r
|
t « S t r| dk( r
|
t « S t « S )Nr )Úgzipúx-gzipÚbrr )r r` rs rp ÚHAS_ZSTDr rB )Úmodes r) r r d sU Ø
|
d{ÜDÓ!Ð!ð Ð!Ñ!Ü}Ð ä Ðd dlÜ Ð åDFNÜ}Ð ä Ó Ðr, c ó8 e Zd ZdZddZd dZd
|
dZd dZd dZy) ÚBytesQueueBuffera Memory-efficient bytes buffer
|
|
To return decoded data in read() and still follow the BufferedIOBase API, we need a
|
buffer to always return the correct amount of bytes.
|
|
This buffer should be filled using calls to put()
|
|
Our maximum memory usage is determined by the sum of the size of:
|
|
* self.buffer, which contains the full data
|
* the largest chunk that we will copy in get()
|
c óD t j « | _ d| _ y r¢ )Ú collectionsÚdequeÚbufferÚ_sizer. s r) rJ zBytesQueueBuffer.__init__ s Ü?J×?PÑ?PÓ?R Ø
|
r, c ó | j S r" )rº r. s r) Ú__len__zBytesQueueBuffer.__len__ s ØzzÐr, c óv | j j |« | xj t |« z c_ y r" )r¹ r rº ri ©r& r' s r) ÚputzBytesQueueBuffer.put s& Ø ×Ñ4Ô Ø
|
|
c$iÑ
|
r, c óH |dk( ry| j s t d« |dk r t d« t | j d « |k( rLt | j d t
|
« r/| xj |z c_ | j j « S d}t j « }||k rä||z
|
}| j j « }t |« }||k rgt |« }|d | ||d }}|j |« | j j |« | xj |z c_ |j « S |j |« | xj |z c_ ||z }| j s |j « S ||k rä|j « S )Nr r, zbuffer is emptyzn should be > 0)r¹ Ú RuntimeErrorÚ
|
ValueErrorri Ú
|
isinstancer6 rº ÚpopleftÚioÚBytesIOÚ
|
memoryviewÚwriteÚ
|
appendleftÚgetvalue) r& ÚnÚfetchedrk Ú remainingÚchunkÚ chunk_lengthÚ
|
left_chunkÚ right_chunks r) ÚgetzBytesQueueBuffer.get sl Ø 6ØØÜ Ð 0Ó1Ð 1Ø UÜ Ð .Ó/Ð /ä t{{1~Ó !Ò #¬
|
°4·;±;¸q±>Ä5Ô(IØ JJ!OJØ;;×&Ñ&Ó(Ð (àÜjjlØkØG IØKK×'Ñ'Ó)EÜ u:LØ<Ò'Ü" 5Ó)Ø*/°
|
°Ð*;¸UÀ9À:Ð=NK
|
Ø *Ô%Ø ×&Ñ& {Ô3Ø
|
|
iÑ'
|
Øð ||~Ð ð %Ô Ø
|
|
lÑ*
|
Ø |Ñ #Gà;;Øà||~Ð ð' kð& ||~Ð r, c ót | j s| j dk( sJ yt « dk( r1j « }t |t
|
« ra|j « }nPt j « }|j fdt t « « D « « |j « }d| _ |S )Nr r, r c 3 ó> K | ] }j « y wr" )rÄ )r© Ú_r¹ s r) rª z+BytesQueueBuffer.get_all.<locals>.<genexpr>½ s øè ø ÒH°6>>×+ÑHùs ) r¹ rº ri Úpoprà rÇ ÚtobytesrÅ rÆ Ú
|
writelinesÚrangerÊ )r& Úresultrk r¹ s @r) Úget_allzBytesQueueBuffer.get_all² s ø ØÙØ:: ?Ð "?ØÜ v;!Ò ØZZ\FÜ&¤*Ô-Ø Ó)ä**,CØ NNÓH´U¼3¸v»;Ó5GÔHÔ HØ\\^FØ
|
Ø r, NrV ©r8 r7 )r' r6 r8 rW )rË r7 r8 r6 r; ) r< r= r> r rJ r¼ r¿ rÒ rÛ r@ r, r) rµ rµ v s! ñ ó óó ó! ôFr, rµ c ó^ e Zd ZU g d¢Zeedgz Zeredgz Zg d¢Zeej fZ
|
de d< ee
|
ej fz Z
|
ere
|
e j fz Z
|
ddd d"d Zd#d
|
Zed$d « Zd%d Zed&d « Zej( d'd« Zed(d« Zed)d« Zej( d*d« Z d+ d,dZ d- d.dZ d/ d0dZ d/ d,dZd1dZd1dZ d1dZ d1dZ d1dZ d2 d3dZ d$d Z!d4d Z"d5d Z#d2d6d Z$d5d Z%d&d!Z&y)7ÚBaseHTTPResponse)r¯ r° ÚdeflateNr± r )i- i. i/ i3 i4 ztuple[type[Exception], ...]ÚDECODER_ERROR_CLASSES)ÚheadersÚretriesc ó~ t |t « r|| _ nt |« | _ || _ || _ || _ || _ || _ d| _ || _ || _
|
d| _ | j j dd« j « } d | j d« D « }
|
d|
|
v rd| _ d | _ | y )NFztransfer-encodingÚ c 3 ó< K | ] }|j « y wr" )r )r© Úencs r) rª z,BaseHTTPResponse.__init__.<locals>.<genexpr>î s è ø Ò> SSYY[Ñ>ùs r ÚchunkedT)rà r rá ÚstatusÚversionÚversion_stringÚreasonÚdecode_contentÚ_has_decoded_contentÚ _request_urlrâ rç rÒ Úlowerr Ú_decoder) r& rá rè ré rê rë rì Ú request_urlrâ Útr_encr s r) rJ zBaseHTTPResponse.__init__Ò s° ô g~Ô .Ø"DLä)¨'Ó2DLØ Ø Ø ,ÔØ Ø ,ÔØ$)Ô!Ø(3ÔØ à Ø ×!Ñ!Ð"5°rÓ:×@Ñ@ÓBá>¨F¯L©L¸Ó,=Ô> Ø Ñ !Ø DLà/3 Ú r, c ój | j | j v r| j j d« S y)a
|
Should we redirect and where to?
|
|
:returns: Truthy redirect location string if we got a redirect status
|
code and valid location. ``None`` if redirect status and no
|
location. ``False`` if not a redirect status code.
|
ÚlocationF)rè ÚREDIRECT_STATUSESrá rÒ r. s r) Úget_redirect_locationz&BaseHTTPResponse.get_redirect_locationõ s. ð ;;$×0Ñ0Ñ 0Ø<<×#Ñ# JÓ/Ð /Ør, c ó t « r" r# r. s r) r' zBaseHTTPResponse.data r0 r, c ób | j j d« }t j |« S )aÄ
|
Deserializes the body of the HTTP response as a Python object.
|
|
The body of the HTTP response must be encoded using UTF-8, as per
|
`RFC 8529 Section 8.1 <https://www.rfc-editor.org/rfc/rfc8259#section-8.1>`_.
|
|
To use a custom JSON decoder pass the result of :attr:`HTTPResponse.data` to
|
your custom decoder instead.
|
|
If the body of the HTTP response is not decodable to UTF-8, a
|
`UnicodeDecodeError` will be raised. If the body of the HTTP response is not a
|
valid JSON document, a `json.JSONDecodeError` will be raised.
|
|
Read more :ref:`here <json_content>`.
|
|
:returns: The body of the HTTP response as a Python object.
|
zutf-8)r' ÚdecodeÚ_jsonÚloadsr¾ s r) ÚjsonzBaseHTTPResponse.json s' ð$ yy× Ñ Ó(Ü{{4Ó Ð r, c ó t « r" r# r. s r) ÚurlzBaseHTTPResponse.url r0 r, c ó t « r" r# ©r& rþ s r) rþ zBaseHTTPResponse.url r0 r, c ó t « r" r# r. s r) Ú
|
connectionzBaseHTTPResponse.connection" r0 r, c ó | j S r" )Ú_retriesr. s r) râ zBaseHTTPResponse.retries& s à}}Ð r, c ój |*|j r |j d j | _ || _ y )Nr4 )ÚhistoryÚredirect_locationrþ r )r& râ s r) râ zBaseHTTPResponse.retries* s- ð Ð 7§?¢?Ø rÑ*×<Ñ<DHØ r, c ó t « r" r# ©r& Úamtrì s r) ÚstreamzBaseHTTPResponse.stream1 s ô "Ó#Ð#r, c ó t « r" r# )r& r
|
rì Ú cache_contents r) ÚreadzBaseHTTPResponse.read6 s ô "Ó#Ð#r, c ó t « r" r# r s r) Úread1zBaseHTTPResponse.read1> ó ô
|
"Ó#Ð#r, c ó t « r" r# r s r) Ú read_chunkedz BaseHTTPResponse.read_chunkedE r r, c ó t « r" r# r. s r) Ú release_connz BaseHTTPResponse.release_connL r+ r, c ó t « r" r# r. s r) Ú
|
drain_connzBaseHTTPResponse.drain_connO r+ r, c ó t « r" r# r. s r) ÚshutdownzBaseHTTPResponse.shutdownR r+ r, c ó t « r" r# r. s r) ÚclosezBaseHTTPResponse.closeU r+ r, c óz | j j dd« j « }| j || j v rt |« | _ yd|v r\|j d« D cg c]. }|j « | j v r|j « 0 }}|rt |« | _ yyyyc c}w )z=
|
Set-up the _decoder attribute if necessary.
|
úcontent-encodingrä Nr )rá rÒ rï rð ÚCONTENT_DECODERSr r r )r& Úcontent_encodingr r s r) Ú _init_decoderz BaseHTTPResponse._init_decoderX s½ ð <<×+Ñ+Ð,>ÀÓC×IÑIÓKÐØ ==Ð Ø 4×#8Ñ#8Ñ8Ü ,Ð-=Ó > ØÐ(Ñ(ð .× 3Ñ 3°CÓ 8ö àØwwy D×$9Ñ$9Ñ9ð GGIð ð ñ
|
Ü$0Ð1AÓ$BDMð ð )ð !ùò s Á-3B8c óv |s| j r t d« |S ||rd} | j r$| j j ||¬« }d| _ |r|| j « z }|S # | j $ r?}| j
|
j dd« j « }t d|z |« |d}~ww xY w) zN
|
Decode the data passed in and potentially flush the decoder.
|
ú_Calling read(decode_content=False) is not supported after read(decode_content=True) was called.Nr4 rL Tr rä zEReceived response with content-encoding: %s, but failed to decode it.)
|
rí rÁ rð r* rà rá rÒ rï r Ú_flush_decoder)r& r' rì Ú flush_decoderr( r r s r) Ú_decodezBaseHTTPResponse._decodek sÛ ñ Ø×(Ò(Ü"ð<óð ð Kà Ð ¡ ØJð
|
Ø}}Ø}}×/Ñ/°ÀÐ/ÓLØ,0Ô)ñ Ø D×'Ñ'Ó)Ñ )Dà øð ×)Ñ)ò Ø #||× /Ñ /Ð0BÀBÓ G× MÑ MÓ OÐ Ü ð'Ø)9ñ:àóð ð ûð ús £0A* Á*B8Á9:B3Â3B8c ó | j r6| j j d« | j j « z S y)zk
|
Flushes the decoder. Should only be called if the decoder is actually
|
being used.
|
r, )rð r* r2 r. s r) r# z BaseHTTPResponse._flush_decoder s5 ð
|
==Ø==×+Ñ+¨CÓ0°4·=±=×3FÑ3FÓ3HÑHÐ HØr, c ó | j t |« « }t |« dk( ry||d t |« t |« S r¢ )r ri )r& ÚbÚtemps r) ÚreadintozBaseHTTPResponse.readinto s; ØyyQÓ Ü t9>Øà !AkD NÜt9Ð r, c ó | j S r" ©rá r. s r) Ú
|
getheaderszBaseHTTPResponse.getheaders£ ó Ø||Ðr, c ó: | j j ||« S r" )rá rÒ )r& ÚnameÚdefaults r) Ú getheaderzBaseHTTPResponse.getheader¦ s Ø||× Ñ gÓ.Ð.r, c ó | j S r" r, r. s r) ÚinfozBaseHTTPResponse.infoª r. r, c ó | j S r" )rþ r. s r) ÚgeturlzBaseHTTPResponse.geturl s Øxxr, )rá ú>typing.Mapping[str, str] | typing.Mapping[bytes, bytes] | Nonerè r7 ré r7 rê r¬ rë ú
|
str | Nonerì r: rñ r8 râ ú Retry | Noner8 rW )r8 z"str | None | typing.Literal[False]r; )r8 z
|
typing.Any©r8 r8 ©rþ r8 r8 rW )r8 zBaseHTTPConnection | None)r8 r9 )râ r9 r8 rW ©i N)r
|
ú
|
int | Nonerì ú bool | Noner8 útyping.Iterator[bytes]©NNF©r
|
r= rì r> r r: r8 r6 ©NN©r
|
r= rì r> r8 r6 rV r" )
|
r' r6 rì r> r$ r: r( r= r8 r6 )r( rf r8 r7 )r8 r )r0 r¬ r1 r8 r8 r8 )'r< r= r> r rs r² rõ ÚIOErrorrG rN rà Ú__annotations__r Ú ZstdErrorrJ rö r? r' rü rþ Úsetterr râ r r r r r r r r r r% r# r* r- r2 r4 r6 r@ r, r) rÞ rÞ Ã s
Ú4ÐØ ÐØTFÑ"ÐÙØVHÑ$ÐÚ1Ðà:AÀ4Ç:Á:Ð9NÐÐ6ÓNØ ÐØ &§,¡, Ñ0Ð áØ $§.¡.Ð!2Ñ2Ð ð
|
SWð !%ñ!*ð Pð!*ð ð !*ð
|
ð !*ð ð !*ð ð!*ð ð!*ð ð!*ð ð!*ð
|
ó!*óF
|
ð ò$ó ð$ó!ð* ò$ó ð$ð ZZò$ó ð$ð ò$ó ð$ð ò ó ð ð ^^ò ó ð ð FJð$Ø ð$Ø7Bð$à ó$ð Ø&*Ø #ð $à ð$ð $ð$ð ð $ð
|
|
ó $ð Ø&*ð$à ð$ð $ð$ð
|
ó $ð Ø&*ð$à ð$ð $ð$ð
|
ó $ó$ó$ó$ó$óCð0 "&ð #àð#ð $ð#ð ð #ð
|
ð #ð
|
ó #óJó ó ô/ó ôr, rÞ c ó e Zd ZdZ d d fd Zd!dZd!dZed"d« Zed#d« Z d$dZ
|
d%dZ d&d Z e d'd
|
« Z d(d d d)d Z d(d d d)dZ d* d+dZ d, d-dZ d. d/dZd$dZd!dZd!dZed$d« Zd%dZd!dZd$dZd!dZd0dZ d, d/dZ ed1d « Z e j> d2d « Z d3d Z xZ!S )4r aá
|
HTTP Response container.
|
|
Backwards-compatible with :class:`http.client.HTTPResponse` but the response ``body`` is
|
loaded and decoded on-demand when the ``data`` property is accessed. This
|
class is also compatible with the Python standard library's :mod:`io`
|
module, and can hence be treated as a readable object in the context of that
|
framework.
|
|
Extra parameters for behaviour not present in :class:`http.client.HTTPResponse`:
|
|
:param preload_content:
|
If True, the response's body will be preloaded during construction.
|
|
:param decode_content:
|
If True, will attempt to decode the body based on the
|
'content-encoding' header.
|
|
:param original_response:
|
When this HTTPResponse wrapper is generated from an :class:`http.client.HTTPResponse`
|
object, it's convenient to include the original for debug purposes. It's
|
otherwise unused.
|
|
:param retries:
|
The retries contains the last :class:`~urllib3.util.retry.Retry` that
|
was used during the request.
|
|
:param enforce_content_length:
|
Enforce content length checking. Body returned by server must match
|
value of Content-Length header, if present. Otherwise, raise error.
|
c
|
óÊ t | |||||||| ¬« || _ || _ d | _ d | _ | | _ d| _ | | _ |r t |t t f« r|| _ |
|
| _ | | _ t |d« r|| _ || _ d | _ | j# |« | _ t' « | _ |r%| j s| j+ |¬« | _ y y y )N)rá rè ré rê rë rì rñ râ r r ©rì )ÚsuperrJ Úenforce_content_lengthÚ
|
auto_closeÚ_bodyÚ_fpÚ_original_responseÚ_fp_bytes_readÚmsgrà r¬ r6 Ú_poolÚ _connectionru Ú_sock_shutdownÚ
|
chunk_leftÚ _init_lengthÚlength_remainingrµ Ú_decoded_bufferr )r& Úbodyrá rè ré rê rë Úpreload_contentrì Úoriginal_responseÚpoolr rR râ rL Úrequest_methodrñ rM Ú sock_shutdownÚ __class__s r) rJ zHTTPResponse.__init__Ò só ø ô* ÑØØØØ)ØØ)Ø#Øð ô
|
ð '=Ô#Ø$à
|
Ø04Ø"3Ô Ø ÔØá Jt¤c¬5 \Ô2Ø DJà
|
Ø%Ôä 4Ô ØDHØ +Ôð '+ð !%× 1Ñ 1°.Ó AÔ ô 0Ó 1Ô ñ 4§:¢:Ø °.ÓADJð $.?r, c ó | j r | j sy | j j | j « d | _ y r" )rS rT Ú _put_connr. s r) r zHTTPResponse.release_conn s4 Øzz ×!1Ò!1Øà
|
|
× Ñ T× -Ñ -Ô.Ø Õr, c ód | j « y# t t t t f$ r Y yw xY w)zÏ
|
Read and discard any remaining HTTP response data in the response connection.
|
|
Unread data in the HTTPResponse connection blocks the connection from being released back to the pool.
|
N)r r ÚOSErrorr r r. s r) r zHTTPResponse.drain_conn s+ ð Ø IIKøÜ7¤L´-Ð@ò Ù ð ús /®/c óp | j r | j S | j r| j d¬« S y )NT)r )rN rO r r. s r) r' zHTTPResponse.data$ s0 ð ::Ø::Ð à 88Ø99¨49Ó0Ð 0àr, c ó | j S r" )rT r. s r) r zHTTPResponse.connection/ s à× Ñ Ð r, c ó, t | j « S r" )r rO r. s r) ÚisclosedzHTTPResponse.isclosed3 s ÜDHHÓ%Ð%r, c ó | j S )zì
|
Obtain the number of bytes pulled over the wire so far. May differ from
|
the amount of content returned by :meth:``urllib3.response.HTTPResponse.read``
|
if bytes are encoded on the wire (e.g, compressed).
|
)rQ r. s r) ÚtellzHTTPResponse.tell6 s ð ×"Ñ"Ð"r, c óê | j j d« }|~| j rt j d« y |j d« D ch c] }t |« }}t |« dkD rt d|z « |j « }|dk rd}nd} t | j « }|dv sd |cxk rd
|
k sn |d k( rd}|S c c}w # t $ r d}Y Bw xY w# t $ r d}Y =w xY w) zM
|
Set initial length value for Response content if available.
|
zcontent-lengthNzÒReceived response with both Content-Length and Transfer-Encoding set. This is expressly forbidden by RFC 7230 sec 3.3.2. Ignoring Content-Length and attempting to process response as Transfer-Encoding: chunked.r r z8Content-Length contained multiple unmatching values (%s)r )éÌ i0 éd éÈ ÚHEAD) rá rÒ rç ÚlogÚwarningr r7 ri r rÖ r rè )r& r^ Úcontent_lengthÚvalÚlengthsr rè s r) rW zHTTPResponse._init_length> s ð
|
&*§\¡\×%5Ñ%5Ð6FÓ%Gà Ð %Ø||ô ð ôð ð "ð 0>×/CÑ/CÀCÓ/HÖI¨3s8ÐIÐIÜw< !Ò#Ü'ð1Ø3AñBóð ð ! ð A:Ø !Fð Fð ÜÓ%Fð
|
ZÑ 3¨&Ô#6°3Ô#6¸.ÈFÒ:RØFà ùò7 Jøô ò Ø ð ûô ò ØFð ús6 ÁC ÁCÁ&.C Â C$ ÃC Ã C!Ã C!Ã$ C2Ã1C2c # óø K d} d d}|sL| j r| j j « | j r| j j « | j r,| j j « r| j! « yyy# t $ r }t | j dd« |d}~wt $ r6}dt |« vr t |« |t | j dd« |d}~wt $ rL}|j )|j |j |j k( rd}nd|}t ||« |d}~wt t f$ r}t d||« |d}~ww xY w# |sL| j r| j j « | j r| j j « | j r,| j j « r| j! « w w w xY ww)zç
|
Catch low-level python exceptions, instead re-raising urllib3
|
variants, so that low-level exceptions are not leaked in the
|
high-level api.
|
|
On exit, release the connection back to the pool.
|
FNzRead timed out.zread operation timed outz!Response may not contain content.zConnection broken: T)Ú SocketTimeoutr rS r r¬ r r ÚexpectedÚpartialr r rd rP r rT rh r )r& Ú
|
clean_exitr Úargs r) Ú_error_catcherzHTTPResponse._error_catcherv sÞ è ø ð
|
ð5 $ð KÛð> Jñ ð ×*Ò*Ø×+Ñ+×1Ñ1Ô3ð
|
×#Ò#Ø×$Ñ$×*Ñ*Ô,ð ×&Ò&¨4×+BÑ+B×+KÑ+KÔ+MØ×!Ñ!Õ#ð ,NÐ&øôa !ò Sô ' t§z¡z°4Ð9JÓKÐQRÐRûä ò Sà-´S¸³VÑ;ä" 1+¨1Ð,ä& t§z¡z°4Ð9JÓKÐQRÐRûä!ò 3àJJÐ*Ø Ð-Ø
|
|
q§y¡y jÒ0à=Cà /°¨uÐ5CÜ# C¨Ó+°Ð2ûä!¤7Ð+ò KÜ#Ð&9¸!¸Ð$?ÀÓCÈÐJûð Kûñ ð ×*Ò*Ø×+Ñ+×1Ñ1Ô3ð
|
×#Ò#Ø×$Ñ$×*Ñ*Ô,ð ×&Ò&¨4×+BÑ+B×+KÑ+KÔ+MØ×!Ñ!Õ#ð ,NÐ&üs_ G:B E/ BG: E, B5Â5 E,Ã1C2Ã2 E,Ã>AEÅE,ÅE'Å'E,Å,E/ Å/BG7Ç7G:F©r c óâ | j sJ d}|r||kD s |ç| j rÛ| j |kD rÌt j st j
|
dk r©|r| j j |« S t j « }d}||dk7 r_|t ||« }||z }n|}| j j |« }|s |j « S |j |« ~|Y|dk7 r_|j « S |r7|| j j |« S | j j « S || j j |« S | j j « S )aX
|
Read a response with the thought that reading the number of bytes
|
larger than can fit in a 32-bit int at a time via SSL in some
|
known cases leads to an overflow error that has to be prevented
|
if `amt` or `self.length_remaining` indicate that a problem may
|
happen.
|
|
The known cases:
|
* CPython < 3.9.7 because of a bug
|
https://github.com/urllib3/urllib3/issues/2513#issuecomment-1152559900.
|
* urllib3 injected with pyOpenSSL-backed SSL-support.
|
* CPython < 3.10 only when `amt` does not fit 32-bit int.
|
iÿÿÿ)r é
|
i r ) rO rX r
|
Ú IS_PYOPENSSLÚsysÚ version_infor rÅ rÆ Úminr rÈ rÊ )r& r
|
r Ú c_int_maxr¹ Ú max_chunk_amtÚ chunk_amtr' s r) Ú_fp_readzHTTPResponse._fp_read¸ sH ð& xxxØ á S9_à Ø×)Ò)Ø×)Ñ)¨IÒ5ä× Ò ¤C×$4Ñ$4°wÒ$>ÙØxx~~ iÓ0Ð0ÜZZ\Fð "MØ+ ¨¢Ø?Ü # C¨ Ó 7IØ9Ñ$Cà -IØxx}} YÓ/ÙØð ??Ó$Ð $ð TÔ"Øð + ¨£ð ??Ó$Ð $Ù Ø*-¨/488>> #Ó&Ð O¸t¿x¹x¿~¹~Ó?OÐ Oð *-¨ 488== Ó%Ð M¸d¿h¹h¿m¹m»oÐ Mr, c ó¤ | j yt | j dd« }| j « 5 |s| j ||¬« nd}|h|dk7 rc|sa| j j « | j
|
rv| j j| j dk7 r[t | j | j « |r9|dk7 r|r| j t |« k( r| j j « ddd« rH| xj t |« z c_ | j | xj t |« z c_ |S # 1 sw Y UxY w)z7
|
Reads `amt` of bytes from the socket.
|
NÚclosedFr| r, r )
|
rO Úgetattrr{ r r rL rX r rQ ri )r& r
|
r Ú fp_closedr' s r) Ú _raw_readzHTTPResponse._raw_readñ s$ ð 88Ð ØäDHH h°Ó6 à × Ñ Ó "ñ !Ù:C4== ¨E=Ô2ÈDØ 3¨!¢8±Dð Ô à×/Ò/Ø ×-Ñ-Ð9Ø ×-Ñ-°Ò2ô )¨×)<Ñ)<¸d×>SÑ>SÓTÐTÙØ¡$¨4×+@Ñ+@ÄCÈÃIÒ+Mð Ô ÷= !ñ@ Ø × Ò ¤3 t£9Ñ ,Õ Ø×$Ñ$Ð0Ø×%Ò%¬¨T«Ñ2Õ%Ø ÷I !ð !ús µB=EÅEc ó¢ | j « | | j }|r|dk rd}n|d}| j r\| j j rF| j d|d|t | j « z
|
¬« }| j j |« t | j « |k\ r| j j |« S | j |« }|du xs
|
|dk7 xr | }|s<t | j « dk( r$| j r| j j s|S | | j |||« }|r|| _
|
|S |s| j r t d« |S | j ||||t | j « z
|
¬« }| j j |« t | j « |k rt|rr| j |« }| j ||||t | j « z
|
¬« }| j j |« t | j « |k r|rr| j j |« }|S )aT
|
Similar to :meth:`http.client.HTTPResponse.read`, but with two additional
|
parameters: ``decode_content`` and ``cache_content``.
|
|
:param amt:
|
How much of the content to read. If specified, caching is skipped
|
because it doesn't make sense to cache partial content as the full
|
response.
|
|
:param decode_content:
|
If True, will attempt to decode the body based on the
|
'content-encoding' header.
|
|
:param cache_content:
|
If True, will save the returned data such that the same result is
|
returned despite of the state of the underlying file object. This
|
is useful if you want the ``.data`` property to continue working
|
after having ``.read()`` the file object. (Overridden if ``amt`` is
|
set.)
|
Nr Fr, ©r$ r( r" rL ) r rì rð r/ r% ri rY r¿ rÒ r rN rí rÁ )r& r
|
rì r Ú decoded_datar' r$ s r) r zHTTPResponse.read% sF ð4 ×ÑÔ Ø Ð !Ø !× 0Ñ 0Ná 37àCØ _Ø !Mà}} § ¡ ×!BÒ!BØ #||ØØ"Ø"'Ø "¤S¨×)=Ñ)=Ó%>Ñ >ð ,ó ð ×$Ñ$×(Ñ(¨ Ô6Ü4×'Ñ'Ó(¨CÒ/Ø×+Ñ+×/Ñ/°Ó4Ð4à~~cÓ"àt Ò>¨¨q©Ò(=¸°X ñ ÜD×(Ñ(Ó)¨QÒ.Ø]] t§}¡}×'HÒ'HàKà ;Ø<< n°mÓDDÙ Ø !
|
ðB ñ= "Ø×,Ò,Ü&ð@óð ð à <<ØØ Ø Ø ¤ T×%9Ñ%9Ó!:Ñ:ð (ó Lð × Ñ × $Ñ $ \Ô 2äd×*Ñ*Ó+¨cÒ1±dð ~~ cÓ*Ø #||ØØ"Ø!Ø "¤S¨×)=Ñ)=Ó%>Ñ >ð ,ó ð ×$Ñ$×(Ñ(¨ Ô6ô d×*Ñ*Ó+¨cÒ1²dð ×'Ñ'×+Ñ+¨CÓ0Dà r, c ór | | j }|r|dk rd}| j râ|s t d« | j rz| j j rd|t | j « |k rJ| j d|d||t | j « z
|
nd¬« }| j j |« t | j « dkD r7|| j j « S | j j |« S |dk( ry| j |d¬« }|r||S | j « | }| j ||||¬ « }| j j |« |s|rn| j d
|
d¬« }L|| j j « S | j j |« S ) a
|
Similar to ``http.client.HTTPResponse.read1`` and documented
|
in :meth:`io.BufferedReader.read1`, but with an additional parameter:
|
``decode_content``.
|
|
:param amt:
|
How much of the content to read.
|
|
:param decode_content:
|
If True, will attempt to decode the body based on the
|
'content-encoding' header.
|
Nr zaCalling read1(decode_content=False) is not supported after read1(decode_content=True) was called.r, Fr Tr| rL i ) rì rí rÁ rð r/ ri rY r% r¿ rÛ rÒ r r )r& r
|
rì r r' r$ s r) r zHTTPResponse.read1
s ð" Ð !Ø !× 0Ñ 0NÙ 37àCà × $Ò $Ù!Ü"ð=óð ð
|
ØMM×5Ò5Ø[¤C¨×(<Ñ(<Ó$=ÀÒ$Cà #||ØØ"Ø"'à;>¸?c $×"6Ñ"6Ó 7Ò7ÐPTð ,ó ð ×$Ñ$×(Ñ(¨ Ô6Ü4×'Ñ'Ó(¨1Ò,Ø;Ø ×/Ñ/×7Ñ7Ó9Ð9Ø×+Ñ+×/Ñ/°Ó4Ð4Ø !8Øð ~~c¨~Ó.Ù ØKà ×ÑÔ ØØ $HMØ <<Øn mÀð (ó Lð × Ñ × $Ñ $ \Ô 2Ù}ØØ>> $¨d>Ó3Dð ð ;Ø×'Ñ'×/Ñ/Ó1Ð 1Ø×#Ñ#×'Ñ'¨Ó,Ð,r, c # óú K | j r,| j « r | j ||¬« E d{ yt | j « r:t | j « dkD s"| j r| j j rm| j ||¬« }|r| t | j « s/t | j « dkD rH| j r| j j rkyyyy7 Ãw)a_
|
A generator wrapper for the read() method. A call will block until
|
``amt`` bytes have been read from the connection or until the
|
connection is closed.
|
|
:param amt:
|
How much of the content to read. The generator will return up to
|
much data per iteration, but may return less. This is particularly
|
likely when using compressed data. However, the empty string will
|
never be returned.
|
|
:param decode_content:
|
If True, will attempt to decode the body based on the
|
'content-encoding' header.
|
rJ Nr )r
|
rì )
|
rç Úsupports_chunked_readsr r rO ri rY rð r/ r )r& r
|
rì r' s r) r zHTTPResponse.streamË s è ø ð$ <<D× 7Ñ 7Ô 9Ø×(Ñ(¨¸^Ð(ÓL× LÑ Lô ! §¡Ô*Üt×+Ñ+Ó,¨qÒ0ØMM d§m¡m×&GÒ&Gàyy S¸ yÓHáØ Jô ! §¡Õ*Üt×+Ñ+Ó,¨qÓ0ØMM d§m¡m×&GÔ&GMÐ&GMð Mús" 3C;µC9¶BC;Â9C;Ã"C;Ã5C;c ó y)NTr@ r. s r) ÚreadablezHTTPResponse.readableë s Ør, c ó | j s t d« | j t d« | j t j
|
« y )Nz8Cannot shutdown socket as self._sock_shutdown is not setzCCannot shutdown as connection has already been released to the pool)rU r rT rÁ ÚsocketÚSHUT_RDr. s r) r zHTTPResponse.shutdownî sG Ø×"Ò"Ü Ð WÓXÐ XØ × Ñ Ð #Ü ØUóð ð ×ÑFNNÕ+r, c ó d | _ | j s&| j r| j j « | j r| j j « | j
|
s t j j | « y y r" )rU r rO r rT rM rÅ ÚIOBaser. s r) r zHTTPResponse.close÷ s\ Ø "Ôà{{txxØ HHNNÔ à × Ò Ø × Ñ × "Ñ "Ô $àÜ IIOODÕ !ð r, c ó@ | j s)t j j j | « S | j
|
yt | j
|
d« r| j
|
j « S t | j
|
d« r| j
|
j S y)NTrh r )rM rÅ r r Ú__get__rO ru rh r. s r) r zHTTPResponse.closed sq àÜ99×#Ñ#×+Ñ+¨DÓ1Ð 1Ø XXÐ ØÜ TXXzÔ *Ø88×$Ñ$Ó&Ð &Ü TXXxÔ (Ø88??Ð "àr, c ó¦ | j t d« t | j d« r| j j « S t d« )Nz-HTTPResponse has no file to get a fileno fromÚfilenozOThe file-like object this HTTPResponse is wrapped around has no file descriptor)rO rd ru r r. s r) r zHTTPResponse.fileno sI Ø 88Ð ÜÐIÓJÐ JÜ TXXxÔ (Ø88??Ó$Ð $äð0óð r, c ó® | j It | j d« r2t | j dd« s| j j « S y y y )Nr2 r F)rO ru r r2 r. s r) r2 zHTTPResponse.flush sJ à HHÐ Ü 'Ô*ÜDHH h°Ô6à88>>Ó#Ð #ð 7ð +ð !r, c ó. t | j d« S )a
|
Checks if the underlying file-like object looks like a
|
:class:`http.client.HTTPResponse` object. We do this by testing for
|
the fp attribute. If it is present we assume it returns raw chunks as
|
processed by read_chunked().
|
Úfp)ru rO r. s r) r z#HTTPResponse.supports_chunked_reads# s ô txx Ó&Ð&r, c ó$ | j y | j j j « }|j dd« d } t |d« | _ y # t $ r, | j « |r t | |« d t d« d w xY w)Nó ;r r rb zResponse ended prematurely)
|
rV rO r Úreadliner r7 r r r r )r& Úlines r) Ú_update_chunk_lengthz!HTTPResponse._update_chunk_length, s ð ??Ð &ØØxx{{×#Ñ#Ó%Øzz$ Ó" 1Ñ%ð LÜ ! $¨mDOøÜò LØ JJLÙä(¨¨tÓ4¸$Ð>ô $Ð$@ÓAÀtÐKð Lús ÁA Á5Bc ón d }|K| j j | j « }|}| j j d« d | _ |S | j B|| j k r3| j j |« }| j |z
|
| _ |}|S || j k( rA| j j |« }| j j d« d | _ |}|S | j j | j « }| j j d« d | _ |S )Nr[ )rO Ú
|
_safe_readrV )r& r
|
Úreturned_chunkrÎ Úvalues r) Ú _handle_chunkzHTTPResponse._handle_chunk> s Ø Ø ;ØHH×'Ñ'¨¯©Ó8EØ "NØ HH× Ñ Ô "Ø "DOð Ð ð __Ð (¨S°4·?±?Ò-BØHH×'Ñ'¨Ó,EØ "oo°Ñ 3DOØ "Nð Ð ð DOOÒ #ØHH×'Ñ'¨Ó,EØ HH× Ñ Ô "Ø "DOØ "Nð
|
Ð ð "XX× 0Ñ 0°· ± Ó ANØ HH× Ñ Ô "Ø "DOØ Ð r, c # ó¤ K | j « | j s t d« | j « s t d« | j « 5 | j r9t | j « r$| j j « ddd« y| j j
|
ddd« y|r|dk rd} | j r| j j rd}n1| j « | j dk( rn-| j |« }| j! ||d|¬« }|r| r|r| j# « }|r| | j :| j j j% « }|sn|dk( rn | j :| j r| j j « ddd« y# 1 sw Y yxY ww) aÆ
|
Similar to :meth:`HTTPResponse.read`, but with an additional
|
parameter: ``decode_content``.
|
|
:param amt:
|
How much of the content to read. If specified, caching is skipped
|
because it doesn't make sense to cache partial content as the full
|
response.
|
|
:param decode_content:
|
If True, will attempt to decode the body based on the
|
'content-encoding' header.
|
zHResponse is not chunked. Header 'transfer-encoding: chunked' is missing.zkBody should be http.client.HTTPResponse like. It should have have an fp attribute which returns raw chunks.Nr r, F)rì r$ r( s
|
)r rç r r r r{ rP r r rO r rð r/ r¤ rV r© r% r# r¢ )r& r
|
rì rÎ Údecodedr£ s r) r zHTTPResponse.read_chunkedT sà è ø ð ×ÑÔ à||Ü$ðBóð ð ×*Ñ*Ô,Ü*ðPóð ð
|
× Ñ Ó "ñ 5 0à×&Ò&Ô+>¸t×?VÑ?VÔ+WØ×'Ñ'×-Ñ-Ô/Ø÷ 5 0ð 5 0ð xx{{Ð"Ø÷5 0ð 5 0ñ sQwð àà== T§]¡]×%FÒ%FØ Eà×-Ñ-Ô/ب!Ò+Ø Ø × .Ñ .¨sÓ 3EØ ,,ØØ#1Ø"'Ø "ð 'ó ñ Ø!Mð! ñ$ ð ×-Ñ-Ó/ÙØ!Mð ((Ð&Øxx{{×+Ñ+Ó-ÙàØ7?Øð ((Ñ&ð ×&Ò&Ø×'Ñ'×-Ñ-Ô/÷k5 0÷ 5 0ñ 5 0üs= AGÁ=G GÂGÂ2 GÂ;CGÆ&GÆ; GÇG Ç Gc ó | j S )zÄ
|
Returns the URL that was the source of this response.
|
If the request that generated this response redirected, this method
|
will return the final redirect location.
|
©rî r. s r) rþ zHTTPResponse.url¨ s ð × Ñ Ð r, c ó || _ y r" r r s r) rþ zHTTPResponse.url± s
|
à Õr, c # ó. K g }| j d¬« D ]d }d|v rM|j d« }dj |« |d z dz |dd D ] }|dz |d r|d g}Qg }T|j |« f |rdj |« y y w)NTrJ ó
|
r, r r r4 )r r r r )r& r¹ rÎ ÚchunksÚxs r) Ú__iter__zHTTPResponse.__iter__µ s± è ø Ø Ø[[°[Ó5ò %EØ~Ø UÓ+ØhhvÓ&¨°©Ñ2°UÑ:Ò:Ø " ò $AØe)Oð$à":Ø $ Rj\Fà Fà eÕ$ð %ñ Ø((6Ó"Ó "ð ùs BB)rä Nr r zHTTP/?NTTNNNNNTNNTN)&rZ r rá r7 rè r7 ré r7 rê r¬ rë r8 r[ r: rì r: r\ z_HttplibHTTPResponse | Noner] zHTTPConnectionPool | Noner úHTTPConnection | NonerR z_HttplibHTTPMessage | Nonerâ r9 rL r: r^ r8 rñ r8 rM r: r_ z#typing.Callable[[int], None] | Noner8 rW rV r; )r8 r´ r9 rÜ )r^ r8 r8 r= )r8 ztyping.Generator[None]r" )r
|
r= r r: r8 r6 r@ rA rB rC r< )r
|
r= rì r> r8 ztyping.Generator[bytes])r
|
r= r8 r6 r: r; )r8 r? )"r< r= r> r rJ r r r? r' r rh rj rW r r{ r r r r r r r r r r r2 r r¤ r© r rþ rG r³ Ú __classcell__)r` s @r) r r ± sü ø ñ ðD ØRVØØØ &Ø !Ø $Ø #Ø9=Ø*.Ø,0Ø*.Ø $Ø'+Ø%)Ø"&Ø Ø=Að'>Bàð>Bð Pð>Bð ð >Bð
|
ð >Bð ð >Bð ð>Bð ð>Bð ð>Bð 7ð>Bð (ð>Bð *ð>Bð (ð>Bð ð >Bð !%ð >Bð #ð!>Bð" ð#>Bð$ ð%>Bð& ;ð'>Bð(
|
õ)>Bó@ ó ð òó ðð ò ó ð ó&ó#ó6ðp ò?$ó ð?$ðF ð7Nð ñ 7Nà ð7Nð ð 7Nð
|
|
ó 7Nðv ð2ð ñ 2à ð2ð ð 2ð
|
|
ó 2ðl Ø&*Ø #ð ^à ð^ð $ð^ð ð ^ð
|
|
ó ^ðD Ø&*ðD-à ðD-ð $ðD-ð
|
ó D-ðN FJð Ø ð Ø7Bð à ó ó@ó,ó
|
"ð ò
|
ó ð
|
ó ó$ó'óLó$ ð. EIðR0Ø ðR0Ø6AðR0à óR0ðh ò!ó ð!ð ZZò ó ð ÷#r, r )r³ r¬ r8 r )JÚ
|
__future__r r· rÅ rü rú Úloggingr r Útypingr| rG Ú
|
contextlibr Ú http.clientr Ú_HttplibHTTPMessager Ú_HttplibHTTPResponser rv Ú TYPE_CHECKINGÚ_base_connectionr Ú
|
brotlicffirs Ú ImportErrorrä r
|
r Ú _collectionsr r r r r Ú
|
exceptionsr r r r r r r r r r r Ú util.responser r Ú
|
util.retryr Úconnectionpoolr Ú getLoggerr< rp r rB rZ r` rp r Ú compressionr Ú backportsr² r r r rµ r rÞ r@ r, r) ú<module>rÉ s ðÝ "ã Û Û Û Û Û
|
Û Û Û Ý %Ý :Ý <Ý +à ×ÒÝ4ððÛ#õ Ý (Ý (ß CÑ C÷ ÷ ÷ ñ ÷ =Ý à ×ÒÝ2àg×ÑÓ!÷ $ñ $ô8!^ô 8!÷vñ ô =!.ô =!ð@
|
Ðô(ô (ðV9Ø
|
×Ñ7Ò"Þ$å"ð Hô/nô /ôd5B>ô 5Bóp ÷$Jñ JôZkryyô kô\S #Ð#õ S #øðu ò Þðûàò Ø Fðûðx ò ØHðús< ÁE Ã; E< Å E+Å'E. Å*E+Å+E. Å.E9Å8E9Å<FÆF
|
