o 6Wj@s`ddlmZddlZddlZddlZddlZddlZddlZddlm 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@ejArddlBZBgdZCejDdddZEejDdddZFd7ddZGd8d d!ZHd9d#d$ZIGd%d&d&ZJeJZKeLd'ZMd(e ZNd)Od*d+ePDZQGd,d-d-ejRZSGd.d/d/e9ZTGd0d1d1e.ZUejVd2ejWfZXGd3d4d4ZYGd5ddeYZZGd6ddeYZ[dS):) 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)boundUr1urlr,locationreturnboolcCs<|j|jkrdS|jdkot|dko|jdkot|dkS)zA Return 'True' if 'location' is a HTTPS upgrade of 'url' FhttpPhttps)hostscheme_port_or_default)r6r7rA\/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/httpx/_client.py_is_https_redirect>s    rC int | NonecCs"|jdur|jSddd|jS)Nr;r=)r:r<)portgetr?r6rArArBr@Ms r@othercCs(|j|jko|j|jkot|t|kS)z@ Return 'True' if the given URLs share the same origin. )r?r>r@)r6rHrArArB _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 ysrSc@seZdZdZdZdZdS) ClientStaterN)rKrLrMUNOPENEDOPENEDCLOSEDrArArArBrT}srTc@.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*responserstartfloatr8NonecC||_||_||_dSN_stream _response_startselfr\r]r^rArArB__init__ zBoundSyncStream.__init__typing.Iterator[bytes]ccs|jD]}|VqdSrbrdrhchunkrArArB__iter__s zBoundSyncStream.__iter__cCs,t|j}tj|d|j_|jdSN)seconds) time perf_counterrfdatetime timedeltareelapsedrdcloserhrvrArArBrwszBoundSyncStream.closeN)r\r*r]rr^r_r8r`)r8rkr8r`)rKrLrMrNrirorwrArArArBr[   r[c@rZ)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. r\rr]rr^r_r8r`cCrarbrcrgrArArBrirjzBoundAsyncStream.__init__typing.AsyncIterator[bytes]cCs"|j2z 3dHW}|Vq6dSrbrlrmrArArB __aiter__szBoundAsyncStream.__aiter__cs4t|j}tj|d|j_|jIdHdSrp) rrrsrfrtrurervrdacloserxrArArBr~szBoundAsyncStream.acloseN)r\rr]rr^r_r8r`)r8r|ry)rKrLrMrNrir}r~rArArArBr{rzr{.c @seZdZddddededdddd d|ddZed}d d!Zed}d"d#Zd~d&d'Z dd,d-Z edd/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 dddddeZddfdgZefddkdlZddodpZddqdrZddsdtZddudvZddxdyZddzd{Z dS) BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingrAuthTypes | NonerQueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr+rr9rintr+None | typing.Mapping[str, list[EventHook]]r URL | strrr#str | typing.Callable[[bytes], str]r8r`c Cs|durin|}|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_encodingrTrW_state) rhrrrrrrrrrrrrArArBris      zBaseClient.__init__cCs |jtjkS)z2 Check if the client being closed )rrTrYrhrArArB is_closeds zBaseClient.is_closedcC|jSrb)rrrArArBrzBaseClient.trust_envr6r,cCs"|jdr|S|j|jddS)N/raw_path)rendswith copy_withrhr6rArArBrs z"BaseClient._enforce_trailing_slashproxyProxyTypes | Noneallow_env_proxiesdict[str, Proxy | None]cCsH|dur|rddtDSiSt|ttfrt|dn|}d|iS)NcSs(i|]\}}||dur dnt|dqS)NrG)r)rQrRr6rArArB sz-BaseClient._get_proxy_map..rGzall://)r/items isinstancestrr,r)rhrrrArArB_get_proxy_mapszBaseClient._get_proxy_maprcCrrb)rrrArArBrrzBaseClient.timeoutcCt||_dSrb)rr)rhrrArArBrdict[str, list[EventHook]]cCrrb)rrrArArBrrzBaseClient.event_hookscCs(t|dgt|dgd|_dSr)rrFr)rhrrArArBr s Auth | NonecCr)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrrArArBrs zBaseClient.authr cCs|||_dSrb)rrrhrrArArBrscCr)zK Base URL to use when sending requests with relative URLs. )rrrArArBrzBaseClient.base_urlcCs|t||_dSrb)rr,rrrArArBr&srcCr)z@ HTTP headers to include when sending requests. )_headersrrArArBr*rzBaseClient.headersr#cCs2tdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rhrclient_headersrArArBr1s  rcCr)zA Cookie values to include when sending requests. )rrrArArBr>rzBaseClient.cookiesr"cCrrb)rr)rhrrArArBrErr-cCr)zO Query parameters to include in the URL when sending requests. )rrrArArBrIrzBaseClient.paramsr%cCrrb)r-r)rhrrArArBrPr) contentdatafilesjsonrrrr extensionsmethodrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NoneTimeoutTypes | UseClientDefaultrRequestExtensions | Nonerc Cs||}||}|| } ||}| durin| } d| vr9t| tr(|jnt| } tdi| 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)rrrrrrrrrA) _merge_url_merge_headers_merge_cookies_merge_queryparamsrrJrrdictas_dictr) rhrr6rrrrrrrrrrArArB build_requestTs.    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)rhr6 merge_urlmerge_raw_pathrArArBrs  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. )rrr)rhrmerged_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)rhrmerged_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)rhrmerged_queryparamsrArArBrs   zBaseClient._merge_queryparamscCsX|durdSt|trt|d|ddSt|tr|St|r%t|dStd|)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler rcallabler TypeErrorrrArArBrs   zBaseClient._build_authr#AuthTypes | UseClientDefault | NonercCsRt|tr|jn||}|dur|S|jj|jj}}|s |r&t||dStS)Nr) rrJrrr6rrr r)rhrrrrrArArB_build_request_auths zBaseClient._build_request_authr]rcCsR|||}|||}||||}|||}t|j}t||||||jdS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rr6rrr\r)_redirect_method _redirect_url_redirect_headers_redirect_streamrrrr)rhrr]rr6rr\rrArArB_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)rhrr]rrArArBrszBaseClient._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)r>)fragment) rr,rrr?r>rr6rjoinr)rhrr]r7r6excrArArBrs$     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) rrrIr6rCpopnetlocdecoder)rhrr6rrrArArBr"s       zBaseClient._redirect_headers'SyncByteStream | AsyncByteStream | NonecCs||jkr |dkr dS|jS)zO Return the body that should be used for the redirect request. rN)rr\)rhrrrArArBr=szBaseClient._redirect_streamcCsLd|jvr$t|jtr|jnt|j}tdi|jd|i|_dSdS)NrrA)rrrrJrrr)rhrrrArArB _set_timeoutHs  "zBaseClient._set_timeout)rrrrrrrrrr+rr9rrrrrrrr9rrr8r`)r8r9)r6r,r8r,)rrrr9r8r)r8r)rr+r8r`)r8r)rrr8r`)r8r)rr r8r`)r8r,)r6rr8r`)r8r)rr#r8r`)r8r)rr"r8r`)r8r-)rr%r8r`)rrr6rrrrrrrrrrrrrrrrrrrr8r)r6rr8r,rb)rrr8r)rrr8r)rrr8r)rrr8r)rrrrr8r)rrr]rr8r)rrr]rr8r)rrr]rr8r,)rrr6r,rrr8r)rrrrr8r)rrr8r`)!rKrLrMr r ripropertyrrrrrsetterrrrrrrr0rrrrrrrrrrrrrrArArArBrs"                   3         rcseZdZdZdddddddddddedeedddddd|fd-d.Zdddddedfd}d0d1Zdddddefd~d3d4Z dd7d8Z ddddddde e e dd9 ddJdKZ e ddddddde e e dd9 ddMdNZde e dOddSdTZddXdYZddZd[Zdd\d]Zddde e e dd^dd_d`Zddde e e dd^ddbdcZddde e e dd^ddddeZddddddde e e dd9 ddfdgZddddddde e e dd9 ddhdiZddddddde e e dd9 ddjdkZddde e e dd^ddldmZddndoZddrdsZ   dddzd{ZZS)r2av 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". NTFrr)rrrrverifycertrhttp1http2rmountsrrlimitsrrr transportrrrrrrrrrrssl.SSLContext | str | boolrCertTypes | Nonerr9rrrrr0None | typing.Mapping[str, BaseTransport | None]rr+rr rrrrrrrr BaseTransport | Nonerrr8r`c stj||||| | ||||d r&zddl}Wn ty%tddwo+|du}| |}j|d_fdd|D_| durbj dd| Dt t j_dS)NrruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.rrrrrr r c :i|]\}}t||durdn j|dqSN)rrrrrr r._init_proxy_transportrQrRrrrrr rhrrrArBr z#Client.__init__..cSi|] \}}t||qSrAr.rQrRr rArArBr superrih2 ImportErrorr_init_transport _transportr_mountsrrsorted)rhrrrrrrrrrrrrrr rrrr rrr proxy_map __class__rrBrisT      zClient.__init__rcC |dur|St||||||dSrrrhrrrrrr r rArArBr  zClient._init_transportrc Ct|||||||dSN)rrrrrr rr(rhrrrrrrr rArArBr zClient._init_proxy_transportr6r,cC>|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!rhr6patternr rArArB_transport_for_url  zClient._transport_for_url rrrrrrrrrrrrrrrrrrrrrrbool | UseClientDefaultrrrrc  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.rU stacklevel rr6rrrrrrrrrrrwarningswarnDeprecationWarningrsendrhrr6rrrrrrrrrrrmessagerrArArBrs$! 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)rrrr\N)rrBrwrhrr6rrrrrrrrrrrrr]rArArBr\;s. z Client.streamr\rrrrr\c Cs|jtjkr tdtj|_t|tr|jn|}||| ||}|j |||gd}z |s3| |WSt yG}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/clients/#request-instances 5Cannot send a request, as the client has been closed.rrhistoryN)rrTrY RuntimeErrorrXrrJrrr_send_handling_authread BaseExceptionrwrhrr\rrr]rrArArBrBos0   z Client.sendrrKlist[Response]c Cs||}zLt|} |j|||d}z+z||}Wnty,|YWW|Swt||_||}| |Wnt yP}z||d}~wwq |wNT)rrK) sync_auth_flownext_send_handling_redirectsrB StopIterationrwrrKrNappendrO rhrrrrK auth_flowr] next_requestrrArArBrMs6      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.rrr]) lenrrr_send_single_requestrrKhas_redirect_locationrrNrZrOrwrhrrrKhookr]rrArArBrUs6       zClient._send_handling_redirectscCs||j}t}t|jtstdt|d | |}Wdn1s)wYt|jts6J||_ 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]r^HTTP Request: %s %s "%s %d %s")r5r6rrrsrr\r*rLrhandle_requestrr[rextract_cookiesrrloggerinfor http_versionr reason_phraserhrr r^r]rArArBr]s2      zClient._send_single_requestrrrrrrrc C|jd||||||||d S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrkr rhr6rrrrrrrrArArBrF z Client.getAuthTypes | UseClientDefaultc Crl)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrkrrnrArArBoptions)rozClient.optionsc Crl)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrkrrnrArArBheadFroz Client.headc C$|jd||||||||| | | | d S)V Send a `POST` request. **Parameters**: See `httpx.request`. rr7r rhr6rrrrrrrrrrrrArArBpostcz Client.postc Crv)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTr7rrxrArArBputrzz Client.putc Crv)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHr7rrxrArArBpatchrzz Client.patchc Crl)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErkrrnrArArBdeleteroz Client.deletecCsF|jtjkrtj|_|j|jD] }|dur|qdSdSz. Close transport and proxies. N)rrTrYr!rwr"values)rhr rArArBrws  z Client.closerhr3cCs`|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.) rrTrWrXrYrLr! __enter__r"r)rhmsgr rArArBrs  zClient.__enter__exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonecCsBtj|_|j||||jD] }|dur||||qdSrb)rTrYrr!__exit__r"r)rhrrrr rArArBr szClient.__exit__)(rrrrrrrrrr rr rr9rr9rr9rrrr rr+rr9r rrrrrrrr rrrr8r`)rr rr rr9rr9rr9r rr rr8r)rrrr rr rr9rr9rr9r rr8r)r6r,r8rrrr6rrrrrrrrrrrrrrrrrrr8rrrrr8r)rrr6rrrrrrrrrrrrrrrrrrr8rrrrr8rE rrr\r9rrrr8r8r rrrrrr9rKrQr8rrrrr9rKrQr8rrrr8rr6rrrrrrrrrrr8rrrrr8rr6rrrrrrrrrprr8rrrrr8rr6rrrrrrrrrrrrrrrrrprr8rrrrr8rry)rhr3r8r3NNNrrrrrrr8r`)rKrLrMrNr r r rir rr5r0rrr\rBrMrUr]rFrsruryr}rrrwrr __classcell__rArAr%rBr2Rs /Q  87 3 " %'!!!)))  cseZdZdZddddddddddedeeddddddd|fd-d.Zdddddedfd}d0d1Zdddddefd~d3d4Z dd7d8Z ddddddde e e dd9 ddJdKZ e ddddddde e e dd9 ddMdNZde e dOddSdTZddXdYZddZd[Zdd\d]Zddde e e dd^dd_d`Zddde e e dd^ddbdcZddde e e dd^ddddeZddddddde e e dd9 ddfdgZddddddde e e dd9 ddhdiZddddddde e e dd9 ddjdkZddde e e dd^ddldmZddndoZddrdsZ   dddzd{ZZS)r1a 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". NTFrr)rrrrrrrrrrrrr rrrr rrrrrrrrrrrr rr rr9rrrr5None | typing.Mapping[str, AsyncBaseTransport | None]rr+rr rrrrrrrr AsyncBaseTransport | Nonerrrr8r`c stj||||| | ||||d r&zddl}Wn ty%tddwo+|du}| |}j|d_fdd|D_| durbj dd| Dt t j_dS)Nrrrrc rrrrrrArBrrz(AsyncClient.__init__..cSrrArrrArArBrrr)rhrrrrrrrrrrrrr rrrr rrrrr$r%rrBriIsT      zAsyncClient.__init__rcCr'rrr)rArArBr r*zAsyncClient._init_transportrc Cr+r,rr-rArArBrr.z!AsyncClient._init_proxy_transportr6r,cCr/r0r1r3rArArBr5r6zAsyncClient._transport_for_urlr7rrrrrrrrrrrr8rrrrc  sT| 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 Nr9rUr:r<r=r>rCrArArBrs&" zAsyncClient.requesttyping.AsyncIterator[Response]c  Csf|j||||||||| | | d }|j|| | ddIdH}z |VW|IdHdS|IdHwrF)rrBr~rGrArArBr\s.  "zAsyncClient.streamrHrrr\c s|jtjkr tdtj|_t|tr|jn|}||| ||}|j |||gdIdH}z |s:| IdH|WSt yQ}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/clients/#request-instances rIrJN)rrTrYrLrXrrJrrrrMareadrOr~rPrArArBrB:s2    zAsyncClient.sendrrKrQc s||}z^|IdH} |j|||dIdH}z4z ||IdH}Wnty9|YWW|IdHSwt||_|IdH|}| |Wnt yc}z |IdH|d}~wwq|IdHwrR) async_auth_flow __anext__rUasendStopAsyncIterationr~rrKrrWrOrXrArArBrMms8      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}~wwqr[) r\rrrr]rrKr^rrrZrOr~r_rArArBrUs8   z$AsyncClient._send_handling_redirectscs||j}t}t|jtstdt|d| |IdH}Wdn1s-wYt|jts:J||_ t |j||d|_|j ||j|_td|j|j|j|j|j|S)raz?Attempted to send an sync request with an AsyncClient instance.rNrbrc)r5r6rrrsrr\rrLrhandle_async_requestrr{rrerrrfrgrrhrrirjrArArBr]s4     z AsyncClient._send_single_requestrkc $|jd||||||||d IdHS)rmrrkNrrnrArArBrF zAsyncClient.getrpc r)rqrrrkNrrnrArArBrsrzAsyncClient.optionsc r)rtrrkNrrnrArArBrurzAsyncClient.headc ,|jd||||||||| | | | d IdHS)rwrr7NrrxrArArBry.  zAsyncClient.postc r)r{r|r7NrrxrArArBr}SrzAsyncClient.putc r)r~rr7NrrxrArArBrxrzAsyncClient.patchc r)rrrkNrrnrArArBrrzAsyncClient.deletecsT|jtjkr&tj|_|jIdH|jD]}|dur%|IdHqdSdSr)rrTrYr!r~r"r)rhrrArArBr~s zAsyncClient.acloserhr5csn|jtjkrtjdtjdi|j}t|tj|_|jIdH|j D] }|dur4|IdHq'|Sr) rrTrWrXrYrLr! __aenter__r"r)rhrrrArArBrs  zAsyncClient.__aenter__rrrrrrcsPtj|_|j|||IdH|jD]}|dur%||||IdHqdSrb)rTrYrr! __aexit__r"r)rhrrrrrArArBrszAsyncClient.__aexit__)(rrrrrrrrrr rr rr9rr9rrrrrr+rr9r rrrrrrrr rrr9rrr8r`)rr rr rr9rr9rr9r rr rr8r)rrrr rr rr9rr9rr9r rr8r)r6r,r8rr)rrr6rrrrrrrrrrrrrrrrrrr8rrrrr8rrrrrrrrry)rhr5r8r5rr)rKrLrMrNr r r rir rr5r0rrr\rBrMrUr]rFrsruryr}rrr~rrrrArAr%rBr1s 0Q  97 3 " &&!!!)))  )r6r,r7r,r8r9)r6r,r8rD)r6r,rHr,r8r9)\ __future__rrtenumloggingrrtypingr? contextlibrrtypesrrrrr r _configr r r rrr _decodersr _exceptionsrrrr_modelsrrrr _status_codesr_transports.baserr_transports.defaultrr_typesrr r!r"r#r$r%r&r'r(r)r*r+_urlsr,r-_utilsr.r/ TYPE_CHECKINGssl__all__TypeVarr3r5rCr@rIrJr0 getLoggerrfrrkeysrEnumrTr[r{CallableAny EventHookrr2r1rArArArBsf      <      N