U dd+ @sDddlZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z ddl m Z m Z mZddlmZmZmZmZmZmZddlmZdd lmZmZmZmZdd lmZmZm Z m!Z!dd l"m#Z#dd l$m%Z%dd l&m'Z'm(Z(ddl)m*Z*m+Z+ddl,m-Z-ddl.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mm?Z?m@Z@ddlAmBZBmCZCmDZDmEZEmFZFejGdddZHejGdddZIGdddZJeJZKeLdZMde ZNdOddePDZQGdd d ejRZSGd!d"d"e:ZTGd#d$d$e/ZUejVd%ejWfZXGd&d'd'ZYGd(ddeYZZGd)ddeYZ[dS)*N)asynccontextmanagercontextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth)DEFAULT_LIMITSDEFAULT_MAX_REDIRECTSDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)CookiesHeadersRequestResponse)codes) ASGITransport)AsyncBaseTransport BaseTransport)AsyncHTTPTransport HTTPTransport) WSGITransport)AsyncByteStream AuthTypes CertTypes CookieTypes HeaderTypes ProxiesTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesSyncByteStream TimeoutTypesURLTypes VerifyTypes)URL QueryParams)Timer URLPatternget_environment_proxiesis_https_redirect same_originTClient)boundU AsyncClientc@seZdZdZdS)UseClientDefaulta< For some parameters such as `auth=...` and `timeout=...` we need to be able to indicate the default "unset" state, in a way that is distinctly different to using `None`. The default "unset" state indicates that whatever default is set on the client should be used. This is different to setting `None`, which explicitly disables the parameter, possibly overriding a client default. For example we use `timeout=USE_CLIENT_DEFAULT` in the `request()` signature. Omitting the `timeout` parameter will send a request using whatever default timeout has been configured on the client. Including `timeout=None` will ensure no timeout is used. Note that user code shouldn't need to use the `USE_CLIENT_DEFAULT` constant, but it is used internally when a parameter is not included. N)__name__ __module__ __qualname____doc__r@r@1/tmp/pip-unpacked-wheel-fkuvgui5/httpx/_client.pyr;@sr;Zhttpxz python-httpx/z, cCsg|]}|dkr|qS)identityr@).0keyr@r@rA [srEc@seZdZdZdZdZdS) ClientStaterN)r<r=r>UNOPENEDOPENEDCLOSEDr@r@r@rArF_srFc@sFeZdZdZeeeddddZej e dddZ ddd d Z dS) BoundSyncStreamz A byte stream that is bound to a given response instance, and that ensures the `response.elapsed` is set once the response is closed. NstreamresponsetimerreturncCs||_||_||_dSN_stream _response_timerselfrNrOrPr@r@rA__init__sszBoundSyncStream.__init__rQccs|jD] }|VqdSrRrTrXchunkr@r@rA__iter__zs zBoundSyncStream.__iter__cCs(|j}tj|d|j_|jdSN)seconds)rVZ sync_elapseddatetime timedeltarUelapsedrTcloserXr`r@r@rArd~s zBoundSyncStream.close) r<r=r>r?r+rr1rYtypingIteratorbytesr^rdr@r@r@rArLms rLc@sFeZdZdZeeeddddZej e dddZ ddd d Z dS) BoundAsyncStreamz An async byte stream that is bound to a given response instance, and that ensures the `response.elapsed` is set once the response is closed. NrMcCs||_||_||_dSrRrSrWr@r@rArYszBoundAsyncStream.__init__rZcCs |j2z3dHW}|Vq6dSrRr[r\r@r@rA __aiter__szBoundAsyncStream.__aiter__cs4|jIdH}tj|d|j_|jIdHdSr_)rVZ async_elapsedrarbrUrcrTacloserer@r@rArkszBoundAsyncStream.aclose) r<r=r>r?r rr1rYrf AsyncIteratorrhrjrkr@r@r@rAris ri.c@seZdZddddededdddd ejeejeeje eje e e e ejejeejefee ejeejegeffd ddZee d d d Zee d d d ZeedddZejee ejeejefdddZee d ddZ!e!j"e ddddZ!eejeejefd ddZ#e#j"ejeejefddddZ#eeje$d ddZ%e%j"eddddZ%eed d d!Z&e&j"eddd"d!Z&ee'd d#d$Z(e(j"e dd%d&d$Z(ee)d d'd(Z*e*j"e dd)d*d(Z*ee+d d+d,Z,e,j"edd-d.d,Z,ddddddde-dd/ eeeje.eje/eje0ejej1ejeeje eje eje e2feje3e4d0 d1d2Z5eedd3d4Z6dMeje eje d)d5d6Z7dNeje eje d%d7d8Z8dOejeejed-d9d:Z9ejeeje$dd;d<Z:e-fe4ejee2dfe$d=d>d?Z;e4ee4esz-BaseClient._get_proxy_map..rzall://)r3items isinstancedictstrr/r)rXrr new_proxiesrDvalueproxyr@r@rA_get_proxy_maps zBaseClient._get_proxy_mapcCs|jSrR)rrr@r@rAruszBaseClient.timeout)rurQcCst||_dSrR)rr)rXrur@r@rAruscCs|jSrR)rrr@r@rArxszBaseClient.event_hooks)rxrQcCs(t|dgt|dgd|_dSr|)rrr)rXrxr@r@rArxscCs|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrr@r@rArqs zBaseClient.auth)rqrQcCs|||_dSrR)rrrXrqr@r@rArqscCs|jS)zK Base URL to use when sending requests with relative URLs. )rrr@r@rAry szBaseClient.base_urlcCs|t||_dSrR)r~r/rrr@r@rAryscCs|jS)z@ HTTP headers to include when sending requests. )_headersrr@r@rArsszBaseClient.headers)rsrQcCs2tdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rXrsZclient_headersr@r@rArss cCs|jS)zA Cookie values to include when sending requests. )rrr@r@rArt*szBaseClient.cookies)rtrQcCst||_dSrR)rr)rXrtr@r@rArt1scCs|jS)zO Query parameters to include in the URL when sending requests. )rrr@r@rArr5szBaseClient.params)rrrQcCst||_dSrR)r0r)rXrrr@r@rArr<s) contentdatafilesjsonrrrsrtru extensions) methodrrrrrrrrsrtrurrQc Cs||}||}|| } ||}| dkr4in| } d| krnt| trP|jnt| } tf| d| i} t ||||||||| | d S)aJ Build and return a request instance. * The `params`, `headers` and `cookies` arguments are merged with any values set on the client. * The `url` argument is merged with any `base_url` set on the client. See also: [Request instances][0] [0]: /advanced/#request-instances Nru)rrrrrrrsrtr) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr;rurrZas_dictr) rXrrrrrrrrrsrtrurr@r@rA build_request@s.    zBaseClient.build_requestcCs4t|}|jr0|jj|jd}|jj|dS|S)z Merge a URL argument together with any 'base_url' on the client, to create the URL used for the outgoing request. rr)r/is_relative_urlryrlstripr)rXrZ merge_urlZmerge_raw_pathr@r@rArss  zBaseClient._merge_urlcCs&|s |jr"t|j}|||S|S)z Merge a cookies argument together with any cookies on the client, to create the cookies used for the outgoing request. )rtrr)rXrtmerged_cookiesr@r@rArs    zBaseClient._merge_cookiescCst|j}|||S)z Merge a headers argument together with any headers on the client, to create the headers used for the outgoing request. )rrsr)rXrsZmerged_headersr@r@rArs  zBaseClient._merge_headerscCs"|s |jrt|j}||S|S)z Merge a queryparams argument together with any queryparams on the client, to create the queryparams used for the outgoing request. )rrr0merge)rXrrZmerged_queryparamsr@r@rArs   zBaseClient._merge_queryparamscCs\|dkr dSt|tr*t|d|ddSt|tr8|St|rJt|dStd|dS)Nrrusernamepassword)funczInvalid "auth" argument: )rtuplerrcallabler TypeErrorrr@r@rArs   zBaseClient._build_auth)r}rqrQcCsRt|tr|jn||}|dk r&|S|jj|jj}}|s@|rLt||dStS)Nr) rr;rrrrrrr)rXr}rqrrr@r@rA_build_request_auths zBaseClient._build_request_auth)r}rOrQcCsR|||}|||}||||}|||}t|j}t||||||jdS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrrsrtrNr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrtrr)rXr}rOrrrsrNrtr@r@rA_build_redirect_requests    z"BaseClient._build_redirect_requestcCsR|j}|jtjkr|dkrd}|jtjkr6|dkr6d}|jtjkrN|dkrNd}|S)z When being redirected we may want to change the method of the request based on certain specs or browser behavior. HEADGETPOST)r status_coder SEE_OTHERFOUNDMOVED_PERMANENTLY)rXr}rOrr@r@rArszBaseClient._redirect_methodc Cs|jd}z t|}Wn8tk rN}ztd|d|ddW5d}~XYnX|jrl|jsl|j|jjd}|jr~|j |}|jj r|j s|j|jj d}|S)z< Return the URL for the redirect to follow. ZLocationz Invalid URL in location header: .r}N)host)fragment) rsr/rrschemerrrrjoinr)rXr}rOlocationrexcr@r@rArs"     zBaseClient._redirect_url)r}rrrQcCsxt|j}t||js>t|j|s.|dd|jd|d<||jkrh|dkrh|dd|dd|dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rrsr5rr4popnetlocdecoder)rXr}rrrsr@r@rArs       zBaseClient._redirect_headers)r}rrQcCs||jkr|dkrdS|jS)zO Return the body that should be used for the redirect request. rN)rrN)rXr}rr@r@rAr-szBaseClient._redirect_stream)N)N)N)Dr<r=r>r r rfOptionalr!r&r$r#r,boolintMappingrList EventHookr-UnionCallablerhrYpropertyrrzr/r~r%Dictrrrrusetterrxrrqryrrsrrtr0rrUSE_CLIENT_DEFAULTr'r(r*Anyr;r)rrrrrrrrrrrrrr+r rr@r@r@rArms $       3    rmcseZdZdZddddddddddedeedddddddeje eje eje eje e ejeeeejeejejeefeeeeejejeejefeejeejejdejfeejeejegeffdfd d Zddddedddfe ejeeeeejeejejdejfeed d d Zddddedfe e ejeeeeeedddZ!e"edddZ#ddddddde$e$e$dd eeeje%eje&eje'ejejeje eje eje eje e(dfejee(fejee(feje)e*dddZ+e,ddddddde$e$e$dd eeeje%eje&eje'ejejeje eje eje eje e(dfejee(fejee(feje)ej-e*dddZ.de$e$de/eeje e(dfejee(fe*dddZ0e/e1eeje*e*ddd Z2e/eeje*e*d!d"d#Z3e/e*d$d%d&Z4ddde$e$e$dd'eeje eje eje eje e(fejee(fejee(feje)e*d( d)d*Z5ddde$e$e$dd'eeje eje eje eje e(fejee(fejee(feje)e*d( d+d,Z6ddde$e$e$dd'eeje eje eje eje e(fejee(fejee(feje)e*d( d-d.Z7ddddddde$e$e$dd eeje%eje&eje'ejejeje eje eje eje e(fejee(fejee(feje)e*d/ d0d1Z8ddddddde$e$e$dd eeje%eje&eje'ejejeje eje eje eje e(fejee(fejee(feje)e*d/ d2d3Z9ddddddde$e$e$dd eeje%eje&eje'ejejeje eje eje eje e(fejee(fejee(feje)e*d/ d4d5Z:ddde$e$e$dd'eeje eje eje eje e(fejee(fejee(feje)e*d( d6d7Z;dd8d9d:ZdAejej?e@eje@ejeAdd>d?d@ZBZCS)Br7a An HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between threads. Usage: ```python >>> client = httpx.Client() >>> response = client.get('https://example.org') ``` **Parameters:** * **auth** - *(optional)* An authentication class to use when sending requests. * **params** - *(optional)* Query parameters to include in request URLs, as a string, dictionary, or sequence of two-tuples. * **headers** - *(optional)* Dictionary of HTTP headers to include when sending requests. * **cookies** - *(optional)* Dictionary of Cookie items to include when sending requests. * **verify** - *(optional)* SSL certificates (a.k.a CA bundle) used to verify the identity of requested hosts. Either `True` (default CA bundle), a path to an SSL certificate file, an `ssl.SSLContext`, or `False` (which will disable verification). * **cert** - *(optional)* An SSL certificate used by the requested host to authenticate the client. Either a path to an SSL certificate file, or two-tuple of (certificate file, key file), or a three-tuple of (certificate file, key file, password). * **proxies** - *(optional)* A dictionary mapping proxy keys to proxy URLs. * **timeout** - *(optional)* The timeout configuration to use when sending requests. * **limits** - *(optional)* The limits configuration to use. * **max_redirects** - *(optional)* The maximum number of redirect responses that should be followed. * **base_url** - *(optional)* A URL to use as the base when building request URLs. * **transport** - *(optional)* A transport class to use for sending requests over the network. * **app** - *(optional)* An WSGI application to send requests to, rather than sending actual network requests. * **trust_env** - *(optional)* Enables or disables usage of environment variables for configuration. * **default_encoding** - *(optional)* The default encoding to use for decoding response text, if no charset information is included in a response Content-Type header. Set to a callable for automatic character set detection. Default: "utf-8". NTFrnrorqrrrsrtverifycerthttp1http2rmountsrurvlimitsrwrxry transportapprzr{.c stj||||| | ||||d rRz ddl}Wntk rPtddYnXod|dkod|dk}| |}j||d_fdd|D_| dk rԈj dd| Dt t j_dS)NrpruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.rrrrrrrrzc s:i|]2\}}t||dkrdnj|dqSNrrrrrrzr2_init_proxy_transportrCrDrrrrrrXrzrr@rArs z#Client.__init__..cSsi|]\}}t||qSr@r2rCrDrr@r@rArs superrYh2 ImportErrorr_init_transport _transportr_mountsrrsortedrXrqrrrsrtrrrrrrrurvrrwrxryrrrzr{rrZ proxy_map __class__rrArYlsT    zClient.__init__ rrrrrrrrzrQc Cs2|dk r |S|dk rt|dSt||||||dSN)rr)rr rXrrrrrrrrzr@r@rArs  zClient._init_transportrrrrrrrzrQc Cst|||||||dS)N)rrrrrrzr)rrXrrrrrrrzr@r@rArs zClient._init_proxy_transportrcCs:|jD](\}}||r |dkr*|jn|Sq |jSz Returns the transport instance that should be used for a given URL. This will either be the standard connection pool, or a proxy. NrrmatchesrrXrpatternrr@r@rA_transport_for_urls zClient._transport_for_url rrrrrrrsrtrqrvrurrrrrrrrrrsrtrqrvrurrQc  CsH| dk rd}t|t|j||||||||| | | d }|j|| | dS)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = client.send(request, ...) ``` See `Client.build_request()`, `Client.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/#merging-of-configuration NzSetting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead. rrrrrrrrrsrtrurrqrv)warningswarnDeprecationWarningrsend)rXrrrrrrrrrsrtrqrvrurmessager}r@r@rAr}s$!  zClient.requestc  csL|j||||||||| | | d }|j|| | dd}z |VW5|XdSa  Alternative to `httpx.request()` that streams the response body instead of loading it into memory at once. **Parameters**: See `httpx.request`. See also: [Streaming Responses][0] [0]: /quickstart#streaming-responses rT)r}rqrvrNN)rrrdrXrrrrrrrrrsrtrqrvrurr}rOr@r@rArN0s,  z Client.streamrNrqrvr}rNrqrvrQc Cs|jtjkrtdtj|_t|tr,|jn|}|||}|j |||gd}z|s\| |WSt k r}z| |W5d}~XYnXdS)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `Client.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/#request-instances 5Cannot send a request, as the client has been closed.rqrvhistoryN) rrFrK RuntimeErrorrJrr;rvr_send_handling_authread BaseExceptionrdrXr}rNrqrvrOrr@r@rArds*  z Client.sendr}rqrvrrQc Cs||}zt|}|j|||d}zRz||}Wntk rR|YWW\SXt||_||}| |Wqt k r}z||W5d}~XYqXqW5|XdSN)rvr) Zsync_auth_flowrdnext_send_handling_redirectsr StopIterationrrr!appendr" rXr}rqrvrZ auth_flowrO next_requestrr@r@rAr s*  zClient._send_handling_authr}rvrrQc Cst||jkrtd|d|jdD] }||q$||}zb|jdD] }||qHt||_|jsl|WS|||}||g}|r| n ||_ |WSWqt k r}z| |W5d}~XYqXqdSNz#Exceeded maximum allowed redirects.rr}rO) lenrwrr_send_single_requestrrhas_redirect_locationrr!r+r"rdrXr}rvrhookrOrr@r@rAr's.        zClient._send_handling_redirectsr}rQc Cs||j}t}|t|jts.tdt|d| |}W5QRXt|jts^t ||_ t |j||d|_|j ||j|_td|j|j|j|j|j|S)L Sends a single request, without handling any redirections. z?Attempted to send an async request with a sync Client instance.rrOrPzHTTP Request: %s %s "%s %d %s")rrr1Z sync_startrrNr+rrhandle_requestAssertionErrorr}rLrtextract_cookiesrr{loggerinfor http_versionr reason_phrase)rXr}rrPrOr@r@rAr/s6     zClient._send_single_requestrrrsrtrqrvrur rrrrsrtrqrvrurrQc Cs|jd||||||||d S)U Send a `GET` request. **Parameters**: See `httpx.request`. rr=r rXrrrrsrtrqrvrurr@r@rArsz Client.getc Cs|jd||||||||d S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSr=rr@r@r@rAoptionsszClient.optionsc Cs|jd||||||||d S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rr=rr@r@r@rAhead:sz Client.head rrrrrrrrsrtrqrvrurrQc Cs$|jd||||||||| | | | d S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrr rXrrrrrrrrsrtrqrvrurr@r@rApostWsz Client.postc Cs$|jd||||||||| | | | d S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrrrHr@r@rAput|sz Client.putc Cs$|jd||||||||| | | | d S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrrrHr@r@rApatchsz Client.patchc Cs|jd||||||||d S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETEr=rr@r@r@rAdeletesz Client.deleterZcCsB|jtjkr>tj|_|j|jD]}|dk r(|q(dSz. Close transport and proxies. N)rrFrKrrdrvalues)rXrr@r@rArds   z Client.closerXrQcCs`|jtjkr*tjdtjdi|j}t|tj|_|j|j D]}|dk rF|qF|SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrFrIrJrKrr __enter__rrT)rXmsgrr@r@rArWs   zClient.__enter__exc_type exc_value tracebackrQcCsBtj|_|j||||jD]}|dk r"||||q"dSrR)rFrKrr__exit__rrT)rXrZr[r\rr@r@rAr]s zClient.__exit__)NNN)Dr<r=r>r?r r r rfrr!r&r$r#r.r"rr%rrrr,r rrrr-rrrrhrYrrrr/rrr'r(r*r;r)rr}rrgrNrrrr r'r/rrCrErIrLrOrRrdr6rWTyper"rr] __classcell__r@r@rrAr79s~5U      8   7  3 $ %(    !    !    !     )     )     )     cseZdZdZddddddddddedeedddddddeje eje eje eje e ejeeeejeejejeefeeeeejejeejejdejffeejeejejdejfeejeejegeffdfd d Zddddedddfe ejeeeeejeejejdejfeed d d Zddddedfee ejeeeeeedddZ e!edddZ"ddddddde#e#e#dd eeeje$eje%eje&ejejeje eje eje eje e'dfejee'fejee'feje(e)dddZ*e+ddddddde#e#e#dd eeeje$eje%eje&ejejeje eje eje eje e'fejee'fejee'feje(ej,e)dddZ-de#e#de.eeje e'dfejee'fe)dddZ/e.e0eeje)e)ddd Z1e.eeje)e)d!d"d#Z2e.e)d$d%d&Z3ddde#e#e#dd'eeje eje eje eje e'dfejee'fejee'feje(e)d( d)d*Z4ddde#e#e#dd'eeje eje eje eje e'fejee'fejee'feje(e)d( d+d,Z5ddde#e#e#dd'eeje eje eje eje e'fejee'fejee'feje(e)d( d-d.Z6ddddddde#e#e#dd eeje$eje%eje&ejejeje eje eje eje e'fejee'fejee'feje(e)d/ d0d1Z7ddddddde#e#e#dd eeje$eje%eje&ejejeje eje eje eje e'fejee'fejee'feje(e)d/ d2d3Z8ddddddde#e#e#dd eeje$eje%eje&ejejeje eje eje eje e'fejee'fejee'feje(e)d/ d4d5Z9ddde#e#e#dd'eeje eje eje eje e'fejee'fejee'feje(e)d( d6d7Z:dd8d9d:Z;ee?eje?eje@dd>d?d@ZAZBS)Br:aC An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. Usage: ```python >>> async with httpx.AsyncClient() as client: >>> response = await client.get('https://example.org') ``` **Parameters:** * **auth** - *(optional)* An authentication class to use when sending requests. * **params** - *(optional)* Query parameters to include in request URLs, as a string, dictionary, or sequence of two-tuples. * **headers** - *(optional)* Dictionary of HTTP headers to include when sending requests. * **cookies** - *(optional)* Dictionary of Cookie items to include when sending requests. * **verify** - *(optional)* SSL certificates (a.k.a CA bundle) used to verify the identity of requested hosts. Either `True` (default CA bundle), a path to an SSL certificate file, an `ssl.SSLContext`, or `False` (which will disable verification). * **cert** - *(optional)* An SSL certificate used by the requested host to authenticate the client. Either a path to an SSL certificate file, or two-tuple of (certificate file, key file), or a three-tuple of (certificate file, key file, password). * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxies** - *(optional)* A dictionary mapping HTTP protocols to proxy URLs. * **timeout** - *(optional)* The timeout configuration to use when sending requests. * **limits** - *(optional)* The limits configuration to use. * **max_redirects** - *(optional)* The maximum number of redirect responses that should be followed. * **base_url** - *(optional)* A URL to use as the base when building request URLs. * **transport** - *(optional)* A transport class to use for sending requests over the network. * **app** - *(optional)* An ASGI application to send requests to, rather than sending actual network requests. * **trust_env** - *(optional)* Enables or disables usage of environment variables for configuration. * **default_encoding** - *(optional)* The default encoding to use for decoding response text, if no charset information is included in a response Content-Type header. Set to a callable for automatic character set detection. Default: "utf-8". NTFrnror.c stj||||| | ||||d rRz ddl}Wntk rPtddYnXod|dkod|dk}| |}j||d_fdd|D_| dk rԈj dd| Dt t j_dS)Nrprrrc s:i|]2\}}t||dkrdnj|dqSrrrrr@rArs z(AsyncClient.__init__..cSsi|]\}}t||qSr@rrr@r@rArsrrrrrArYAsT    zAsyncClient.__init__rc Cs2|dk r |S|dk rt|dSt||||||dSr)rrrr@r@rArs  zAsyncClient._init_transportrcCst||||||dS)N)rrrrrzr)rrr@r@rArs z!AsyncClient._init_proxy_transportrcCs:|jD](\}}||r |dkr*|jn|Sq |jSr r r r@r@rArs zAsyncClient._transport_for_urlrrc  s6|j||||||||| | | d }|j|| | dIdHS)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = await client.send(request, ...) ``` See `AsyncClient.build_request()`, `AsyncClient.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/#merging-of-configuration rrN)rr)rXrrrrrrrrrsrtrqrvrurr}r@r@rAr}s! zAsyncClient.requestc  CsX|j||||||||| | | d }|j|| | ddIdH}z |VW5|IdHXdSr)rrrkrr@r@rArNs,   zAsyncClient.streamrrc s|jtjkrtdtj|_t|tr,|jn|}|||}|j |||gdIdH}z|sh| IdH|WSt k r}z| IdH|W5d}~XYnXdS)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `AsyncClient.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/#request-instances rrN) rrFrKrrJrr;rvrr areadr"rkr#r@r@rAr0s*   zAsyncClient.sendr$c s||}z|IdH}|j|||dIdH}z^z||IdH}Wntk rd|YWWhSXt||_|IdH|}| |Wqt k r}z|IdH|W5d}~XYqXqW5|IdHXdSr%) Zasync_auth_flowrk __anext__r'asendStopAsyncIterationrrr`r)r"r*r@r@rAr as*   zAsyncClient._send_handling_authr,c st||jkrtd|d|jdD]}||IdHq$||IdH}zn|jdD]}||IdHqTt||_|js~|WS|||}||g}|r| IdHn ||_ |WSWqt k r}z| IdH|W5d}~XYqXqdSr-) r.rwrrr/rrr0rr`r+r"rkr1r@r@rAr's.    z$AsyncClient._send_handling_redirectsr3c s||j}t}|IdHt|jts4tdt|d| |IdH}W5QRXt|jtsjt ||_ t |j||d|_|j ||j|_|jd|j}|jd|}td|j|j||S)r4Nz?Attempted to send an sync request with an AsyncClient instance.rr5 zHTTP Request: %s %s "%s")rrr1Z async_startrrNr rrZhandle_async_requestr7r}rirtr8rr{rr<r;r9debugr)rXr}rrPrOstatusZ response_liner@r@rAr/s6    z AsyncClient._send_single_requestr=r>c s"|jd||||||||d IdHS)r?rr=Nrr@r@r@rArszAsyncClient.getc s"|jd||||||||d IdHS)rArBr=Nrr@r@r@rArCszAsyncClient.optionsc s"|jd||||||||d IdHS)rDrr=Nrr@r@r@rArEszAsyncClient.headrFc s*|jd||||||||| | | | d IdHS)rGrrNrrHr@r@rArI szAsyncClient.postc s*|jd||||||||| | | | d IdHS)rJrKrNrrHr@r@rArLEszAsyncClient.putc s*|jd||||||||| | | | d IdHS)rMrNrNrrHr@r@rArOjszAsyncClient.patchc s"|jd||||||||d IdHS)rPrQr=Nrr@r@r@rArRszAsyncClient.deleterZcsN|jtjkrJtj|_|jIdH|jD]}|dk r.|IdHq.dSrS)rrFrKrrkrrT)rXrr@r@rArks  zAsyncClient.acloserUcsl|jtjkr*tjdtjdi|j}t|tj|_|jIdH|j D]}|dk rL|IdHqL|SrV) rrFrIrJrKrr __aenter__rrT)rXrXrr@r@rArgs zAsyncClient.__aenter__rYcsNtj|_|j|||IdH|jD] }|dk r(||||IdHq(dSrR)rFrKrr __aexit__rrT)rXrZr[r\rr@r@rArhs zAsyncClient.__aexit__)NNN)Cr<r=r>r?r r r rfrr!r&r$r#r.r"rr%rrrr,r rrrrr-rrhrYrrrr/rrr'r(r*r;r)rr}rrlrNrrrr r'r/rrCrErIrLrOrRrkr9rgr^r"rrhr_r@r@rrAr: s~6U      0    7  3 $ &$   !    !    !     )     )     )     )\raenumloggingrfr contextlibrrtypesrrrrrr _configr r r r rr _decodersr _exceptionsrrrrZ_modelsrrrrZ _status_codesrZ_transports.asgirZ_transports.baserrZ_transports.defaultrrZ_transports.wsgir_typesr r!r"r#r$r%r&r'r(r)r*r+r,r-r.Z_urlsr/r0_utilsr1r2r3r4r5TypeVarr6r9r;r getLoggerr9rrkeysrEnumrFrLrirrrrmr7r:r@r@r@rAsX       D   Y