o h; @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@C/var/www/html/ai/venv/lib/python3.10/site-packages/httpx/_client.pyr;@sr;httpxz python-httpx/z, cCsg|]}|dkr|qS)identityr@).0keyr@r@rA [srFc@seZdZdZdZdZdS) ClientStaterN)r<r=r>UNOPENEDOPENEDCLOSEDr@r@r@rArG_srGc@HeZdZdZdedededdfddZdej e fd d Z d d 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. streamresponsetimerreturnNcC||_||_||_dSN_stream _response_timerselfrOrPrQr@r@rA__init__s zBoundSyncStream.__init__ccs|jD]}|VqdSrTrVrZchunkr@r@rA__iter__zs zBoundSyncStream.__iter__cCs(|j}tj|d|j_|jdSN)seconds)rX sync_elapseddatetime timedeltarWelapsedrVcloserZrbr@r@rArg~s zBoundSyncStream.closerRN) r<r=r>r?r+rr1r[typingIteratorbytesr`rgr@r@r@rArNm rNc@rM)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. rOrPrQrRNcCrSrTrUrYr@r@rAr[r\zBoundAsyncStream.__init__cCs"|j2z 3dHW}|Vq6dSrTr]r^r@r@rA __aiter__szBoundAsyncStream.__aiter__cs6|jIdH}tj|d|j_|jIdHdSra)rX async_elapsedrdrerWrfrVacloserhr@r@rArqszBoundAsyncStream.acloseri) r<r=r>r?r rr1r[rj AsyncIteratorrlrorqr@r@r@rArnrmrn.c@seZdZddddededdddd dejedejed eje d eje d e d e d e dejejeejefdede dejeejegeffddfddZede fddZede fddZdedefddZdejede dejeejeffddZede fd d!Z!e!j"d e ddfd"d!Z!edejeejeffd#d$Z#e#j"dejeejefddfd%d$Z#edeje$fd&d'Z%e%j"deddfd(d'Z%edefd)d*Z&e&j"deddfd+d*Z&ede'fd,d-Z(e(j"d e ddfd.d-Z(ede)fd/d0Z*e*j"d e ddfd1d0Z*ede+fd2d3Z,e,j"deddfd4d3Z,ddddddde-dd5 d6eded7eje.d8eje/d9eje0d:ejej1dejed eje d eje d eje e2fd;eje3de4fdd?Z6 dVd eje deje fd@dAZ7 dVd eje deje fdBdCZ8 dVdejedejefdDdEZ9dejedeje$fdFdGZ:e-fdHe4dejee2dfde$fdIdJZ;dHe4dKedHe4dKesz-BaseClient._get_proxy_map..rzall://)r3items isinstancedictstrr/r)rZrr new_proxiesrEvalueproxyr@r@rA_get_proxy_maps zBaseClient._get_proxy_mapcCrrT)rrr@r@rAr{rzBaseClient.timeoutcCt||_dSrT)rr)rZr{r@r@rAr{cCrrT)rrr@r@rAr~rzBaseClient.event_hookscCs(t|dgt|dgd|_dSr)rrr)rZr~r@r@rAr~s cCr)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrr@r@rArws zBaseClient.authcCs|||_dSrT)rrrZrwr@r@rArwscCr)zK Base URL to use when sending requests with relative URLs. )rrr@r@rAr zBaseClient.base_urlcCs|t||_dSrT)rr/rrr@r@rArscCr)z@ HTTP headers to include when sending requests. )_headersrr@r@rAryrzBaseClient.headerscCs2tdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rZryclient_headersr@r@rArys  cCr)zA Cookie values to include when sending requests. )rrr@r@rArz*rzBaseClient.cookiescCrrT)rr)rZrzr@r@rArz1rcCr)zO Query parameters to include in the URL when sending requests. )rrr@r@rArx5rzBaseClient.paramscCrrT)r0r)rZrxr@r@rArx<r) contentdatafilesjsonrxryrzr{ extensionsmethodrrrrrc Cs||}||}|| } ||}| durin| } d| vr9t| tr(|jnt| } tdi| 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 Nr{)rrrrrxryrzrr@) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr;r{rras_dictr) rZrrrrrrrxryrzr{rr@r@rA build_request@s.    zBaseClient.build_requestcCs4t|}|jr|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_urlrrlstripr)rZr merge_urlmerge_raw_pathr@r@rArss  zBaseClient._merge_urlcCs&|s|jrt|j}|||S|S)z Merge a cookies argument together with any cookies on the client, to create the cookies used for the outgoing request. )rzrr)rZrzmerged_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. )rryr)rZrymerged_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. )rxr0merge)rZrxmerged_queryparamsr@r@rArs   zBaseClient._merge_queryparamscCsX|durdSt|trt|d|ddSt|tr|St|r%t|dStd|)Nrrusernamepassword)funczInvalid "auth" argument: )rtuplerrcallabler TypeErrorrr@r@rArs   zBaseClient._build_authrcCsRt|tr|jn||}|dur|S|jj|jj}}|s |r&t||dStS)Nr) rr;rrrrrrr)rZrrwrrr@r@rA_build_request_auths zBaseClient._build_request_authrPcCsR|||}|||}||||}|||}t|j}t||||||jdS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrryrzrOr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrzrr)rZrrPrrryrOrzr@r@rA_build_redirect_requests    z"BaseClient._build_redirect_requestcCsR|j}|jtjkr|dkrd}|jtjkr|dkrd}|jtjkr'|dkr'd}|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)rZrrPrr@r@rArszBaseClient._redirect_methodc Cs|jd}zt|}Wnty"}z td|d|ddd}~ww|jr1|js1|j|jjd}|jr:|j |}|jj rI|j sI|j|jj d}|S)z< Return the URL for the redirect to follow. Locationz Invalid URL in location header: .rN)host)fragment) ryr/rrschemerrrrjoinr)rZrrPlocationrexcr@r@rArs$     zBaseClient._redirect_urlcCsxt|j}t||jst|j|s|dd|jd|d<||jkr4|dkr4|dd|dd|dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rryr5rr4popnetlocdecoder)rZrrrryr@r@rArs       zBaseClient._redirect_headerscCs||jkr |dkr dS|jS)zO Return the body that should be used for the redirect request. rN)rrO)rZrrr@r@rAr-szBaseClient._redirect_streamrT)Dr<r=r>r r rjOptionalr!r&r$r#r,boolintMappingrList EventHookr-UnionCallablerlr[propertyrrr/rr%Dictrrrr{setterr~rrwrrryrrzr0rxUSE_CLIENT_DEFAULTr'r(r*Anyr;r)rrrrrrrrrrrrrr+r rr@r@r@rArss8    $            3      rsc-seZdZdZddddddddddedeeddddddddeje d eje d eje d eje d e d ejedededejedejejeefdededededejejeejefdedejedejejdejfdedejeejegeffddf*fddZddddedddfd e d ejededededejedejejdejfdedefd d!Zddddedfd"e d e d ejedededededefd#d$Z!d%e"defd&d'Z#ddddddde$e$e$dd( d)ed%ed*eje%d+eje&d,eje'd-ejejd eje d eje d eje deje e(dfdejee(fdejee(fd.eje)de*fd/d0Z+e,ddddddde$e$e$dd( d)ed%ed*eje%d+eje&d,eje'd-ejejd eje d eje d eje deje e(dfdejee(fdejee(fd.eje)dej-e*fd1d2Z.de$e$d3d4e/d5edeje e(dfdejee(fde*f d6d7Z0d4e/de1ded8eje*de*f d9d:Z2d4e/ded8eje*de*fd;d<Z3d4e/de*fd=d>Z4ddde$e$e$dd?d%ed eje d eje d eje deje e(fdejee(fdejee(fd.eje)de*fd@dAZ5ddde$e$e$dd?d%ed eje d eje d eje deje e(fdejee(fdejee(fd.eje)de*fdBdCZ6ddde$e$e$dd?d%ed eje d eje d eje deje e(fdejee(fdejee(fd.eje)de*fdDdEZ7ddddddde$e$e$dd( d%ed*eje%d+eje&d,eje'd-ejejd eje d eje d eje deje e(fdejee(fdejee(fd.eje)de*fdFdGZ8ddddddde$e$e$dd( d%ed*eje%d+eje&d,eje'd-ejejd eje d eje d eje deje e(fdejee(fdejee(fd.eje)de*fdHdIZ9ddddddde$e$e$dd( d%ed*eje%d+eje&d,eje'd-ejejd eje d eje d eje deje e(fdejee(fdejee(fd.eje)de*fdJdKZ:ddde$e$e$dd?d%ed eje d eje d eje deje e(fdejee(fdejee(fd.eje)de*fdLdMZ;dXdNdOZ   dYdSejej?e@dTeje@dUejeAddfdVdWZBZCS)Zr7a 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". NTFrtrurwrxryrzverifycerthttp1http2rmountsr{r|limitsr}r~r transportapprrrwrxryrzrrrrrrr{r|rr}r~rrr.rrrRc tj||||| | ||||d r&zddl}Wn ty%tddwo/|duo/|du}| |}j||d_fdd|D_| durgj dd| Dt t j_dS)NrvruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.rrrrrrrrc :i|]\}}t||durdn j|dqSNrrrrrrr2_init_proxy_transportrDrErrrrrrZrrr@rAr z#Client.__init__..cSi|] \}}t||qSr@r2rDrErr@r@rAr superr[h2 ImportErrorr_init_transport _transportr_mountsrrsortedrZrwrxryrzrrrrrrr{r|rr}r~rrrrrrr proxy_map __class__r rAr[lsV     zClient.__init__c C2|dur|S|durt|dSt||||||dSN)rr)rr rZrrrrrrrrr@r@rAr  zClient._init_transportrc Cst|||||||dS)N)rrrrrrr)rrZrrrrrrrr@r@rArs zClient._init_proxy_transportrcC>|jD]\}}||r|dur|jS|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. NrrmatchesrrZrpatternrr@r@rA_transport_for_url  zClient._transport_for_url rrrrrxryrzrwr|r{rrrrrrrc  CsH| dur d}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. rrrrrrrxryrzr{rrwr|)warningswarnDeprecationWarningrsend)rZrrrrrrrxryrzrwr|r{rmessagerr@r@rArs$!  zClient.requestc  csT|j||||||||| | | d }|j|| | dd}z |VW|dS|wa  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 r)T)rrwr|rON)rr.rgrZrrrrrrrxryrzrwr|r{rrrPr@r@rArO0s. z Client.streamrOrwr|rrOc Cs|jtjkr tdtj|_t|tr|jn|}|||}|j |||gd}z |s.| |WSt yB}z| |d}~ww)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.rwr|historyN) rrGrL RuntimeErrorrKrr;r|r_send_handling_authread BaseExceptionrgrZrrOrwr|rPrr@r@rAr.ds.  z Client.sendr5c Cs||}zLt|} |j|||d}z+z||}Wnty,|YWW|Swt||_||}| |Wnt yP}z||d}~wwq |wNT)r|r5) sync_auth_flownext_send_handling_redirectsr. StopIterationrgrr5r8appendr9 rZrrwr|r5 auth_flowrP next_requestrr@r@rAr7s6      zClient._send_handling_authc Cs t||jkrtd|d|jdD]}||q||}z1|jdD]}||q%t||_|js7|WS|||}||g}|rI| n||_ |WSWnt yb}z| |d}~wwqNTz#Exceeded maximum allowed redirects.rrrP) lenr}rr_send_single_requestrr5has_redirect_locationrr8rCr9rgrZrr|r5hookrPrr@r@rAr>s6       zClient._send_handling_redirectscCs||j}t}|t|jtstdt|d | |}Wdn1s,wYt|jts9J||_ 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.rNrPrQHTTP Request: %s %s "%s %d %s")r&rr1 sync_startrrOr+r6rhandle_requestrrNrzextract_cookiesrrloggerinfor http_versionr reason_phraserZrrrQrPr@r@rArFs4      zClient._send_single_requestrxryrzrwr|r{rc C|jd||||||||d S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrUr rZrrxryrzrwr|r{rr@r@rArz Client.getc CrV)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrUrrXr@r@rAoptionsrYzClient.optionsc CrV)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrUrrXr@r@rAhead:rYz Client.headc C$|jd||||||||| | | | d S)V Send a `POST` request. **Parameters**: See `httpx.request`. rr(r rZrrrrrrxryrzrwr|r{rr@r@rApostWz Client.postc Cr_)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTr(rrar@r@rAput|rcz Client.putc Cr_)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHr(rrar@r@rApatchrcz Client.patchc CrV)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErUrrXr@r@rAdeleterYz Client.deletecCsF|jtjkrtj|_|j|jD] }|dur|qdSdSz. Close transport and proxies. N)rrGrLrrgrvalues)rZrr@r@rArgs  z Client.closerZcCs`|jtjkrtjdtjdi|j}t|tj|_|j|j D] }|dur-|q#|SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrGrJrKrLr6r __enter__rrn)rZmsgrr@r@rArps  zClient.__enter__exc_type exc_value tracebackcCsBtj|_|j||||jD] }|dur||||qdSrT)rGrLrr__exit__rrn)rZrrrsrtrr@r@rAruszClient.__exit__riNNN)Dr<r=r>r?r r r rjrr!r&r$r#r.r"rr%rrrr,r rrrr-rrrrlr[rrrr/r&rr'r(r*r;r)rrrrkrOrr.rr7r>rFrr\r^rbrfrirlrgr6rpTyper9rru __classcell__r@r@rrAr79s5     U           8        7  1 " %(     !     !     !       )       )       )      c-seZdZdZddddddddddedeeddddddddeje d eje d eje d eje d e d ejedededejedejejeefdededededejejeejejdejffdedejedejejdejfdedejeejegeffddf*fddZddddedddfd e d ejededededejedejejdejfdedefd d!Zddddedfd"ed e d ejedededededefd#d$Z d%e!defd&d'Z"ddddddde#e#e#dd( d)ed%ed*eje$d+eje%d,eje&d-ejejd eje d eje d eje deje e'dfdejee'fdejee'fd.eje(de)fd/d0Z*e+ddddddde#e#e#dd( d)ed%ed*eje$d+eje%d,eje&d-ejejd eje d eje d eje deje e'fdejee'fdejee'fd.eje(dej,e)fd1d2Z-de#e#d3d4e.d5edeje e'dfdejee'fde)f d6d7Z/d4e.de0ded8eje)de)f d9d:Z1d4e.ded8eje)de)fd;d<Z2d4e.de)fd=d>Z3ddde#e#e#dd?d%ed eje d eje d eje deje e'dfdejee'fdejee'fd.eje(de)fd@dAZ4ddde#e#e#dd?d%ed eje d eje d eje deje e'fdejee'fdejee'fd.eje(de)fdBdCZ5ddde#e#e#dd?d%ed eje d eje d eje deje e'fdejee'fdejee'fd.eje(de)fdDdEZ6ddddddde#e#e#dd( d%ed*eje$d+eje%d,eje&d-ejejd eje d eje d eje deje e'fdejee'fdejee'fd.eje(de)fdFdGZ7ddddddde#e#e#dd( d%ed*eje$d+eje%d,eje&d-ejejd eje d eje d eje deje e'fdejee'fdejee'fd.eje(de)fdHdIZ8ddddddde#e#e#dd( d%ed*eje$d+eje%d,eje&d-ejejd eje d eje d eje deje e'fdejee'fdejee'fd.eje(de)fdJdKZ9ddde#e#e#dd?d%ed eje d eje d eje deje e'fdejee'fdejee'fd.eje(de)fdLdMZ:dXdNdOZ;dPee?dTeje?dUeje@ddfdVdWZAZBS)Zr: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". NTFrtrurrwrxryrzrrrrrrr{r|rr}r~.rrrrrrRc r)Nrvrrrc rrrrr r@rArr z(AsyncClient.__init__..cSr r@r r r@r@rArrrrrr rAr[AsV     zAsyncClient.__init__c Crr)rrrr@r@rArrzAsyncClient._init_transportrcCst||||||dS)N)rrrrrr)rrr@r@rArs z!AsyncClient._init_proxy_transportrcCr r!r"r$r@r@rAr&r'zAsyncClient._transport_for_urlr(rrrrrrc  s8|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 r)r*N)rr.)rZrrrrrrrxryrzrwr|r{rrr@r@rArs! zAsyncClient.requestc  Csf|j||||||||| | | d }|j|| | ddIdH}z |VW|IdHdS|IdHwr0)rr.rqr1r@r@rArOs.  "zAsyncClient.streamr2rrOc s|jtjkr tdtj|_t|tr|jn|}|||}|j |||gdIdH}z |s5| IdH|WSt yL}z | IdH|d}~ww)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 r3r4N) rrGrLr6rKrr;r|rr7areadr9rqr:r@r@rAr.0s0   zAsyncClient.sendr5c s||}z^|IdH} |j|||dIdH}z4z ||IdH}Wnty9|YWW|IdHSwt||_|IdH|}| |Wnt yc}z |IdH|d}~wwq|IdHwr;) async_auth_flow __anext__r>asendStopAsyncIterationrqrr5ryr@r9rAr@r@rAr7as8      zAsyncClient._send_handling_authc s t||jkrtd|d|jdD] }||IdHq||IdH}z7|jdD] }||IdHq,t||_|jsA|WS|||}||g}|rV| IdHn||_ |WSWnt yr}z | IdH|d}~wwqrD) rEr}rrrFrr5rGrryrCr9rqrHr@r@rAr>s8   z$AsyncClient._send_handling_redirectscs||j}t}|IdHt|jtstdt|d| |IdH}Wdn1s3wYt|jts@J||_ t |j||d|_|j ||j|_td|j|j|j|j|j|S)rJNz?Attempted to send an sync request with an AsyncClient instance.rrKrL)r&rr1 async_startrrOr r6rhandle_async_requestrrnrzrOrrrPrQrrRrrSrTr@r@rArFs6     z AsyncClient._send_single_requestrUc $|jd||||||||d IdHS)rWrrUNrrXr@r@rAr zAsyncClient.getc r)rZr[rUNrrXr@r@rAr\rzAsyncClient.optionsc r)r]rrUNrrXr@r@rAr^rzAsyncClient.headc ,|jd||||||||| | | | d IdHS)r`rr(Nrrar@r@rArb#  zAsyncClient.postc r)rdrer(Nrrar@r@rArfHrzAsyncClient.putc r)rgrhr(Nrrar@r@rArimrzAsyncClient.patchc r)rjrkrUNrrXr@r@rArlrzAsyncClient.deletecsT|jtjkr&tj|_|jIdH|jD]}|dur%|IdHqdSdSrm)rrGrLrrqrrn)rZrr@r@rArqs zAsyncClient.acloserZcsn|jtjkrtjdtjdi|j}t|tj|_|jIdH|j D] }|dur4|IdHq'|Sro) rrGrJrKrLr6r __aenter__rrn)rZrqrr@r@rArs zAsyncClient.__aenter__rrrsrtcsPtj|_|j|||IdH|jD]}|dur%||||IdHqdSrT)rGrLrr __aexit__rrn)rZrrrsrtrr@r@rArszAsyncClient.__aexit__rirv)Cr<r=r>r?r r r rjrr!r&r$r#r.r"rr%rrrr,r rrrrr-rrlr[rrrr/r&rr'r(r*r;r)rrrrrrOrr.rr7r>rFrr\r^rbrfrirlrqr9rrwr9rrrxr@r@rrAr: s6     U           0        7  1 " &'    !     !     !       )       )       )      )\rdenumloggingrjr+ contextlibrrtypesrrrrrr _configr r r r rr _decodersr _exceptionsrrrr_modelsrrrr _status_codesr_transports.asgir_transports.baserr_transports.defaultrr_transports.wsgir_typesr r!r"r#r$r%r&r'r(r)r*r+r,r-r._urlsr/r0_utilsr1r2r3r4r5TypeVarr6r9r;r getLoggerrPrrkeysrEnumrGrNrnrrrrsr7r:r@r@r@rAsZ       D   Y