
    nbi                    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m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ ddl0m1Z1m2Z2 ddl3m4Z4m5Z5m6Z6m7Z7 ddl8m9Z9m:Z:m;Z;m<Z< ddl=m>Z>m?Z? ddl@mAZAmBZB ddlCmDZDmEZEmFZFmGZGmHZHmIZI ddlJmKZK ddlLmMZM ddlNmOZO ddlPmQZQ ddlRmSZSmTZT ddlUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_ ej`        dk    reja        Zbnej        Zb G d deQ          Zcd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)AsyncBodyTypeAsyncHookTypeAsyncHttpAuthenticationTypeAsyncResolverTypeBodyTypeCacheLayerAltSvcTypeCookiesTypeHeadersTypeHttpAuthenticationTypeHttpMethodTypeMultiPartFilesAltTypeMultiPartFilesType	ProxyTypeQueryParameterType	RetryTypeTimeoutTypeTLSClientCertTypeTLSVerifyType)AsyncBaseAdapterAsyncHTTPAdapter)RequestsCookieJarcookiejar_from_dictextract_cookies_to_jarmerge_cookies)ChunkedEncodingErrorContentDecodingErrorInvalidSchemaTooManyRedirects)DEFAULT_STRATEGYRevocationConfiguration)async_dispatch_hookdefault_hooks)DEFAULT_REDIRECT_LIMITAsyncResponsePreparedRequestRequestResponseTransferProgress)ConnectionInfo)AsyncBaseResolver)load_extension)Session)AsyncQuicSharedCacheCaseInsensitiveDict)
_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eddd&Zdd)Zdd+Z	dd,Z
dd.Zd/ Zd fd3Zdd5Zdd;Z	 	 	 	 	 	 	 dddLZej        	 	 	 	 	 	 	 	 	 	 	 	 	 	 dddb            Zej        	 	 	 	 	 	 	 	 	 	 	 	 	 	 dddd            Z	 	 	 	 	 	 	 	 	 	 	 	 	 	 dddfZej        dMdMdMdMdMdMdMdMdMdMdMdgddh            Zej        dMdMdMdMdMdMdMdMdMdMdMdgddi            Zdddddd<ddddddgddjZej        dMdMdMdMdMdMdMdMdMdMdMdgddl            Zej        dMdMdMdMdMdMdMdMdMdMdm
ddn            Zdddddd<ddddddgddoZej        dMdMdMdMdMdMdMdMdMdMdMdgddp            Zej        dMdMdMdMdMdMdMdMdMdMdm
ddq            ZddddddddddddgddrZej        	 	 ddMdMdMdMdMdMdMdMdMdMdMdMdsddt            Zej        	 	 ddMdMdMdMdMdMdMdMdMdMdMduddv            Z	 	 dddddddd<ddddddsddwZej        	 ddMdMdMdMdMdMdMdMdMdMdMdMdMdxddy            Zej        	 ddMdMdMdMdMdMdMdMdMdMdMdMdzdd{            Z	 ddddddddd<ddddddxdd|Zej        	 ddMdMdMdMdMdMdMdMdMdMdMdMdMdxdd}            Zej        	 ddMdMdMdMdMdMdMdMdMdMdMdMdzdd~            Z	 ddddddddd<ddddddxddZej        dMdMdMdMdMdMdMdMdMdMdMdgdd            Zej        dMdMdMdMdMdMdMdMdMdMdm
dd            Zdddddd<ddddddg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revocation_configurationrK   AsyncResolverType | NonerL   tuple[str, int] | NonerM   CacheLayerAltSvcType | NonerN   r    rO   boolrP   rQ   rR   rS   rT   rU   intrV   rW   
bool | intrX   float | int | NonerY   rZ   
str | Noner[   TimeoutType | Noner\   HeadersType | Noner]   RevocationConfiguration | 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                      | _        i | _        d| _        || _        t%          |          | _        || j        k    | _        || _        || _        || _        || _        || _        |
| _        |	| _        || _        || _        || _        || _        || _         d| _!        d | _"        tF          | _$        d| _%        || _&        tO          i d          | _(        ||ntS          d	          | _*        d | _+        d | _,        || _-        t]                      | _/        | 0                    d
tc          | j*        |||||||
|	||||||                     | 0                    dtc          |||||||
|	||||||                     d S )NT   z!Cannot disable both IPv4 and IPv6totalurllib3_futureF)thread_freei 0  )max_sizehttps://rM   max_retriesrP   rQ   rR   rK   rL   rT   rS   rU   rV   rW   rX   rY   r]   http://rq   rP   rQ   rR   rK   rL   rT   rS   rU   rV   rW   rX   rY   r]   )2countRuntimeErrorrN   r   hasattrstrtyper   r=   rA   r\   authproxiesr1   hooksparamsstreamrO   r@   rK   _own_resolverr[   rL   _disable_http1_disable_http2_disable_http3_disable_ipv4_disable_ipv6_pool_connections_pool_maxsize_happy_eyeballs_keepalive_delay_keepalive_idle_windowverifycertr2   max_redirects	trust_envrZ   r'   cookiesr<   rM   _ocsp_cache
_crl_cache_revocation_configurationr   adaptersmountr%   )selfrK   rL   rM   rN   rO   rP   rQ   rR   rS   rT   rU   rV   rW   rX   rY   rZ   r[   r\   r]   s                       f/var/www/html/mdtn/previsions/meteo_cartes/venv/lib/python3.11/site-packages/niquests/async_session.py__init__zAsyncSession.__init__p   s   . ,'--d33q88BCCC  L	="	= g..	= !D,>,>(?(???.t|<<DL
 8?7J*7333P_PaPa 	
 #% Q^P_P_

 +-  ' ,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  	
 	
 	
 	
 	
    returnrw   c                j    dt          | j                                      dd          d d          dS )Nz<AsyncSession zOrderedDict( >)reprr   replacer   s    r   __repr__zAsyncSession.__repr__(  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__+  s    klllr   c                
   K   | S N r   s    r   
__aenter__zAsyncSession.__aenter__.  s      r   Nonec                >   K   |                                   d {V  d S r   )close)r   excvaluetbs       r   	__aexit__zAsyncSession.__aexit__1  s,      jjllr   c                H   |                                 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                             | j                                        D ]:}t1          |d          r| j        |_        t1          |d          r| j        |_        ;d S )NTro   )rM   rq   rP   rQ   rR   rL   rT   rS   rK   rU   rV   rW   rX   rY   r]   rr   )rq   rP   rQ   rR   rL   rT   rS   rK   rU   rV   rW   rX   rY   r]   r   r   )itemssetattrr@   rK   r~   r   r   r   r%   rM   rN   r   r   r   rL   r   r   r   r   r   r   r   r   valuesrv   r   r   )r   stateattrr   adapters        r   __setstate__zAsyncSession.__setstate__4  s    ;;== 	' 	'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  	
 	
 	
& }++-- 	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.mounti  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
startswithrB   tuplesplitr:   supported_schemesscheme_to_http_schemeImportErrorr,   )r   r   r   r   schemer   	extensionadditional_hints           r   get_adapterzAsyncSession.get_adapterl  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requestr4   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}d/fd}d0fd}                    d|                               d|                               d j                                       d|           j        J  j                                        sM 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+        $                      ,                    j        %          }t[                      }	 |j.        fi  d{V }
t_          j0                  _0        t          |
d&          r[|
j1        d
u rR fd'}||
_2        dd<   |
j3        4                    ||	 j5        |d( j6        d)           |sto          |
           |
S t[                      |	z
  }tq          |*          |
_9        tu          d+|
fi  d{V }
|
j;        r*|
j;        D ]"}ty           j5        |j=        |j>                   #ty           j5        |
j>                   |rL  j?        |
fd,d
i}g }|2 3 d{V }t          |t                    r|A                    |           2|56 ng }|rZ|B                    d(|
           |                                }
|D ]&}t          |t                    rto          |           '||
_;        |s|
jD        r|  j?        |
fd-d
i}	 |E                                 d{V |
_F        n# t          $ r Y nw xY w|H                                 d{V  n# |H                                 d{V  w xY w|sGt          |
t                    r$|
jI        |
jJ         d{V  to          |
           n|
jI        |
jJ         |
S )1zSend a given PreparedRequest.z#You can only send PreparedRequests.r}   r   r   rz   r[   rk   rl   allow_redirectsT	conn_infor8   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.ro   r   NIQUESTS_STRICT_OCSP0Nr	   )InMemoryRevocationStatus)r   r   g?g      ?rz   )rK   rW   cache)InMemoryRevocationListr   pre_send)r   r   r   osenvirongetr   strict_moderG   "extensions.revocation._ocsp._asyncr   r   r   r   r   rv   rK   r   r   rF   !extensions.revocation._crl._asyncr   r   r0   )r   strict_ocsp_enabledr   ocsp_verifyr   r   
crl_verifyr{   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_sentrb   content_length
int | Noneis_completedra   	any_errorc                   K   k    rd S j         t                      _         | j         _        |j         _        |j         _        |j         _        t          d           d {V  d S )N	on_upload)upload_progressr7   rk   r   r   r   r0   )r   r   r   r   r{   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_responser6   c                :   K   t          d|            d {V  d S )Nr   )r0   )r   r{   s    r   on_early_responsez,AsyncSession.send.<locals>.on_early_response	  s2      %&6~NNNNNNNNNNNr   r   on_upload_bodyrO   r   NzA externally instantiated resolver was closed. Attempt to recycling it internally, the Session will detach itself from given resolver.ro   rp   rr   rs   )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_refU  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   r8   r   r   )
r   rb   r   r   r   ra   r   ra   r   r   )r   r6   r   r   )K
isinstancer5   
ValueError
setdefaultr}   r   r   rD   rz   r   r   rv   rw   rx   r   popr   r{   rO   r   rK   is_availabler~   warningswarnResourceWarningr   recycler   r%   rM   rN   r   r   r   rL   r   r   r   r   r   r   r   r   r   preferred_clocksendr>   r   r   _resolve_redirect_promiseupdate_parametersr   r   r?   r   elapsedr0   historyr(   r   rawr   r6   appendinsertr3   is_redirectr   _nextr   r   r   content)r   r   r   r   r}   r   r   r   r   startrr   r  respgenr  resp_or_reqhrr{   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{&&& }))++ /	% 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    * ""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   =R2-U U8 
UU8 UU8 8VTr  r3   reqr}   int | float | Noner   r#   r   TLSClientCertType | Nonerz   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Cookier-  r.  )r}   r[   r   r   rz   r   r   )4get_redirect_targetr   r   r,  copyr  r  r  r  r3   r  r*   r+   ru   readlenr   r-   r   r   rB   bytesdecodejoin_replacerw   geturlnetlocr   rC   rx   r\   rebuild_methodstatus_coder
   temporary_redirectpermanent_redirectr
  body_cookiesr(   r)   r   prepare_cookiesrebuild_proxiesrebuild_auth_body_positionrE   r  rv   r   gather)r   r  r#  r}   r[   r   r   rz   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.methodr   r|   QueryParameterType | NonedataBodyType | AsyncBodyType | Noner   CookiesType | Nonefiles1MultiPartFilesType | MultiPartFilesAltType | Nonery   ;HttpAuthenticationType | AsyncHttpAuthenticationType | Noner   r{   0AsyncHookType[PreparedRequest | Response] | NoneLiteral[False] | NoneTLSVerifyType | Nonejsontyping.Any | Noner6   c                
   K   d S r   r   r   rM  r   r|   rO  r\   r   rR  ry   r[   r   rz   r{   r}   r   r   rX  s                    r   r   zAsyncSession.requestO        & 3r   Literal[True]c                
   K   d S r   r   r[  s                    r   r   zAsyncSession.requestd        & 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)rM  r   r\   rR  rO  rX  r|   ry   r   r{   rZ   pre_request)r[   r   r[   >   PUTPOSTPATCHDELETE)isupperupperr5   rZ   prepare_request_asynchronous_auth_pending_async_auth__dict__updateprepare_content_lengthr>  r0   r{   r   merge_environment_settingsr[   r   r   r  )r   rM  r   r|   rO  r\   r   rR  ry   r[   r   rz   r{   r}   r   r   rX  r#  prepr  settingssend_kwargss                         r   r   zAsyncSession.requesty  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   ry   r[   r   rz   r{   r   r}   r   c               
   K   d S r   r   r   r   r|   r\   r   ry   r[   r   rz   r{   r   r}   r   r   s                 r   r   zAsyncSession.get        " 3r   c               
   K   d S r   r   ru  s                 r   r   zAsyncSession.get        " r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NGETrs  r   ru  s                 r   r   zAsyncSession.get  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   Literal[False] | Literal[None]c               
   K   d S r   r   ru  s                 r   optionszAsyncSession.options	  rv  r   )
r|   r\   r   ry   r[   r   rz   r{   r   r   c               
   K   d S r   r   ru  s                 r   r~  zAsyncSession.options  rx  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NOPTIONSrs  r{  ru  s                 r   r~  zAsyncSession.options/  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   ru  s                 r   headzAsyncSession.headQ  rv  r   c               
   K   d S r   r   ru  s                 r   r  zAsyncSession.headd  rx  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NHEADrs  r{  ru  s                 r   r  zAsyncSession.headw  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   )r|   r\   r   rR  ry   r[   r   rz   r{   r   r}   r   c               
   K   d S r   r   r   r   rO  rX  r|   r\   r   rR  ry   r[   r   rz   r{   r   r}   r   s                   r   postzAsyncSession.post  r\  r   )r|   r\   r   rR  ry   r[   r   rz   r{   r   r   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.post  r_  r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nrd  rO  rX  r|   r\   r   rR  ry   r[   r   rz   r{   r   r}   r   r{  r  s                   r   r  zAsyncSession.post  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   )rX  r|   r\   r   rR  ry   r[   r   rz   r{   r   r}   r   c               
   K   d S r   r   r  s                   r   putzAsyncSession.put  r\  r   )rX  r|   r\   r   rR  ry   r[   r   rz   r{   r   r   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.put  r_  r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nrc  r  r{  r  s                   r   r  zAsyncSession.put  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   r  s                   r   patchzAsyncSession.patch9  r\  r   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.patchN  r_  r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nre  r  r{  r  s                   r   r  zAsyncSession.patchc  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   ru  s                 r   deletezAsyncSession.delete  rv  r   c               
   K   d S r   r   ru  s                 r   r  zAsyncSession.delete  rx  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )Nrf  rs  r{  ru  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  )rO   r   r   rD  )r   r  r  r   s       r   rD  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~   rK   )r   vs     r   r   zAsyncSession.close  s      %%'' 	 	A''))OOOOOOOO 	(-%%'''''''''''	( 	(r   )&rK   r^   rL   r_   rM   r`   rN   r    rO   ra   rP   ra   rQ   ra   rR   ra   rS   ra   rT   ra   rU   rb   rV   rb   rW   rc   rX   rd   rY   rd   rZ   re   r[   rf   r\   rg   r]   rh   )r   rw   )r   r   )r   rJ   )r   r   )r   rw   r   r$   r   r   )r   rw   r   r$   )r   r4   r   r   r   r   )FNTNNFF)r  r3   r#  r4   r}   ra   r[   r$  r   r#   r   r%  rz   r&  r   ra   r  ra   r'  r   r   r(  )..............)"rM  r   r   rw   r|   rN  rO  rP  r\   rg   r   rQ  rR  rS  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r}   rV  r   rW  r   r%  rX  rY  r   r6   )"rM  r   r   rw   r|   rN  rO  rP  r\   rg   r   rQ  rR  rS  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r}   r]  r   rW  r   r%  rX  rY  r   r3   )NNNNNNNTNNNNNN)"rM  r   r   rw   r|   rN  rO  rP  r\   rg   r   rQ  rR  rS  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r}   r`  r   rW  r   r%  rX  rY  r   r   )r   rw   r|   rN  r\   rg   r   rQ  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r   rW  r}   rV  r   r%  r   r   r   r6   )r   rw   r|   rN  r\   rg   r   rQ  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r   rW  r}   r]  r   r%  r   r   r   r3   )r   rw   r|   rN  r\   rg   r   rQ  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r   rW  r}   r`  r   r%  r   r   r   r   )r   rw   r|   rN  r\   rg   r   rQ  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r   rW  r}   r|  r   r%  r   r   r   r6   )..) r   rw   rO  rP  rX  rY  r|   rN  r\   rg   r   rQ  rR  rS  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r   rW  r}   r|  r   r%  r   r6   ) r   rw   rO  rP  rX  rY  r|   rN  r\   rg   r   rQ  rR  rS  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r   rW  r}   r]  r   r%  r   r3   )NN) r   rw   rO  rP  rX  rY  r|   rN  r\   rg   r   rQ  rR  rS  ry   rT  r[   rf   r   ra   rz   r&  r{   rU  r   rW  r}   r`  r   r%  r   r   ).r   )r  r6   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  rD  r   __classcell__)r   s   @r   rJ   rJ   ]   sE	        * .2158<,!###"" 0,%*.448#&*&*CS+v
 v
 v
 v
 v
 v
pX X X Xm m m m      35 35 35j' ' ' ' ' '_ _ _ _@i i i i^	 &* $)-$($%*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   rJ   )d
__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   _typingr   r   r   r   r   r   r   r   r   r   r   r   r   r   r    r!   r"   r#   r   r$   r%   r   r&   r'   r(   r)   
exceptionsr*   r+   r,   r-   extensions.revocationr.   r/   r{   r0   r1   modelsr2   r3   r4   r5   r6   r7   packages.urllib3r8   (packages.urllib3.contrib.resolver._asyncr9   -packages.urllib3.contrib.webextensions._asyncr:   sessionsr;   
structuresr<   r=   utilsr>   r?   r@   rA   rB   rC   rD   rE   rF   rG   platformperf_counterr  rJ   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( ( ( ( (7 ( ( ( ( (r   