
    i*                    l   d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl	m
Z
 d dlmZ d dlmZmZ ddlmZ ej        rd d	lmZ dd
lmZmZ ddlmZmZmZmZ ddlmZmZ ddl m!Z!m"Z"m#Z#m$Z$ ddl%m&Z&m'Z'm(Z(m)Z) ddl*m+Z+m,Z, ddl-m.Z. ddl/m0Z0 ddl1m2Z2m3Z3 ddl4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z: ddl;m<Z< ddl=m>Z> ddl?m@Z@ ddlAmBZBmCZC ddlDmEZEmFZF ddlmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZY ddlZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbmcZcmdZd eje        dk    rejf        Zgnej        Zg G d deB          ZhdS )    )annotationsN)OrderedDict)	timedelta)	CookieJar)urljoinurlparse   )codes)Literal)HAS_LEGACY_URLLIB3urllib3_ensure_type)DEFAULT_POOLSIZEDEFAULT_RETRIESREAD_DEFAULT_TIMEOUTWRITE_DEFAULT_TIMEOUT)AsyncBaseAdapterAsyncHTTPAdapter)RequestsCookieJarcookiejar_from_dictextract_cookies_to_jarmerge_cookies)ChunkedEncodingErrorContentDecodingErrorInvalidSchemaTooManyRedirects)DEFAULT_STRATEGYRevocationConfiguration)AsyncServerGatewayInterface)AsyncUnixAdapter)async_dispatch_hookdefault_hooks)DEFAULT_REDIRECT_LIMITAsyncResponsePreparedRequestRequestResponseTransferProgress)ConnectionInfo)AsyncBaseResolver)load_extension)Sessionmerge_hooks)AsyncQuicSharedCacheCaseInsensitiveDict)ASGIAppAsyncBodyTypeAsyncHookTypeAsyncHttpAuthenticationTypeAsyncResolverTypeBodyTypeCacheLayerAltSvcTypeCookiesTypeHeadersTypeHttpAuthenticationTypeHttpMethodTypeMultiPartFilesAltTypeMultiPartFilesType	ProxyTypeQueryParameterType	RetryTypeTimeoutTypeTLSClientCertTypeTLSVerifyType)
_deepcopy_ci_swap_contextcreate_async_resolverdefault_headersparse_schemerequote_uriresolve_proxiesrewind_bodyshould_check_crlshould_check_ocspwin32c                      e Zd ZdZdddeddddddeedddddddedddd*Zdd-Zdd/Z	dd0Z
dd2Zd3 Zd fd7Zdd9Zdd?Z	 	 	 	 	 	 	 dddPZej        	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddde            Zej        	 	 	 	 	 	 	 	 	 	 	 	 	 	 dddg            Z	 	 	 	 	 	 	 	 	 	 	 	 	 	 dddiZej        dQdQdQdQdQdQdQdQdQdQdQdjddk            Zej        dQdQdQdQdQdQdQdQdQdQdQdjddl            Zdddddd@ddddddjddmZej        dQdQdQdQdQdQdQdQdQdQdQdjddo            Zej        dQdQdQdQdQdQdQdQdQdQdp
ddq            Zdddddd@ddddddjddrZej        dQdQdQdQdQdQdQdQdQdQdQdjdds            Zej        dQdQdQdQdQdQdQdQdQdQdp
ddt            ZddddddddddddjdduZej        	 	 ddQdQdQdQdQdQdQdQdQdQdQdQdvddw            Zej        	 	 ddQdQdQdQdQdQdQdQdQdQdQdxddy            Z	 	 dddddddd@ddddddvddzZej        	 ddQdQdQdQdQdQdQdQdQdQdQdQdQd{dd|            Zej        	 ddQdQdQdQdQdQdQdQdQdQdQdQd}dd~            Z	 ddddddddd@dddddd{ddZej        	 ddQdQdQdQdQdQdQdQdQdQdQdQdQd{dd            Zej        	 ddQdQdQdQdQdQdQdQdQdQdQdQd}dd            Z	 ddddddddd@dddddd{ddZej        dQdQdQdQdQdQdQdQdQdQdQdjdd            Zej        dQdQdQdQdQdQdQdQdQdQdp
dd            Zdddddd@ddddddjddZddddZddZ xZS )AsyncSessiona  A Requests asynchronous session.

    Provides cookie persistence, connection-pooling, and configuration.

    Basic Usage::

      >>> import niquests
      >>> s = niquests.AsyncSession()
      >>> await s.get('https://httpbin.org/get')
      <Response HTTP/2 [200]>

    Or as a context manager::

      >>> async with niquests.AsyncSession() as s:
      ...     await s.get('https://httpbin.org/get')
      <Response HTTP/2 [200]>
    NFg      @g      N@)resolversource_addressquic_cache_layerretriesmultiplexeddisable_http1disable_http2disable_http3disable_ipv6disable_ipv4pool_connectionspool_maxsizehappy_eyeballskeepalive_delaykeepalive_idle_windowbase_urltimeoutheadershooksrevocation_configurationapprO   AsyncResolverType | NonerP   tuple[str, int] | NonerQ   CacheLayerAltSvcType | NonerR   r>   rS   boolrT   rU   rV   rW   rX   rY   intrZ   r[   
bool | intr\   float | int | Noner]   r^   
str | Noner_   TimeoutType | Noner`   HeadersType | Nonera   @AsyncHookType[PreparedRequest | Response | AsyncResponse] | Nonerb   RevocationConfiguration | Nonerc   ASGIApp | Nonec                  |
|	g                     d          dk    rt          d          || _        | j        rXt          rQt	          | j        d          r<dt          t          | j                            vrt          | j                  | _        |t          |          nt                      | _
        d | _        i | _        |t          t                      |          nt                      | _        i | _        d| _        || _        t'          |          | _        || j        k    | _        || _        || _        || _        || _        || _        |
| _        |	| _        || _        || _        || _        || _         || _!        d| _"        d | _#        tH          | _%        d| _&        || _'        tQ          i d          | _)        ||ntU          d	          | _+        d | _,        d | _-        || _.        t_                      | _0        | 1                    d
te          | j+        |||||||
|	||||||                     | 1                    dte          |||||||
|	||||||                     | 1                    dtg          |||||||
|	||||||                     |5| 1                    dti          ||                     | j'        d| _'        d S d S d S )NT   z!Cannot disable both IPv4 and IPv6totalurllib3_futureF)thread_freei 0  )max_sizehttps://rQ   max_retriesrT   rU   rV   rO   rP   rX   rW   rY   rZ   r[   r\   r]   rb   http://ry   rT   rU   rV   rO   rP   rX   rW   rY   rZ   r[   r\   r]   rb   http+unix://zasgi://default)rc   ry   )5countRuntimeErrorrR   r   hasattrstrtyper   r.   rE   r`   authproxiesr,   r!   ra   paramsstreamrS   rD   rO   _own_resolverr_   rP   _disable_http1_disable_http2_disable_http3_disable_ipv4_disable_ipv6_pool_connections_pool_maxsize_happy_eyeballs_keepalive_delay_keepalive_idle_windowverifycertr"   max_redirects	trust_envr^   r   cookiesr-   rQ   _ocsp_cache
_crl_cache_revocation_configurationr   adaptersmountr   r   r   )selfrO   rP   rQ   rR   rS   rT   rU   rV   rW   rX   rY   rZ   r[   r\   r]   r^   r_   r`   ra   rb   rc   s                         Q/root/projects/butler/venv/lib/python3.11/site-packages/niquests/async_session.py__init__zAsyncSession.__init__s   s   2 ,'--d33q88BCCC  L	="	= g..	= !D,>,>(?(???.t|<<DL
 8?7J*7333P_PaPa 	
 #%
   /// 	
 +-  ' ,A+J+J#+t}#<  -+++))!1)- /&;# &* /3	 #9  $ %- 7J"Z^6_6_6_
 5E4P 0 0VjtzV{V{V{
 /3
 .2 Jb& =HMM

!%!6#+++!-))!1)- /&;)A  	
 	
 	
( 	

#+++!-))!1)- /&;)A  	
 	
 	
& 	

#+++!-))!1)- /&;)A  	
 	
 	
& ?JJ + '     }$ 0 ? %$    returnr   c                j    dt          | j                                      dd          d d          dS )Nz<AsyncSession zOrderedDict( >)reprr   replacer   s    r   __repr__zAsyncSession.__repr__N  s9    WT] 3 3 ; ;NB O OPSQSPS TWWWWr   typing.NoReturnc                     t          d          )NzOYou probably meant "async with". Did you forget to prepend the "async" keyword?)SyntaxErrorr   s    r   	__enter__zAsyncSession.__enter__Q  s    klllr   c                
   K   | S N r   s    r   
__aenter__zAsyncSession.__aenter__T  s      r   Nonec                >   K   |                                   d {V  d S r   )close)r   excvaluetbs       r   	__aexit__zAsyncSession.__aexit__W  s,      jjllr   c                6   |                                 D ]\  }}t          | ||           t          d           | _        d| _        t                      | _        |                     dt          | j	        | j
        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j                             |                     dt          | j
        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j                             |                     dt/          | j
        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j                             | j                                        D ]:}t3          |d          r| j        |_        t3          |d          r| j        |_        ;d S )	NTrw   )rQ   ry   rT   rU   rV   rP   rX   rW   rO   rY   rZ   r[   r\   r]   rb   rz   )ry   rT   rU   rV   rP   rX   rW   rO   rY   rZ   r[   r\   r]   rb   r|   r   r   )itemssetattrrD   rO   r   r   r   r   r   rQ   rR   r   r   r   rP   r   r   r   r   r   r   r   r   r   valuesr   r   r   )r   stateattrr   adapters        r   __setstate__zAsyncSession.__setstate__Z  s8    ;;== 	' 	'KD%D$&&&&-d33!#

!%!6 L"1"1"1#2!/!/!%!7!/#3 $ 5&*&A)-)G  	
 	
 	
( 	

 L"1"1"1#2!/!/!%!7!/#3 $ 5&*&A)-)G  	
 	
 	
& 	

 L"1"1"1#2!/!/!%!7!/#3 $ 5&*&A)-)G  	
 	
 	
& }++-- 	5 	5Gw.. 7&*&6#w-- 5%)_"		5 	5r   prefixr   r   c                L    t                                          ||           d S r   )superr   )r   r   r   	__class__s      r   r   zAsyncSession.mount  s!    fg&&&&&r   urlc                   | j                                         D ]B\  }}|                                                    |                                          r|c S Ct	          |          }d|v r(t          |                    dd                    \  }}nd }	 t          ||          }| j                                         D ]E\  }}||                                v r*|	                    |          t	          |          k    r|c S Fn# t          $ r Y nw xY w|                    d          s|                    d          rd}nd}t          d	||           )
N+r	   )maxsplit)implementationzws://zwss://z_ Did you forget to install the extra for WebSocket? Run `pip install niquests[ws]` to fix this.r   z&No connection adapters were found for )r   r   lower
startswithrF   tuplesplitr*   supported_schemesscheme_to_http_schemeImportErrorr   )r   r   r   r   schemer   	extensionadditional_hints           r   get_adapterzAsyncSession.get_adapter  s   #}2244 	 	OFGyy{{%%fllnn55 
 c""&==%*6<<a<+H+H%I%I"FNN!N	&vnMMMI#'=#6#6#8#8 # #Y88::::y?^?^_e?f?fjvw}j~j~?~?~"NNN#  	 	 	D	
 >>'"" 	!cnnX&>&> 	!OO O ]S]O]]^^^s   A.D 
D 
DDrequestr$   kwargs
typing.AnyResponse | AsyncResponsec                   K   t          t                    rt          d                              d j                                       d j                                       d j                   dvrt           j         j	                  d<   dv rad         rYt          rRt          d         d          r<dt          t          d                             vrt          d                   d<                       d	d
          }                    d          }j        d/ fd}d0fd}d1fd}                    d|                               d|                               d j                                       d|           j        J  j                                        sĉ j        st/          j        d t2                                                       d{V   j                                         _                             d!t;           j         j         j          j!         j"         j         j#         j$         j%         j&         j'         j(         j)         j*         j+        "                                          d#t;           j         j          j!         j"         j         j#         j$         j%         j&         j'         j(         j)         j*         j+        $                                          d%tY           j         j          j!         j"         j         j#         j$         j%         j&         j'         j(         j)         j*         j+        $                      -                    j        &          }t]                      }	 |j/        fi  d{V }
ta          j1                  _1        t          |
d'          r[|
j2        d
u rR fd(}||
_3        dd<   |
j4        5                    ||	 j6        |d) j7        d*           |stq          |
           |
S t]                      |	z
  }ts          |+          |
_:        tw          d,|
fi  d{V }
|
j<        r*|
j<        D ]"}t{           j6        |j>        |j?                   #t{           j6        |
j?                   |rL  j@        |
fd-d
i}g }|2 3 d{V }t          |t                    r|B                    |           2|56 ng }|rZ|C                    d)|
           |                                }
|D ]&}t          |t                    rtq          |           '||
_<        |s|
jE        r|  j@        |
fd.d
i}	 |F                                 d{V |
_G        n# t          $ r Y nw xY w|I                                 d{V  n# |I                                 d{V  w xY w|sGt          |
t                    r$|
jJ        |
jK         d{V  tq          |
           n|
jJ        |
jK         |
S )2zSend a given PreparedRequest.z#You can only send PreparedRequests.r   r   r   r   r_   rs   rt   allow_redirectsT	conn_infor(   r   r   c           	       K   | 	_         	j        r	j                            d          rd         rt          j                            dd          dk    }|sj        j        j        }t          | j                  r	 ddl	m
} ddl	m} j        G |            _        j                                        D ]}t          |d	          rj        |_         |	||sd
ndd         j        j        j                   d{V  n# t$          $ r Y nw xY wt'          | j                  r	 ddlm} ddlm} j        G |            _        j                                        D ]}t          |d          rj        |_         |	||sd
ndd         j        j        j                   d{V  n# t$          $ r Y nw xY w	
k    rt/          d	           d{V  dS dS )zVThis function will be called by urllib3.future just after establishing the connection.rw   r   NIQUESTS_STRICT_OCSP0Nr	   )InMemoryRevocationStatus)r   r   g?g      ?r   )rO   r[   cache)InMemoryRevocationListr   pre_send)r   r   r   osenvirongetr   strict_moderK   "extensions.revocation._ocsp._asyncr   r   r   r   r   r   rO   r   r   rJ   !extensions.revocation._crl._asyncr   r   r    )r   strict_ocsp_enabledr   ocsp_verifyr   r   
crl_verifyra   r   ptr_requestr   r   s          r   on_post_connectionz-AsyncSession.send.<locals>.on_post_connection  s)      %.K! <;?#=#=j#I#I <fU]N^ <,.JNN;QSV,W,W[^,^#* Ut/M/Y*.*H*T'$Y0NOO             +3/G/G/I/ID,+/=+?+?+A+A K K#*7M#B#B !K:>:JG$7)k'/':CCC"9-%)]+/+?"&"2           '   ( $It/MNN             ?2.D.D.F.FDO+/=+?+?+A+A I I#*7L#A#A !I9=G$6(j'/':CCC"9-%)]+/+?"&/           '   * g%%)*e[IIIIIIIIIII &%s$   D 
DD8G 
GG
total_sentrh   content_length
int | Noneis_completedrg   	any_errorc                   K   k    rd S j         t                      _         | j         _        |j         _        |j         _        |j         _        t          d           d {V  d S )N	on_upload)upload_progressr'   rs   r   r   r   r    )r   r   r   r   ra   r   r   r   s       r   handle_upload_progressz1AsyncSession.send.<locals>.handle_upload_progress/  s       g%%&.*:*<*<',6G#)5CG#23?G#009G#-%k5'BBBBBBBBBBBr   early_responser&   c                :   K   t          d|            d {V  d S )Nr   )r    )r   ra   s    r   on_early_responsez,AsyncSession.send.<locals>.on_early_responseB  s2      %&6~NNNNNNNNNNNr   r   on_upload_bodyrS   r   NzA externally instantiated resolver was closed. Attempt to recycling it internally, the Session will detach itself from given resolver.rw   rx   rz   r{   r|   )r   lazyc                *  K    j         | |fddi}	 |                                 d {V 	 |                                 d {V  S # t          $ r Y |                                 d {V  d S w xY w# |                                 d {V  w xY w)Nyield_requestsT)resolve_redirects	__anext__acloseStopAsyncIteration)xy	aiter_genr   r   s      r   _redirect_method_refz/AsyncSession.send.<locals>._redirect_method_ref  s      2D21aWWWPVWW	-!*!4!4!6!66666666 $**,,,,,,,,,, *      #**,,,,,,,,,,,  $**,,,,,,,,,,s#   A 
A3A6 2A33A6 6Br   )niquests_is_streamniquests_startniquests_hooksniquests_cookiesniquests_allow_redirectniquests_kwargsniquests_redirect_countniquests_max_redirects)secondsresponseyield_requests_trailr   )r   r(   r   r   )
r   rh   r   r   r   rg   r   rg   r   r   )r   r&   r   r   )L
isinstancer%   
ValueError
setdefaultr   r   r   rH   r   r   r   r   r   r   r   popr   ra   rS   r   rO   is_availabler   warningswarnResourceWarningr   recycler   r   rQ   rR   r   r   r   rP   r   r   r   r   r   r   r   r   r   r   preferred_clocksendrB   r   r   _resolve_redirect_promiseupdate_parametersr   r   rC   r   elapsedr    historyr   r   rawr   r&   appendinsertr#   is_redirectr   _nextr   r   r   content)r   r   r   r   r   r   r   r   r   startrr  r  respgenr  resp_or_reqhrra   r   s   ```               @@r   r  zAsyncSession.send  s*      gw'' 	DBCCC 	(DK000(DK000&$),,,F"" /t~ V VF9 y!  "   y)733   !D	1B,C,C(D(DDD 3F94E F FF9 !**%6==H%%E	J E	J E	J E	J E	J E	J E	J E	J E	J E	JN	C 	C 	C 	C 	C 	C 	C 	C 	C&	O 	O 	O 	O 	O 	O 	.0BCCC*,BCCC-)9:::-/@AAA{&&& }))++ B	% J#  
 **,, M1133DMJJ %)%: $"&"5"&"5"&"5!]#'#6!%!3!%!3%)%;!%!3#'#7$($9*.*E-1-K    ( JJ  $"&"5"&"5"&"5!]#'#6!%!3!%!3%)%;!%!3#'#7$($9*.*E-1-K    & JJ  $"&"5"&"5"&"5!]#'#6!%!3!%!3%)%;!%!3#'#7$($9*.*E-1-K    * ""w{"33  !! ',w11&11111111 )):;; 1f #	!&D..- - - - - - #7A ,0F'( J((*0&+&+(,/>'- 01.2.@     !a   H "##e+g...	 &j%EEfEEEEEEEE 9 	M	 M M&t|T\48LLLLt|Wae<<<  	($(GYY$YRXYYCG%( * * * * * * *kk844 NN;///)	 &)S G  	 NN1a   A & &b-00 &!"%%%AI  		'} ',d,QWWWPVWW'$'MMOO333333AGG)   D **,,&&&&&&&&#**,,&&&&&&&& 	!]++ ;&)OOOOOOOa    ;&IIs0   4T)$W W/ 
