o Zh@sTddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddl mZmZmZddlmZmZmZmZmZmZdd lmZdd lmZmZmZmZdd lm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@ddlAmBZBmCZCddlDmEZEmFZFmGZGmHZHmIZIejJdddZKejJdddZLGdddZMeMZNeOdZPde ZQdRddeSDZTGd d!d!ejUZVGd"d#d#e=ZWGd$d%d%e1ZXejYd&ejZfZ[Gd'd(d(Z\Gd)dde\Z]Gd*dde\Z^dS)+) annotationsN)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 ProxiesTypes ProxyTypesQueryParamTypesRequestContent 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__rBrBD/var/www/html/lang_env/lib/python3.10/site-packages/httpx/_client.pyr=Csr=Zhttpxz python-httpx/z, cCsg|]}|dkr|qS)identityrB).0keyrBrBrC ^srGc@seZdZdZdZdZdS) ClientStaterN)r>r?r@UNOPENEDOPENEDCLOSEDrBrBrBrCrHbsrHc@.eZdZdZdd d Zdd dZdddZdS)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. streamr-responsertimerr3returnNonecC||_||_||_dSN_stream _response_timerselfrPrQrRrBrBrC__init__v zBoundSyncStream.__init__typing.Iterator[bytes]ccs|jD]}|VqdSrVrXr\chunkrBrBrC__iter__}s zBoundSyncStream.__iter__cCs(|j}tj|d|j_|jdSN)seconds)rZZ sync_elapseddatetime timedeltarYelapsedrXcloser\rerBrBrCris zBoundSyncStream.closeN)rPr-rQrrRr3rSrT)rSr_rSrT)r>r?r@rAr]rcrirBrBrBrCrOp   rOc@rN)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. rPr!rQrrRr3rSrTcCrUrVrWr[rBrBrCr]r^zBoundAsyncStream.__init__typing.AsyncIterator[bytes]cCs"|j2z 3dHW}|Vq6dSrVr`rarBrBrC __aiter__szBoundAsyncStream.__aiter__cs6|jIdH}tj|d|j_|jIdHdSrd)rZZ async_elapsedrfrgrYrhrXacloserjrBrBrCrpszBoundAsyncStream.acloseN)rPr!rQrrRr3rSrT)rSrnrk)r>r?r@rAr]rorprBrBrBrCrmrlrm.c @seZdZddddededdddd dzddZed{d d!Zed{d"d#Zd|d&d'Z d}d,d-Z ed~d/d0Z e j dd1d0Z edd3d4Z e j dd5d4Z edd7d8Zej dd:d8Zedd;d<Zej dd=d<Zedd?d@Zej ddBd@ZeddDdEZej ddGdEZeddIdJZej ddLdJZdddddddeddM dd\d]Zdd^d_Zddd`daZdddbdcZ dddddeZddfdgZefddkdlZddodpZddqdrZddsdtZddudvZddxdyZdS) BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingruAuthTypes | NonervQueryParamTypes | NonerwHeaderTypes | NonerxCookieTypes | Noneryr.rzboolr{intr|+None | typing.Mapping[str, list[EventHook]]r}r/r~r#str | typing.Callable[[bytes], str]rSrTc Cs|durin|}|t| |_|||_t||_t||_t ||_ t ||_ ||_ ||_t|dgt|dgd|_| |_| |_tj|_dSNrequestrQ)rrQ)_enforce_trailing_slashr1 _base_url _build_auth_authr2_paramsrrwr_cookiesr_timeoutrzr{listget _event_hooks _trust_env_default_encodingrHrK_state) r\rurvrwrxryrzr{r|r}r~rrBrBrCr]s      zBaseClient.__init__cCs |jtjkS)z2 Check if the client being closed )rrHrMr\rBrBrC is_closeds zBaseClient.is_closedcC|jSrV)rrrBrBrCr~zBaseClient.trust_envurlr1cCs"|jdr|S|j|jddS)N/raw_path)rendswith copy_withr\rrBrBrCrs z"BaseClient._enforce_trailing_slashproxiesProxiesTypes | Noneallow_env_proxiesdict[str, Proxy | None]cCs|dur|rddtDSiSt|tr8i}|D]\}}t|ttfr-t|dn|}||t|<q|St|ttfrDt|dn|}d|iS)NcSs(i|]\}}||dur dnt|dqS)Nr)r)rErFrrBrBrC sz-BaseClient._get_proxy_map..rzall://)r5items isinstancedictstrr1r)r\rr new_proxiesrFvalueproxyrBrBrC_get_proxy_maps zBaseClient._get_proxy_maprcCrrV)rrrBrBrCryrzBaseClient.timeoutcCt||_dSrV)rr)r\ryrBrBrCrydict[str, list[EventHook]]cCrrV)rrrBrBrCr|rzBaseClient.event_hookscCs(t|dgt|dgd|_dSr)rrr)r\r|rBrBrCr|s Auth | NonecCr)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrrBrBrCrus zBaseClient.authr"cCs|||_dSrV)rrr\rurBrBrCruscCr)zK Base URL to use when sending requests with relative URLs. )rrrBrBrCr} zBaseClient.base_urlcCs|t||_dSrV)rr1rrrBrBrCr}srcCr)z@ HTTP headers to include when sending requests. )_headersrrBrBrCrwrzBaseClient.headersr%cCs2tdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)r\rwZclient_headersrBrBrCrws  rcCr)zA Cookie values to include when sending requests. )rrrBrBrCrx)rzBaseClient.cookiesr$cCrrV)rr)r\rxrBrBrCrx0rr2cCr)zO Query parameters to include in the URL when sending requests. )rrrBrBrCrv4rzBaseClient.paramsr(cCrrV)r2r)r\rvrBrBrCrv;r) contentdatafilesjsonrvrwrxry extensionsmethodrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NoneTimeoutTypes | UseClientDefaultrRequestExtensions | Nonerc 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 Nry)rrrrrvrwrxrrB) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr=ryrras_dictr) r\rrrrrrrvrwrxryrrBrBrC 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)r1is_relative_urlr}rlstripr)r\rZ merge_urlZmerge_raw_pathrBrBrCrrs  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. )rxrr)r\rxmerged_cookiesrBrBrCrs   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. )rrwr)r\rwZmerged_headersrBrBrCrs  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. )rvr2merge)r\rvZmerged_queryparamsrBrBrCrs   zBaseClient._merge_queryparamscCsX|durdSt|trt|d|ddSt|tr|St|r%t|dStd|)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler rcallabler TypeErrorrrBrBrCrs   zBaseClient._build_authr#AuthTypes | UseClientDefault | NonercCsRt|tr|jn||}|dur|S|jj|jj}}|s |r&t||dStS)Nr) rr=rrrrrr r)r\rrurrrBrBrC_build_request_auths zBaseClient._build_request_authrQrcCsR|||}|||}||||}|||}t|j}t||||||jdS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrrwrxrPr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrxrr)r\rrQrrrwrPrxrBrBrC_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)r\rrQrrBrBrCrszBaseClient._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. ZLocationz Invalid URL in location header: .rN)host)fragment) rwr1rrschemerrrrjoinr)r\rrQlocationrexcrBrBrCrs$     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) rrwr7rr6popnetlocdecoder)r\rrrrwrBrBrCr s       zBaseClient._redirect_headers'SyncByteStream | AsyncByteStream | NonecCs||jkr |dkr dS|jS)zO Return the body that should be used for the redirect request. rN)rrP)r\rrrBrBrCr(szBaseClient._redirect_stream)rurrvrrwrrxrryr.rzrr{rr|rr}r/r~rrrrSrT)rSr)rr1rSr1)rrrrrSr)rSr)ryr.rSrT)rSr)r|rrSrT)rSr)rur"rSrT)rSr1)rr/rSrT)rSr)rwr%rSrT)rSr)rxr$rSrT)rSr2)rvr(rSrT)rrrr/rrrrrrrrrvrrwrrxrryrrrrSr)rr/rSr1rV)rxrrSr)rwrrSr)rvrrSr)rurrSr)rrrurrSr)rrrQrrSr)rrrQrrSr)rrrQrrSr1)rrrr1rrrSr)rrrrrSr) r>r?r@r r r]propertyrr~rrrysetterr|rur}rwrxrvUSE_CLIENT_DEFAULTrrrrrrrrrrrrrBrBrBrCrqs"                   3       rqcseZdZdZdddddddddddedeeddddddddfd1d2Zddddedddfdd4d5Zddddedfdd7d8Z dd;d<Z ddddddde e e dd= ddNdOZ e ddddddde e e dd= ddQdRZde e dSddWdXZdd\d]Zdd^d_Zdd`daZddde e e ddbddddeZddde e e ddbddfdgZddde e e ddbddhdiZddddddde e e dd= ddjdkZddddddde e e dd= ddldmZddddddde e e dd= ddndoZddde e e ddbddpdqZddrdsZddvdwZ   ddd~dZZS)r9a 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). * **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. * **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". NTFrrrsrurvrwrxverifycerthttp1http2rrmountsryrzlimitsr{r|r} transportappr~rrurrvrrwrrxrrr0rCertTypes | NonerrrrProxyTypes | Nonerrr0None | typing.Mapping[str, BaseTransport | None]ryr.rzrrr{rr|rr}r/rBaseTransport | Noner'typing.Callable[..., typing.Any] | Noner~rrrSrTc stj||||| | ||||d r&zddl}Wn ty%tddw| r6d}t|t| r6td|r@d}t|toI|duoI|du}| pO| |}j ||d_ fdd | D_ | durj d d | Dttj _ dS) NrtruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.JThe 'proxies' argument is now deprecated. Use 'proxy' or 'mounts' instead.*Use either `proxy` or 'proxies', not both.zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=WSGITransport(app=...)' instead.rrrrrrrr~c :i|]\}}t||durdn j|dqSNrrrrrr~r4_init_proxy_transportrErFrrrrrr\r~rrBrCr z#Client.__init__..cSi|] \}}t||qSrBr4rErFrrBrBrCrsuperr]h2 ImportErrorwarningswarnDeprecationWarning RuntimeErrorr_init_transport _transportr_mountsrrsortedr\rurvrwrxrrrrrrrryrzrr{r|r}rrr~rrmessagerZ proxy_map __class__rrCr]jsj      zClient.__init__rc C2|dur|S|durt|dSt||||||dSN)rr )r r r\rrrrrrrr~rBrBrCr  zClient._init_transportrc Ct|||||||dSN)rrrrrr~r)rr\rrrrrrr~rBrBrCr zClient._init_proxy_transportrr1cC>|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. Nr!rmatchesr r\rpatternrrBrBrC_transport_for_url  zClient._transport_for_url rrrrrvrwrxrurzryrrrrrrrrrrrrbool | UseClientDefaultrrrrc  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 NSetting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead. rrrrrrrvrwrxryrrurzrrrrsendr\rrrrrrrvrwrxrurzryrr$rrBrBrCrs$!  zClient.requesttyping.Iterator[Response]c  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)rrurzrPN)rr=rir\rrrrrrrvrwrxrurzryrrrQrBrBrCrP=s. z Client.streamrPrurzrrrPc 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.rurzhistoryN) rrHrMrrLrr=rzr_send_handling_authread BaseExceptionrir\rrPrurzrQrrBrBrCr=qs.  z Client.sendrrElist[Response]c Cs||}zLt|} |j|||d}z+z||}Wnty,|YWW|Swt||_||}| |Wnt yP}z||d}~wwq |wNT)rzrE) Zsync_auth_flownext_send_handling_redirectsr= StopIterationrirrErGappendrH r\rrurzrEZ auth_flowrQ next_requestrrBrBrCrFs6      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.rrrQ) lenr{rr_send_single_requestrrEhas_redirect_locationrrGrQrHrir\rrzrEhookrQrrBrBrCrMs6       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.rNrQrRHTTP Request: %s %s "%s %d %s")r5rr3Z sync_startrrPr-rrhandle_requestrrOrxextract_cookiesrrloggerinfor http_versionr reason_phraser\rrrRrQrBrBrCrTs4      zClient._send_single_requestrvrwrxrurzryrAuthTypes | UseClientDefaultc C|jd||||||||d S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrbr r\rrvrwrxrurzryrrBrBrCr z Client.getc Crd)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrbrrfrBrBrCoptions*rgzClient.optionsc Crd)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrbrrfrBrBrCheadGrgz Client.headc C$|jd||||||||| | | | d S)V Send a `POST` request. **Parameters**: See `httpx.request`. rr7r r\rrrrrrvrwrxrurzryrrBrBrCpostdz Client.postc Crm)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTr7rrorBrBrCputrqz Client.putc Crm)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHr7rrorBrBrCpatchrqz Client.patchc Crd)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErbrrfrBrBrCdeletergz Client.deletecCsF|jtjkrtj|_|j|jD] }|dur|qdSdSz. Close transport and proxies. N)rrHrMr rir!values)r\rrBrBrCris  z Client.closer\r8cCs`|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.) rrHrKrLrMrr  __enter__r!r|)r\msgrrBrBrCr~s  zClient.__enter__exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonecCsBtj|_|j||||jD] }|dur||||qdSrV)rHrMrr __exit__r!r|)r\rrrrrBrBrCrszClient.__exit__),rurrvrrwrrxrrr0rrrrrrrrrrrrryr.rzrrrr{rr|rr}r/rrrrr~rrrrSrT)rr0rrrrrrrrrrrrr~rrSr)rrrr0rrrrrrrrr~rrSr)rr1rSrrrrr/rrrrrrrrrvrrwrrxrrurrzr8ryrrrrSr)rrrr/rrrrrrrrrvrrwrrxrrurrzr8ryrrrrSr? rrrPrrurrzr8rSr rrrurrzrrErJrSrrrrzrrErJrSrrrrSrrr/rvrrwrrxrrurcrzr8ryrrrrSrrr/rrrrrrrrrvrrwrrxrrurcrzr8ryrrrrSrrk)r\r8rSr8NNNrrrrrrrSrT)r>r?r@rAr r r r]rrr5rrrrPr=rFrMrTrrjrlrprtrwrzrir~r __classcell__rBrBr%rCr94s&8d  87 1 " %(!!!)))  cseZdZdZdddddddddddedeeddddddddfd1d2Zddddedddfdd4d5Zddddedfdd7d8Z dd;d<Z ddddddde e e dd= ddNdOZ e ddddddde e e dd= ddRdSZde e dTddXdYZdd]d^Zdd_d`ZddadbZddde e e ddcddddeZddde e e ddcddfdgZddde e e ddcddhdiZddddddde e e dd= ddjdkZddddddde e e dd= ddldmZddddddde e e dd= ddndoZddde e e ddcddpdqZddrdsZddvdwZ   ddd~dZZS)r<a 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)* 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`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **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". NTFrrrsrrurrvrrwrrxrrr0rrrrrrrrrr5None | typing.Mapping[str, AsyncBaseTransport | None]ryr.rzrrr{rr|BNone | typing.Mapping[str, list[typing.Callable[..., typing.Any]]]r}r/rAsyncBaseTransport | Nonerrr~rrrSrTc stj||||| | ||||d r&zddl}Wn ty%tddw| r6d}t|t| r6td|r@d}t|toE|du}| pK| |}j ||d_ fdd | D_ | durj d d | Dttj _ dS) Nrtrrrr zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=ASGITransport(app=...)' instead.r c r r rrrrBrCrrz(AsyncClient.__init__..cSrrBrrrBrBrCrrrr#r%rrCr]Ssj       zAsyncClient.__init__rc Cr'r()rrr)rBrBrCrr*zAsyncClient._init_transportrc Cr+r,)rr-rBrBrCrr.z!AsyncClient._init_proxy_transportrr1cCr/r0r1r3rBrBrCr5r6zAsyncClient._transport_for_urlr7rrrrrrrrrrrr8rrrrc  sP| dur d}t|t|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 Nr9r:r;r<r>rBrBrCrs&"  zAsyncClient.requestrctyping.AsyncIterator[Response]c  Csf|j||||||||| | | d }|j|| | ddIdH}z |VW|IdHdS|IdHwr@)rr=rprArBrBrCrP(s.  "zAsyncClient.streamrBrrrPc 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 rCrDN) rrHrMrrLrr=rzrrFareadrHrprIrBrBrCr=\s0   zAsyncClient.sendrrErJc s||}z^|IdH} |j|||dIdH}z4z ||IdH}Wnty9|YWW|IdHSwt||_|IdH|}| |Wnt yc}z |IdH|d}~wwq|IdHwrK) Zasync_auth_flow __anext__rMasendStopAsyncIterationrprrErrOrHrPrBrBrCrFs8      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}~wwqrR) rSr{rrrTrrErUrrrQrHrprVrBrBrCrMs8   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)rXNz?Attempted to send an sync request with an AsyncClient instance.rrYrZ)r5rr3Z async_startrrPr!rrZhandle_async_requestrrmrxr\rrr]r^rr_rr`rarBrBrCrTs6     z AsyncClient._send_single_requestrbc $|jd||||||||d IdHS)rerrbNrrfrBrBrCr zAsyncClient.getc r)rhrirbNrrfrBrBrCrjrzAsyncClient.optionsc r)rkrrbNrrfrBrBrCrl2rzAsyncClient.headc ,|jd||||||||| | | | d IdHS)rnrr7NrrorBrBrCrpO  zAsyncClient.postc r)rrrsr7NrrorBrBrCrttrzAsyncClient.putc r)rurvr7NrrorBrBrCrwrzAsyncClient.patchc r)rxryrbNrrfrBrBrCrzrzAsyncClient.deletecsT|jtjkr&tj|_|jIdH|jD]}|dur%|IdHqdSdSr{)rrHrMr rpr!r|)r\rrBrBrCrps zAsyncClient.acloser\r;csn|jtjkrtjdtjdi|j}t|tj|_|jIdH|j D] }|dur4|IdHq'|Sr}) rrHrKrLrMrr  __aenter__r!r|)r\rrrBrBrCrs  zAsyncClient.__aenter__rrrrrrcsPtj|_|j|||IdH|jD]}|dur%||||IdHqdSrV)rHrMrr  __aexit__r!r|)r\rrrrrBrBrCrszAsyncClient.__aexit__),rurrvrrwrrxrrr0rrrrrrrrrrrrryr.rzrrrr{rr|rr}r/rrrrr~rrrrSrT)rr0rrrrrrrrrrrrr~rrSr)rrrr0rrrrrrrrr~rrSr)rr1rSrr)rrrr/rrrrrrrrrvrrwrrxrrurcrzr8ryrrrrSrrrrr)rr/rvrrwrrxrrurrzr8ryrrrrSrrrrk)r\r;rSr;rr)r>r?r@rAr r r r]rrr5rrrrPr=rFrMrTrrjrlrprtrwrzrprrrrBrBr%rCr<s&9e  97 1 " &'!!!)))  )_ __future__rrfenumloggingtypingr contextlibrrtypesrrrrr r _configr r r rrr _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/r0Z_urlsr1r2_utilsr3r4r5r6r7TypeVarr8r;r=r getLoggerr]rrkeysrEnumrHrOrmCallableAnyZ EventHookrqr9r<rBrBrBrCs\        H   m