U g@szddlmZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl m Z ddlmZmZmZddlmZmZmZmZmZmZdd lmZdd lmZmZmZmZdd l m!Z!m"Z"m#Z#m$Z$dd l%m&Z&dd l'm(Z(m)Z)ddl*m+Z+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:ddl;mm?Z?m@Z@ejArlddlBZBdddgZCejDdddZEejDdddZFddddddZGddddd ZHdddd!d"d#ZIGd$d%d%ZJeJZKeLd&ZMd'e ZNd(Od)d*ePDZQGd+d,d,ejRZSGd-d.d.e9ZTGd/d0d0e.ZUejVd1ejWfZXGd2d3d3ZYGd4ddeYZZGd5ddeYZ[dS)6) annotationsN)asynccontextmanagercontextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth)DEFAULT_LIMITSDEFAULT_MAX_REDIRECTSDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)CookiesHeadersRequestResponse)codes)AsyncBaseTransport BaseTransport)AsyncHTTPTransport HTTPTransport) AsyncByteStream AuthTypes CertTypes CookieTypes HeaderTypes ProxyTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesSyncByteStream TimeoutTypes)URL QueryParams) URLPatternget_environment_proxiesUSE_CLIENT_DEFAULT AsyncClientClientT)boundUr,bool)urllocationreturncCs<|j|jkrdS|jdko:t|dko:|jdko:t|dkS)zA Return 'True' if 'location' is a HTTPS upgrade of 'url' FhttpPhttps)hostscheme_port_or_default)r7r8rA1/tmp/pip-unpacked-wheel-ql4n0x43/httpx/_client.py_is_https_redirect>s    rCz int | Noner7r9cCs"|jdk r|jSddd|jS)Nr;r=)r:r<)portgetr?r7rArArBr@Ms r@)r7otherr9cCs(|j|jko&|j|jko&t|t|kS)z@ Return 'True' if the given URLs share the same origin. )r?r>r@)r7rHrArArB _same_originSs   rIc@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__rArArArBrJ^srJZhttpxz python-httpx/z, cCsg|]}|dkr|qS)identityrA).0keyrArArB ysrRc@seZdZdZdZdZdS) ClientStaterN)rKrLrMUNOPENEDOPENEDCLOSEDrArArArBrS}srSc@s@eZdZdZdddddddZd d d d Zdd d dZdS)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. r*rfloatNonestreamresponsestartr9cCs||_||_||_dSN_stream _response_startselfr]r^r_rArArB__init__szBoundSyncStream.__init__ztyping.Iterator[bytes]r9ccs|jD] }|VqdSr`rbrfchunkrArArB__iter__s zBoundSyncStream.__iter__cCs,t|j}tj|d|j_|jdSN)seconds) time perf_counterrddatetime timedeltarcelapsedrbcloserfrsrArArBrtszBoundSyncStream.closeN)rKrLrMrNrgrlrtrArArArBrYsrYc@s@eZdZdZdddddddZd d d d Zdd d dZdS)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. rrrZr[r\cCs||_||_||_dSr`rarerArArBrgszBoundAsyncStream.__init__ztyping.AsyncIterator[bytes]rhcCs |j2z3dHW}|Vq6dSr`rirjrArArB __aiter__szBoundAsyncStream.__aiter__cs2t|j}tj|d|j_|jIdHdSrm) rorprdrqrrrcrsrbacloserurArArBrxszBoundAsyncStream.acloseN)rKrLrMrNrgrwrxrArArArBrvsrv.c@seZdZddddededdddd ddd d d d d ddd ddd ddZed dddZed dddZdddddZ dd dd d!d"Z ed#dd$d%Z e j d dd&d'd%Z ed(dd)d*Z e j d(dd+d,d*Z ed-dd.d/Zej d0dd1d2d/Zeddd3d4Zej dddd5d4Zed6dd7d8Zej d9dd:d;d8ZedZej d?dd@dAd>ZedBddCdDZej dEddFdGdDZdddddddeddH dIddJdKdLdMdd d dNdOdPdQ dRdSZddddTdUZdud d d@dVdWZdvd d d:dXdYZdwdddFdZd[Zdd-d1d\d]ZefdPd^d_d`dadbZdPdcdPdddedfZdPdcdIdddgdhZdPdcddddidjZdPddId6dkdldmZdPdIdndodpdqZdPddrdsdtZ dS)x BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingAuthTypes | NoneQueryParamTypes | NoneHeaderTypes | NoneCookieTypes | Noner+r6int+None | typing.Mapping[str, list[EventHook]] URL | str#str | typing.Callable[[bytes], str]r[) r}r~rrrrrrrrrr9c Cs|dkr in|}|t| |_|||_t||_t||_t ||_ t ||_ ||_ ||_t|dgt|dgd|_| |_| |_tj|_dSNrequestr^)rr^)_enforce_trailing_slashr, _base_url _build_auth_authr-_paramsrrr_cookiesr_timeoutrrlistrF _event_hooks _trust_env_default_encodingrSrV_state) rfr}r~rrrrrrrrrrArArBrgs     zBaseClient.__init__rhcCs |jtjkS)z2 Check if the client being closed )rrSrXrfrArArB is_closedszBaseClient.is_closedcCs|jSr`)rrrArArBrszBaseClient.trust_envr,rDcCs"|jdr|S|j|jddS)N/raw_path)rendswith copy_withrfr7rArArBrs z"BaseClient._enforce_trailing_slashProxyTypes | Nonezdict[str, Proxy | None])proxyallow_env_proxiesr9cCsL|dkr$|r ddtDSiSt|ttfrsz-BaseClient._get_proxy_map..rGzall://)r/items isinstancestrr,r)rfrrrArArB_get_proxy_mapszBaseClient._get_proxy_maprcCs|jSr`)rrrArArBrszBaseClient.timeout)rr9cCst||_dSr`)rr)rfrrArArBrszdict[str, list[EventHook]]cCs|jSr`)rrrArArBrszBaseClient.event_hooks)rr9cCs(t|dgt|dgd|_dSr)rrFr)rfrrArArBr sz Auth | NonecCs|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrrArArBr}s zBaseClient.authr )r}r9cCs|||_dSr`)rrrfr}rArArBr}scCs|jS)zK Base URL to use when sending requests with relative URLs. )rrrArArBrszBaseClient.base_urlcCs|t||_dSr`)rr,rrrArArBr&srcCs|jS)z@ HTTP headers to include when sending requests. )_headersrrArArBr*szBaseClient.headersr#)rr9cCs2tdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rfrZclient_headersrArArBr1s rcCs|jS)zA Cookie values to include when sending requests. )rrrArArBr>szBaseClient.cookiesr")rr9cCst||_dSr`)rr)rfrrArArBrEsr-cCs|jS)zO Query parameters to include in the URL when sending requests. )rrrArArBr~IszBaseClient.paramsr%)r~r9cCst||_dSr`)r-r)rfr~rArArBr~Ps) contentdatafilesjsonr~rrr extensionsrRequestContent | NoneRequestData | NoneRequestFiles | Nonetyping.Any | NoneTimeoutTypes | UseClientDefaultRequestExtensions | Noner) methodr7rrrrr~rrrrr9c Cs||}||}|| } ||}| dkr4in| } d| krnt| trP|jnt| } tf| d| i} t ||||||||| | d S)aR 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/clients/#request-instances Nr)rrrrr~rrr) _merge_url_merge_headers_merge_cookies_merge_queryparamsrrJrrdictas_dictr) rfrr7rrrrr~rrrrrArArB build_requestTs.    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_urlrrlstripr)rfr7Z merge_urlZmerge_raw_pathrArArBrs  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. )rrr)rfrmerged_cookiesrArArBrs    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. )rrr)rfrZmerged_headersrArArBrs  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. )r~r-merge)rfr~Zmerged_queryparamsrArArBrs   zBaseClient._merge_queryparamscCs\|dkr dSt|tr*t|d|ddSt|tr8|St|rJt|dStd|dS)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler rcallabler TypeErrorrrArArBrs   zBaseClient._build_auth#AuthTypes | UseClientDefault | Noner)rr}r9cCsRt|tr|jn||}|dk r&|S|jj|jj}}|s@|rLt||dStS)Nr) rrJrrr7rrr r)rfrr}rrrArArB_build_request_auths zBaseClient._build_request_authr)rr^r9cCsR|||}|||}||||}|||}t|j}t||||||jdS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rr7rrr]r)_redirect_method _redirect_url_redirect_headers_redirect_streamrrrr)rfrr^rr7rr]rrArArB_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)rfrr^rrArArBrszBaseClient._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: .rN)r>)fragment) rr,rrr?r>rr7rjoinr)rfrr^r8r7excrArArBrs"     zBaseClient._redirect_url)rr7rr9cCsxt|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) rrrIr7rCpopnetlocdecoder)rfrr7rrrArArBr"s       zBaseClient._redirect_headersz'SyncByteStream | AsyncByteStream | None)rrr9cCs||jkr|dkrdS|jS)zO Return the body that should be used for the redirect request. rN)rr])rfrrrArArBr=szBaseClient._redirect_streamrr9cCsDd|jkr@t|jtr|jnt|j}tf|jd|i|_dS)Nr)rrrrJrrr)rfrrrArArB _set_timeoutHs   zBaseClient._set_timeout)N)N)N)!rKrLrMr r rgpropertyrrrrrsetterrr}rrrr~r0rrrrrrrrrrrrrrArArArBrys("  (3    rycsreZdZdZdddddddddddedeeddddddd d d d d dddddddddddddddfddZdddddedfd d dddddddddZdddddefd d d dddddd!d"d#Z d$dd%d&d'Z ddddddde e e dd( d)dd*d+d,d-d d d d.d/d0d1d2d3d4d5Z e ddddddde e e dd( d)dd*d+d,d-d d d d.d/d0d1d6d3d7d8Zde e d9d:dd.d/d2d;ddd?d2d@dAdBZd:dd?d2dCdDdEZd:d2dFdGdHZddde e e ddIdd d d d.d/d0d1d2dJ dKdLZddde e e ddIdd d d dMd/d0d1d2dJ dNdOZddde e e ddIdd d d dMd/d0d1d2dJ dPdQZddddddde e e dd( dd*d+d,d-d d d dMd/d0d1d2dR dSdTZddddddde e e dd( dd*d+d,d-d d d dMd/d0d1d2dR dUdVZddddddde e e dd( dd*d+d,d-d d d dMd/d0d1d2dR dWdXZddde e e ddIdd d d dMd/d0d1d2dJ dYdZZdd[d\d]Zd^d^d_d`daZdhdbdcddddedfdgZZS)ir2av 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)* Either `True` to use an SSL context with the default CA bundle, `False` to disable verification, or an instance of `ssl.SSLContext` to use a custom context. * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **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. * **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". NTFrzr{)r}r~rrverifycertrhttp1http2rmountsrrlimitsrrr transportrrrrrssl.SSLContext | str | boolCertTypes | Noner6rz0None | typing.Mapping[str, BaseTransport | None]r+rrrrzBaseTransport | Nonerr[)r}r~rrrrrrrrrrrrrrrrrr9c stj||||| | ||||d rRz ddl}Wntk rPtddYnXo\|dk}| |}j|d_fdd|D_| dk rʈj dd| Dt t j_dS)Nr|ruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.rrrrrrrc s:i|]2\}}t||dkrdnj|dqSN)rrrrrrr._init_proxy_transportrPrQrrrrrrfrrrArBrs z#Client.__init__..cSsi|]\}}t||qSrAr.rPrQrrArArBrs superrgh2 ImportErrorr_init_transport _transportr_mountsrrsorted)rfr}r~rrrrrrrrrrrrrrrrrrr proxy_map __class__rrBrgsR     zClient.__init__rrrrrrrrr9cCs |dk r |St||||||dSrrrfrrrrrrrrArArBrs zClient._init_transportrrrrrrrrr9c Cst|||||||dSN)rrrrrrrrrfrrrrrrrrArArBrs zClient._init_proxy_transportr,rDcCs:|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. Nrrmatchesrrfr7patternrrArArB_transport_for_urls zClient._transport_for_url rrrrr~rrr}rrrrrrrrrbool | UseClientDefaultrrrrr7rrrrr~rrr}rrrr9c  CsL| dk rd}tj|tdd|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/clients/#merging-of-configuration NSetting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead.rT stacklevel rr7rrrrr~rrrrr}rwarningswarnDeprecationWarningrsendrfrr7rrrrr~rrr}rrrmessagerrArArBrs$! zClient.requestztyping.Iterator[Response]c  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)rr}rr]N)rr%rtrfrr7rrrrr~rrr}rrrrr^rArArBr];s,  z Client.streamr]r}rrrr]r}rr9c Cs|jtjkrtdtj|_t|tr,|jn|}||| ||}|j |||gd}z|sf| |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/clients/#request-instances 5Cannot send a request, as the client has been closed.r}rhistoryN)rrSrX RuntimeErrorrWrrJrrr_send_handling_authread BaseExceptionrtrfrr]r}rr^rrArArBr%os,   z Client.sendrlist[Response]rr}rr.r9c Cs||}zt|}|j|||d}zRz||}Wntk rR|YWW\SXt||_||}| |Wqt k r}z||W5d}~XYqXqW5|XdSN)rr.) Zsync_auth_flowrtnext_send_handling_redirectsr% StopIterationrr.r1appendr2 rfrr}rr.Z auth_flowr^ next_requestrrArArBr0s*  zClient._send_handling_authrrr.r9c Cst||jkrtd|d|jdD] }||q$||}zb|jdD] }||qHt||_|jsl|WS|||}||g}|r| n ||_ |WSWqt k r}z| |W5d}~XYqXqdSNz#Exceeded maximum allowed redirects.rrr^) lenrrr_send_single_requestrr.has_redirect_locationrr1r<r2rtrfrrr.hookr^rrArArBr8s.        zClient._send_handling_redirectsrc Cs||j}t}t|jts(tdt|d| |}W5QRXt|jtsXt ||_ 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.rr^r_HTTP Request: %s %s "%s %d %s")rr7rorprr]r*r/rhandle_requestAssertionErrorrrYrextract_cookiesrrloggerinfor http_versionr reason_phraserfrrr_r^rArArBr@s4     zClient._send_single_requestr~rrr}rrr r7r~rrr}rrrr9c Cs|jd||||||||d S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrOr rfr7r~rrr}rrrrArArBrF sz Client.getAuthTypes | UseClientDefaultc Cs|jd||||||||d S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrOrrRrArArBoptions)szClient.optionsc Cs|jd||||||||d S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrOrrRrArArBheadFsz Client.head r7rrrrr~rrr}rrrr9c Cs$|jd||||||||| | | | d S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrr rfr7rrrrr~rrr}rrrrArArBpostcsz Client.postc Cs$|jd||||||||| | | | d S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrrr[rArArBputsz Client.putc Cs$|jd||||||||| | | | d S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrrr[rArArBpatchsz Client.patchc Cs|jd||||||||d S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErOrrRrArArBdeletesz Client.deleterhcCsB|jtjkr>tj|_|j|jD]}|dk r(|q(dSz. Close transport and proxies. N)rrSrXrrtrvalues)rfrrArArBrts   z Client.closer3rfr9cCs`|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.) rrSrVrWrXr/r __enter__rrg)rfmsgrrArArBrjs   zClient.__enter__type[BaseException] | NoneBaseException | NoneTracebackType | Noneexc_type exc_value tracebackr9cCsBtj|_|j||||jD]}|dk r"||||q"dSr`)rSrXrr__exit__rrg)rfrprqrrrrArArBrs s zClient.__exit__)NNN)rKrLrMrNr r r rgrrrr0rrr]r%r0r8r@rFrVrXr\r_rbrertrjrs __classcell__rArAr rBr2Rs/dd?d2d@dAdBZd:dd?d2dCdDdEZd:d2dFdGdHZddde e e ddIdd d d d.d/d0d1d2dJ dKdLZddde e e ddIdd d d dMd/d0d1d2dJ dNdOZddde e e ddIdd d d dMd/d0d1d2dJ dPdQZddddddde e e dd( dd*d+d,d-d d d dMd/d0d1d2dR dSdTZddddddde e e dd( dd*d+d,d-d d d dMd/d0d1d2dR dUdVZddddddde e e dd( dd*d+d,d-d d d dMd/d0d1d2dR dWdXZddde e e ddIdd d d dMd/d0d1d2dJ dYdZZdd[d\d]Zd^d^d_d`daZdhdbdcddddedfdgZZS)ir1a An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between tasks. 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)* Either `True` to use an SSL context with the default CA bundle, `False` to disable verification, or an instance of `ssl.SSLContext` to use a custom context. * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **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. * **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". NTFrzr{)r}r~rrrrrrrrrrrrrrrrrrrrrrrr6rz5None | typing.Mapping[str, AsyncBaseTransport | None]r+rrrrzAsyncBaseTransport | Nonerr[)r}r~rrrrrrrrrrrrrrrrrr9c stj||||| | ||||d rRz ddl}Wntk rPtddYnXo\|dk}| |}j|d_fdd|D_| dk rʈj dd| Dt t j_dS)Nr|rrrc s:i|]2\}}t||dkrdnj|dqSrrrrrArBrs z(AsyncClient.__init__..cSsi|]\}}t||qSrArrrArArBrsr)rfr}r~rrrrrrrrrrrrrrrrrrrr r rrBrgIsR     zAsyncClient.__init__rr cCs |dk r |St||||||dSrrrrArArBrs zAsyncClient._init_transportrrc Cst|||||||dSrrurrArArBrs z!AsyncClient._init_proxy_transportr,rDcCs:|jD](\}}||r |dkr*|jn|Sq |jSrrrrArArBrs zAsyncClient._transport_for_urlrrrrrrrrrrrrc  sR| dk rd}tj|tdd|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/clients/#merging-of-configuration NrrTrrr r!r&rArArBrs$" zAsyncClient.requestztyping.AsyncIterator[Response]c  CsX|j||||||||| | | d }|j|| | ddIdH}z |VW5|IdHXdSr()rr%rxr)rArArBr]s,   zAsyncClient.streamr*rr+c s|jtjkrtdtj|_t|tr,|jn|}||| ||}|j |||gdIdH}z|sr| 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/clients/#request-instances r,r-N)rrSrXr/rWrrJrrrr0areadr2rxr3rArArBr%:s,    zAsyncClient.sendrr4r5c s||}z|IdH}|j|||dIdH}z^z||IdH}Wntk rd|YWWhSXt||_|IdH|}| |Wqt k r}z|IdH|W5d}~XYqXqW5|IdHXdSr6) Zasync_auth_flowrx __anext__r8asendStopAsyncIterationrr.rvr:r2r;rArArBr0ms*   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?rrrr@rr.rArrvr<r2rxrBrArArBr8s.    z$AsyncClient._send_handling_redirectsrc s||j}t}t|jts(tdt|d| |IdH}W5QRXt|jts^t ||_ t |j||d|_|j ||j|_td|j|j|j|j|j|S)rDz?Attempted to send an sync request with an AsyncClient instance.rNrErF)rr7rorprr]rr/rZhandle_async_requestrHrrvrrIrrrJrKrrLrrMrNrArArBr@s4     z AsyncClient._send_single_requestrOrPc s"|jd||||||||d IdHS)rQrrONrrRrArArBrFszAsyncClient.getrSc s"|jd||||||||d IdHS)rTrUrONrrRrArArBrVszAsyncClient.optionsc s"|jd||||||||d IdHS)rWrrONrrRrArArBrXszAsyncClient.headrYc s*|jd||||||||| | | | d IdHS)rZrrNrr[rArArBr\.szAsyncClient.postc s*|jd||||||||| | | | d IdHS)r]r^rNrr[rArArBr_SszAsyncClient.putc s*|jd||||||||| | | | d IdHS)r`rarNrr[rArArBrbxszAsyncClient.patchc s"|jd||||||||d IdHS)rcrdrONrrRrArArBreszAsyncClient.deleterhcsN|jtjkrJtj|_|jIdH|jD]}|dk r.|IdHq.dSrf)rrSrXrrxrrg)rfrrArArBrxs  zAsyncClient.acloser5rhcsl|jtjkr*tjdtjdi|j}t|tj|_|jIdH|j D]}|dk rL|IdHqL|Sri) rrSrVrWrXr/r __aenter__rrg)rfrkrrArArBrzs zAsyncClient.__aenter__rlrmrnrocsNtj|_|j|||IdH|jD] }|dk r(||||IdHq(dSr`)rSrXrr __aexit__rrg)rfrprqrrrrArArBr{s zAsyncClient.__aexit__)NNN)rKrLrMrNr r r rgrrrr0rrr]r%r0r8r@rFrVrXr\r_rbrerxrzr{rtrArAr rBr1s0sd      <    N