WW/ WW/ /XTr'  r#   reqr   int | float | Noner   rA   r   TLSClientCertType | Noner   ProxyType | Noner   r  adapter_kwargs<typing.AsyncGenerator[AsyncResponse | PreparedRequest, None]c
           
    V	  K   g }|                      |          }t          |j                  j        }|rs|                                }|                    |           |dd         |_        |j        J 	 t          |t                    r|j
         d{V  n|j
         n># t          t          t          f$ r$ |j                            d           d{V  Y nw xY wt          |j                  | j        k    rt#          d| j         d|          t          |t                    r|                                 d{V  n|                                 |                    d          r]|j        J t)          |j                  }t          |t*                    r|                                }d	                    ||g          }t          |          }|j        d
k    rC|rA|                    t          |t2                    r|n|                    d                    }n|j        r|j        }|                                }|j        sSt9          |j        t;          |                    }t          |t2                    sJ dt=          |           d            nt;          |          }t          |t*                    r|                    d          }||_        |j        J |                      ||           |j!        tD          j#        tD          j$        fvr)d}|D ]}|j        %                    |d           d|_&        |j        }|%                    dd           |j'        J tQ          |j'        ||j                   tS          |j'        | j*                   |+                    |j'                   | ,                    ||          }| -                    ||           |j.        duod|v pd|v }|rt_          |           |}|r|W V  n|	r|W V   | j0        |f|||||dd|
 d{V }tc          |d          r"|j2        r| 3                    |           d{V  tQ          | j*        ||j                   |                      |          }|W V  |qdS dS )zBReceives a Response. Returns a generator of Responses or Requests.r	   NF)decode_contentz	Exceeded z redirects.)r  z//:r   zutf-8)fragmentzurljoin produced z instead of str)Content-LengthzContent-TypeTransfer-EncodingCookier5  r6  )r   r_   r   r   r   r   r   )4get_redirect_targetr   r   r4  copyr   r  r  r  r#   r$  r   r   r~   readlenr   r   r   r   rF   bytesdecodejoin_replacer   geturlnetlocr   rG   r   r`   rebuild_methodstatus_coder
   temporary_redirectpermanent_redirectr  body_cookiesr   r   r   prepare_cookiesrebuild_proxiesrebuild_auth_body_positionrI   r  r   r   gather)r   r'  r+  r   r_   r   r   r   r   r  r/  histr   previous_fragmentprepared_requesttarget_schemeparsedpurged_headersheaderr`   
