a ~g@sxddlmZddlZddlZddlZddlZddlZddlZddlm 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@ejArlddlBZBgdZCejDdddZEejDdddZFddddddZGddddd 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_proxies)USE_CLIENT_DEFAULT AsyncClientClientTr2)boundUr1r,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)r7r8rAR/var/www/html/emsaiapi.evdpl.com/venv/lib/python3.9/site-packages/httpx/_client.py_is_https_redirect>s    rCz int | Noner7r9cCs"|jdur|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^srJhttpxz python-httpx/z, cCsg|]}|dkr|qS)identityrA).0keyrArArB yrSc@seZdZdZdZdZdS) ClientStaterN)rKrLrMUNOPENEDOPENEDCLOSEDrArArArBrU}srUc@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`rarArArB__init__szBoundSyncStream.__init__ztyping.Iterator[bytes]r9ccs|jD] }|VqdSrbrdrhchunkrArArB__iter__s zBoundSyncStream.__iter__cCs,t|j}tj|d|j_|jdSN)seconds) time perf_counterrfdatetime timedeltareelapsedrdcloserhrurArArBrvszBoundSyncStream.closeN)rKrLrMrNrirnrvrArArArBr[sr[c@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. rrr\r]r^cCs||_||_||_dSrbrcrgrArArBriszBoundAsyncStream.__init__ztyping.AsyncIterator[bytes]rjcCs |j2z3dHW}|Vq6dSrbrkrlrArArB __aiter__szBoundAsyncStream.__aiter__cs2t|j}tj|d|j_|jIdHdSro) rqrrrfrsrtrerurdacloserwrArArBrzszBoundAsyncStream.acloseN)rKrLrMrNriryrzrArArArBrxsrx.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]) rrrrrrrrrrrr9c Cs|dur 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_encodingrUrX_state) rhrrrrrrrrrrrrArArBris     zBaseClient.__init__rjcCs |jtjkS)z2 Check if the client being closed )rrUrZrhrArArB is_closedszBaseClient.is_closedcCs|jSrb)rrrArArBrszBaseClient.trust_envr,rDcCs"|jdr|S|j|jddS)N/raw_path)rendswith copy_withrhr7rArArBrs z"BaseClient._enforce_trailing_slashProxyTypes | Nonezdict[str, Proxy | None])proxyallow_env_proxiesr9cCsL|dur$|r ddtDSiSt|ttfrsz-BaseClient._get_proxy_map..rGzall://)r/items isinstancestrr,r)rhrrrArArB_get_proxy_mapszBaseClient._get_proxy_maprcCs|jSrb)rrrArArBrszBaseClient.timeout)rr9cCst||_dSrb)rr)rhrrArArBrszdict[str, list[EventHook]]cCs|jSrb)rrrArArBrszBaseClient.event_hooks)rr9cCs(t|dgt|dgd|_dSr)rrFr)rhrrArArBr sz Auth | NonecCs|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrrArArBrs zBaseClient.authr )rr9cCs|||_dSrb)rrrhrrArArBrscCs|jS)zK Base URL to use when sending requests with relative URLs. )rrrArArBrszBaseClient.base_urlcCs|t||_dSrb)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)rhrZclient_headersrArArBr1s rcCs|jS)zA Cookie values to include when sending requests. )rrrArArBr>szBaseClient.cookiesr")rr9cCst||_dSrb)rr)rhrrArArBrEsr-cCs|jS)zO Query parameters to include in the URL when sending requests. )rrrArArBrIszBaseClient.paramsr%)rr9cCst||_dSrb)r-r)rhrrArArBrPs) contentdatafilesjsonrrrr extensionsrRequestContent | NoneRequestData | NoneRequestFiles | Nonetyping.Any | NoneTimeoutTypes | UseClientDefaultRequestExtensions | Noner) methodr7rrrrrrrrrr9c Cs||}||}|| } ||}| dur4in| } d| vrrt| trP|jnt| } tfi| 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)rrrrrrrr) _merge_url_merge_headers_merge_cookies_merge_queryparamsrrJrrdictas_dictr) rhrr7rrrrrrrrrrArArB 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)rhr7Z 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)rhrZmerged_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)rhrZmerged_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. )rr-merge)rhrZmerged_queryparamsrArArBrs   zBaseClient._merge_queryparamscCs\|dur dSt|tr*t|d|ddSt|tr8|St|rJt|dStd|dS)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler rcallabler TypeErrorrrArArBrs   zBaseClient._build_auth#AuthTypes | UseClientDefault | Noner)rrr9cCsRt|tr|jn||}|dur&|S|jj|jj}}|s@|rLt||dStS)Nr) rrJrrr7rrr r)rhrrrrrArArB_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)rhrr`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)rhrr`rrArArBrszBaseClient._redirect_methodc Cs|jd}z t|}Wn:tyP}z"td|d|ddWYd}~n d}~00|jrn|jsn|j|jjd}|jr|j |}|jj r|j s|j|jj d}|S)z< Return the URL for the redirect to follow. Locationz Invalid URL in location header: .rN)r>)fragment) rr,rrr?r>rr7rjoinr)rhrr`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)rhrr7rrrArArBr"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_)rhrrrArArBr=szBaseClient._redirect_streamrr9cCsHd|jvrDt|jtr|jnt|j}tfi|jd|i|_dS)Nr)rrrrJrrr)rhrrrArArB _set_timeoutHs   zBaseClient._set_timeout)N)N)N)!rKrLrMr r ripropertyrrrrrsetterrrrrrrr0rrrrrrrrrrrrrrArArArBr{s("  (3    r{csreZdZdZdddddddddddedeeddddddd 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". NTFr|r})rrrrverifycertrhttp1http2rmountsrrlimitsrrr transportrrrrrssl.SSLContext | str | boolCertTypes | Noner6rz0None | typing.Mapping[str, BaseTransport | None]r+rrrrzBaseTransport | Nonerr])rrrrrrrrrrrrrrrrrrrr9c stj||||| | ||||d rPz ddl}WntyNtddYn0oZ|du}| |}j|d_fdd|D_| durȈ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||durdnj|dqSN)rrrrrrr._init_proxy_transportrQrRrrrrrrhrrrArBrs z#Client.__init__..cSsi|]\}}t||qSrAr.rQrRrrArArBrrT superrih2 ImportErrorr_init_transport _transportr_mountsrrsorted)rhrrrrrrrrrrrrrrrrrrrrr proxy_map __class__rrBrisR      zClient.__init__rrrrrrrrr9cCs |dur |St||||||dSrrrhrrrrrrrrArArBrs zClient._init_transportrrrrrrrrr9c Cst|||||||dSN)rrrrrrrrrhrrrrrrrrArArBrs zClient._init_proxy_transportr,rDcCs:|jD](\}}||r |dur*|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. Nr rmatchesr rhr7patternrrArArB_transport_for_urls zClient._transport_for_url rrrrrrrrrrrrrrrrrbool | UseClientDefaultrrrrr7rrrrrrrrrrrr9c  CsL| durd}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.rV stacklevel rr7rrrrrrrrrrrwarningswarnDeprecationWarningrsendrhrr7rrrrrrrrrrrmessagerrArArBrs$! zClient.requestztyping.Iterator[Response]c  csT|j||||||||| | | d }|j|| | dd}z|VW|n |0dSa  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)rrrr_N)rr'rvrhrr7rrrrrrrrrrrrr`rArArBr_;s, z Client.streamr_rrrrr_rrr9c Cs|jtjkrtdtj|_t|tr,|jn|}||| ||}|j |||gd}z|sf| |WSt y}z| |WYd}~n d}~00dS)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.rrhistoryN)rrUrZ RuntimeErrorrYrrJrrr_send_handling_authread BaseExceptionrvrhrr_rrr`rrArArBr'os,   z Client.sendrlist[Response]rrrr0r9c Cs||}zt|}|j|||d}zVz||}Wn"tyV|YWW|S0t||_||}| |Wqt y}z||WYd}~qd}~00qW|n |0dSN)rr0) Zsync_auth_flownext_send_handling_redirectsr' StopIterationrvrr0r3appendr4 rhrrrr0Z auth_flowr` next_requestrrArArBr2s.    zClient._send_handling_authrrr0r9c Cst||jkrtd|d|jdD] }||q$||}zb|jdD] }||qHt||_|jsl|WS|||}||g}|r| n ||_ |WSWqt y}z| |WYd}~qd}~00qdSNz#Exceeded maximum allowed redirects.rrr`) lenrrr_send_single_requestrr0has_redirect_locationrr3r>r4rvrhrrr0hookr`rrArArBr:s,        zClient._send_handling_redirectsrcCs||j}t}t|jts(tdt|d| |}Wdn1sR0Yt|jtslJ||_ 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.rNr`raHTTP Request: %s %s "%s %d %s")rr7rqrrrr_r*r1rhandle_requestrr[rextract_cookiesrrloggerinfor http_versionr reason_phraserhrrrar`rArArBrBs0   (  zClient._send_single_requestrrrrrrr r7rrrrrrrr9c Cs|jd||||||||d S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrPr rhr7rrrrrrrrArArBrF sz Client.getAuthTypes | UseClientDefaultc Cs|jd||||||||d S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrPrrSrArArBoptions)szClient.optionsc Cs|jd||||||||d S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrPrrSrArArBheadFsz Client.head r7rrrrrrrrrrrr9c Cs$|jd||||||||| | | | d S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrr rhr7rrrrrrrrrrrrArArBpostcsz 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`. DELETErPrrSrArArBdeletesz Client.deleterjcCsB|jtjkr>tj|_|j|jD]}|dur(|q(dSz. Close transport and proxies. N)rrUrZr rvr values)rhrrArArBrvs   z Client.closer3rhr9cCs`|jtjkr*tjdtjdi|j}t|tj|_|j|j D]}|durF|qF|SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrUrXrYrZr1r  __enter__r rh)rhmsgrrArArBrks   zClient.__enter__type[BaseException] | NoneBaseException | NoneTracebackType | Noneexc_type exc_value tracebackr9cCsBtj|_|j||||jD]}|dur"||||q"dSrb)rUrZrr __exit__r rh)rhrqrrrsrrArArBrt s zClient.__exit__)NNN)rKrLrMrNr r r rirrrr0rrr_r'r2r:rBrFrWrYr]r`rcrfrvrkrt __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". NTFr|r})rrrrrrrrrrrrrrrrrrrrrrrrrr6rz5None | typing.Mapping[str, AsyncBaseTransport | None]r+rrrrzAsyncBaseTransport | Nonerr])rrrrrrrrrrrrrrrrrrrr9c stj||||| | ||||d rPz ddl}WntyNtddYn0oZ|du}| |}j|d_fdd|D_| durȈj dd| Dt t j_dS)Nr~rrrc s:i|]2\}}t||durdnj|dqSrrrrrArBrs z(AsyncClient.__init__..cSsi|]\}}t||qSrArrrArArBrrTr)rhrrrrrrrrrrrrrrrrrrrrrr r rrBriIsR      zAsyncClient.__init__rrcCs |dur |St||||||dSrrrrArArBrs zAsyncClient._init_transportrrc Cst|||||||dSrrvrrArArBrs z!AsyncClient._init_proxy_transportr,rDcCs:|jD](\}}||r |dur*|jn|Sq |jSrrrrArArBrs zAsyncClient._transport_for_urlrrrrrrrrrrrrc  sR| durd}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 NrrVrr!r"r#r(rArArBrs$" zAsyncClient.requestztyping.AsyncIterator[Response]c  Csf|j||||||||| | | d }|j|| | ddIdH}z|VW|IdHn|IdH0dSr*)rr'rzr+rArArBr_s,  zAsyncClient.streamr,rr-c s|jtjkrtdtj|_t|tr,|jn|}||| ||}|j |||gdIdH}z|sr| IdH|WSt y}z| IdH|WYd}~n d}~00dS)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)rrUrZr1rYrrJrrrr2areadr4rzr5rArArBr':s,    zAsyncClient.sendrr6r7c s||}z|IdH}|j|||dIdH}zhz||IdH}Wn(tyn|YWW|IdHS0t||_|IdH|}| |Wqt y}z|IdH|WYd}~qd}~00qW|IdHn|IdH0dSr8) Zasync_auth_flow __anext__r:asendStopAsyncIterationrzrr0rwr<r4r=rArArBr2ms.     zAsyncClient._send_handling_authr?c st||jkrtd|d|jdD]}||IdHq$||IdH}zn|jdD]}||IdHqTt||_|js~|WS|||}||g}|r| IdHn ||_ |WSWqt y}z| IdH|WYd}~qd}~00qdSr@) rArrrrBrr0rCrrwr>r4rzrDrArArBr:s,    z$AsyncClient._send_handling_redirectsrcs||j}t}t|jts(tdt|d | |IdH}Wdn1sX0Yt|jtsrJ||_ t |j||d|_|j ||j|_td|j|j|j|j|j|S)rFz?Attempted to send an sync request with an AsyncClient instance.rNrGrH)rr7rqrrrr_rr1rZhandle_async_requestrrxrrJrrrKrLrrMrrNrOrArArBrBs0   .  z AsyncClient._send_single_requestrPrQc s"|jd||||||||d IdHS)rRrrPNrrSrArArBrFszAsyncClient.getrTc s"|jd||||||||d IdHS)rUrVrPNrrSrArArBrWszAsyncClient.optionsc s"|jd||||||||d IdHS)rXrrPNrrSrArArBrYszAsyncClient.headrZc s*|jd||||||||| | | | d IdHS)r[rrNrr\rArArBr].szAsyncClient.postc s*|jd||||||||| | | | d IdHS)r^r_rNrr\rArArBr`SszAsyncClient.putc s*|jd||||||||| | | | d IdHS)rarbrNrr\rArArBrcxszAsyncClient.patchc s"|jd||||||||d IdHS)rdrerPNrrSrArArBrfszAsyncClient.deleterjcsN|jtjkrJtj|_|jIdH|jD]}|dur.|IdHq.dSrg)rrUrZr rzr rh)rhrrArArBrzs  zAsyncClient.acloser5ricsl|jtjkr*tjdtjdi|j}t|tj|_|jIdH|j D]}|durL|IdHqL|Srj) rrUrXrYrZr1r  __aenter__r rh)rhrlrrArArBr{s zAsyncClient.__aenter__rmrnrorpcsNtj|_|j|||IdH|jD] }|dur(||||IdHq(dSrb)rUrZrr  __aexit__r rh)rhrqrrrsrrArArBr|s zAsyncClient.__aexit__)NNN)rKrLrMrNr r r rirrrr0rrr_r'r2r:rBrFrWrYr]r`rcrfrzr{r|rurArAr rBr1s0sd      <   N