rewindables                        r   r   zAsyncSession.resolve_redirects  s      &&t,,$SW--6 C	"xxzz KK8DL8''':dM22 !,&&&&&&&&LL(*>M : : :hmm5m99999999999: 4<  D$666&'R43E'R'R'R]abbbb $.. jjll""""""""

 ~~d## 5x+++ ,TX 6 6mU33 ;$1$8$8$:$:Mhhs344 c]]F"$$):$2<=NPS2T2T{..ZkZrZrszZ{Z{ )    4$*O!--//C
 = 'dhC(8(899!#s++[[-[c-[-[-[[[[[!#&& #u%% *jj))#& #+777 0$777 (((  
 "Y, ? ?F$,00>>>>(, %&.GKK$'''#,888 ##3#<c48LLL*3T\BBB,,-=-FGGG **+;WEEG.555
 *8D  G+M/Bg/M 
  .,--- #C 					' IIII&TY	!#!#$)	 	 %	 	 	 	 	 	 	 	 4(( ,TY ,++d+++++++++&t|5EtxPPP ..t44



G  C	 C	 C	 C	 C	s   8*B# #8CC.methodr9   r   QueryParameterType | NonedataBodyType | AsyncBodyType | Noner   CookiesType | Nonefiles1MultiPartFilesType | MultiPartFilesAltType | Noner   ;HttpAuthenticationType | AsyncHttpAuthenticationType | Noner   0AsyncHookType[PreparedRequest | Response] | NoneLiteral[False] | NoneTLSVerifyType | Nonejsontyping.Any | Noner&   c                
   K   d S r   r   r   rU  r   r   rW  r`   r   rZ  r   r_   r   r   ra   r   r   r   r`  s                    r   r   zAsyncSession.request        & 3r   Literal[True]c                
   K   d S r   r   rc  s                    r   r   zAsyncSession.request        & r   bool | Nonec                  K   |                                 du r|                                }t          |||||pi ||pi |||| j                  }|                     |          }|j        rV|                    |           d {V }|j                            |j                   |	                    |j
                   |`t          d|j        |           d {V }|j        J |pi }|                     |j        ||||          }|	p| j        |
d}|                    |           |d         |dv rt           nt"          |d<    | j        |fi | d {V S )NF)rU  r   r`   rZ  rW  r`  r   r   r   ra   r^   pre_request)r_   r   r_   >   PUTPOSTPATCHDELETE)isupperupperr%   r^   prepare_request_asynchronous_auth_pending_async_auth__dict__updateprepare_content_lengthrF  r    ra   r   merge_environment_settingsr_   r   r   r  )r   rU  r   r   rW  r`   r   rZ  r   r_   r   r   ra   r   r   r   r`  r+  prepr&  settingssend_kwargss                         r   r   zAsyncSession.request  s     & >>u$$\\^^F <R]
 
 
 !% 4 4S 9 9" 	)..t44444444AM  ,,,''	222((J
 
 
 
 
 
 
 
 x###-R2248WffVZ[[ .$,.
 
 	8$$$ y!))/3U)U)U%%[o 	" TYt33{333333333r   r   r`   r   r   r_   r   r   ra   r   r   r   c               
   K   d S r   r   r   r   r   r`   r   r   r_   r   r   ra   r   r   r   r   s                 r   r   zAsyncSession.get        " 3r   c               
   K   d S r   r   r}  s                 r   r   zAsyncSession.get         " r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NGETr{  r   r}  s                 r   r   zAsyncSession.get3  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   Literal[False] | Literal[None]c               
   K   d S r   r   r}  s                 r   optionszAsyncSession.optionsU  r~  r   )
r   r`   r   r   r_   r   r   ra   r   r   c               
   K   d S r   r   r}  s                 r   r  zAsyncSession.optionsh  r  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NOPTIONSr{  r  r}  s                 r   r  zAsyncSession.options{  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   r}  s                 r   headzAsyncSession.head  r~  r   c               
   K   d S r   r   r}  s                 r   r  zAsyncSession.head  r  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NHEADr{  r  r}  s                 r   r  zAsyncSession.head  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   )r   r`   r   rZ  r   r_   r   r   ra   r   r   r   c               
   K   d S r   r   r   r   rW  r`  r   r`   r   rZ  r   r_   r   r   ra   r   r   r   s                   r   postzAsyncSession.post  rd  r   )r   r`   r   rZ  r   r_   r   r   ra   r   r   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.post  rg  r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nrl  rW  r`  r   r`   r   rZ  r   r_   r   r   ra   r   r   r   r  r  s                   r   r  zAsyncSession.post  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   )r`  r   r`   r   rZ  r   r_   r   r   ra   r   r   r   c               
   K   d S r   r   r  s                   r   putzAsyncSession.put5  rd  r   )r`  r   r`   r   rZ  r   r_   r   r   ra   r   r   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.putJ  rg  r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nrk  r  r  r  s                   r   r  zAsyncSession.put_  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   r  s                   r   patchzAsyncSession.patch  rd  r   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.patch  rg  r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nrm  r  r  r  s                   r   r  zAsyncSession.patch  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   r}  s                 r   deletezAsyncSession.delete  r~  r   c               
   K   d S r   r   r}  s                 r   r  zAsyncSession.delete  r  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )Nrn  r{  r  r}  s                 r   r  zAsyncSession.delete  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   )	max_fetch	responsesr  r   c               ~   K   | j         du rd S | j                                        D ]} |j        |d|i d {V  d S )NFr  )rS   r   r   rL  )r   r  r  r   s       r   rL  zAsyncSession.gather  sp      u$$F}++-- 	B 	BG '.)AyAAAAAAAAAA	B 	Br   c                   K   | j                                         D ]}|                                 d {V  | j        r!| j                                         d {V  d S d S r   )r   r   r   r   rO   )r   vs     r   r   zAsyncSession.close$  s      %%'' 	 	A''))OOOOOOOO 	(-%%'''''''''''	( 	(r   )*rO   rd   rP   re   rQ   rf   rR   r>   rS   rg   rT   rg   rU   rg   rV   rg   rW   rg   rX   rg   rY   rh   rZ   rh   r[   ri   r\   rj   r]   rj   r^   rk   r_   rl   r`   rm   ra   rn   rb   ro   rc   rp   )r   r   )r   r   )r   rN   )r   r   )r   r   r   r   r   r   )r   r   r   r   )r   r$   r   r   r   r   )FNTNNFF)r'  r#   r+  r$   r   rg   r_   r,  r   rA   r   r-  r   r.  r   rg   r  rg   r/  r   r   r0  )..............)"rU  r9   r   r   r   rV  rW  rX  r`   rm   r   rY  rZ  r[  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   r^  r   r_  r   r-  r`  ra  r   r&   )"rU  r9   r   r   r   rV  rW  rX  r`   rm   r   rY  rZ  r[  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   re  r   r_  r   r-  r`  ra  r   r#   )NNNNNNNTNNNNNN)"rU  r9   r   r   r   rV  rW  rX  r`   rm   r   rY  rZ  r[  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   rh  r   r_  r   r-  r`  ra  r   r   )r   r   r   rV  r`   rm   r   rY  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   r_  r   r^  r   r-  r   r   r   r&   )r   r   r   rV  r`   rm   r   rY  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   r_  r   re  r   r-  r   r   r   r#   )r   r   r   rV  r`   rm   r   rY  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   r_  r   rh  r   r-  r   r   r   r   )r   r   r   rV  r`   rm   r   rY  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   r_  r   r  r   r-  r   r   r   r&   )..) r   r   rW  rX  r`  ra  r   rV  r`   rm   r   rY  rZ  r[  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   r_  r   r  r   r-  r   r&   ) r   r   rW  rX  r`  ra  r   rV  r`   rm   r   rY  rZ  r[  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   r_  r   re  r   r-  r   r#   )NN) r   r   rW  rX  r`  ra  r   rV  r`   rm   r   rY  rZ  r[  r   r\  r_   rl   r   rg   r   r.  ra   r]  r   r_  r   rh  r   r-  r   r   ).r   )r  r&   r  r   r   r   )__name__
__module____qualname____doc__r   r   r   r   r   r   r   r   r   r   r   r  r   typingoverloadr   r   r  r  r  r  r  r  rL  r   __classcell__)r   s   @r   rN   rN   `   sN	        * .2158<,!###"" 0,%*.448#&*&*RVCS"/Y1 Y1 Y1 Y1 Y1 Y1vX X X Xm m m m      F5 F5 F5P' ' ' ' ' '_ _ _ _@| | | |D
 &* $)-$($%*V V V V Vp _
 -003&)&)CFLO&) #$'BE(+'*),"%#    _( _
 -003&)&)CFLO&) #$'BE #'*),"%#    _0 -104&*&*CGLP&* $$(BF"'+)-"&#F4 F4 F4 F4 F4P _
 -0&)&)LO&) #$'BE'*(+),     _$ _
 -0&)&)LO&) #$'BE'* #),     _, -1&*&*LP&* $$(BF'+")- 
  
  
  
  
  
D _
 -0&)&)LO&) #$'BE'*14),     _$ _
 -0&)&)LO&) #$'BE'*),     _, -1&*&*LP&* $$(BF'+")- 
  
  
  
  
  
D _
 -0&)&)LO&) #$'BE'*14),     _$ _
 -0&)&)LO&) #$'BE'*),     _, -1&*&*LP&* %$(BF'+")- 
  
  
  
  
  
D _ 14"%	 -0&)&)CFLO&) #$'BE'*14),#     _( _ 14"%	 -0&)&)CFLO&) #$'BE'*),#     _. 15"&	$
 -1&*&*CGLP&* $$(BF'+")-#$
 $
 $
 $
 $
 $
L _ 14
 #&,/&)&)CFLO&) #$'BE'*14),#     _( _ 14
 #&,/&)&)CFLO&) #$'BE'*),#     _. 15$

 #',0&*&*CGLP&* $$(BF'+")-#$
 $
 $
 $
 $
 $
L _ 14
 #&,/&)&)CFLO&) #$'BE'*14),#     _( _ 14
 #&,/&)&)CFLO&) #$'BE'*),#     _. 15$

 #',0&*&*CGLP&* $$(BF'+")-#$
 $
 $
 $
 $
 $
L _
 -0&)&)LO&) #$'BE'*14),     _$ _
 -0&)&)LO&) #$'BE'*),     _, -1&*&*LP&* $$(BF'+")- 
  
  
  
  
  
D JN B B B B B B( ( ( ( ( ( ( (r   rN   )i
__future__r   r   systimer  r  collectionsr   datetimer   http.cookiejarr   urllib.parser   r   status_codesr
   TYPE_CHECKINGtyping_extensionsr   _compatr   r   	_constantr   r   r   r   r   r   r   r   r   r   r   r   
exceptionsr   r   r   r   extensions.revocationr   r   extensions.sgi._asyncr   extensions.unixsocket._asyncr   ra   r    r!   modelsr"   r#   r$   r%   r&   r'   packages.urllib3r(   (packages.urllib3.contrib.resolver._asyncr)   -packages.urllib3.contrib.webextensions._asyncr*   sessionsr+   r,   
structuresr-   r.   r/   r0   r1   r2   r3   r4   r5   r6   r7   r8   r9   r:   r;   r<   r=   r>   r?   r@   rA   utilsrB   rC   rD   rE   rF   rG   rH   rI   rJ   rK   platformperf_counterr  rN   r   r   r   <module>r     s^   " " " " " " 				 



    # # # # # #       $ $ $ $ $ $ * * * * * * * *      	 *)))))) < < < < < < < <            9 8 8 8 8 8 8 8                       M L L L L L L L > > > > > > : : : : : : 5 5 5 5 5 5 5 5                - , , , , , G G G G G G I I I I I I * * * * * * * * A A A A A A A A                                         *                        <7'OOiOH( H( H( H( H(7 H( H( H( H( H(r   