+
    )	i]                    F   ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	t^ RI
t^ RIt^ RIt^RIHt ^RIHtHtHt ^RIHtHtHt ^RIHtHtHt ^RIHt ^RIHt ]P>                  ! R	4      t R
 R lt! ! R R]PD                  4      t# ! R R]4      t$ ! R R4      t%R# )    )annotationsN)AsyncNetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError)OriginRequestResponse)	AsyncLockAsyncSemaphoreAsyncShieldCancellation)Trace)AsyncConnectionInterfacezhttpcore.http2c                    V ^8  d   QhRRRR/# )   requestr	   returnbool )formats   "5lib/python3.14/site-packages/httpcore/_async/http2.py__annotate__r      s      g $     c                    \         ;QJ d&    R  V P                   4       F  '       g   K   R# 	  R# ! R  V P                   4       4      # )c              3     "   T F5  w  rVP                  4       R 8H  ;'       g    VP                  4       R8H  x  K7  	  R# 5i)s   content-length   transfer-encodingN)lower).0kvs   &  r   	<genexpr>#has_body_headers.<locals>.<genexpr>   s<      #DA 	
	&&KK!'')7K*KK#s    ??TF)anyheaders)r   s   &r   has_body_headersr%      sE    3 OO33 3 3 OO  r   c                  "    ] tR t^$t^t^t^tRtR# )HTTPConnectionStater   N)__name__
__module____qualname____firstlineno__ACTIVEIDLECLOSED__static_attributes__r   r   r   r'   r'   $   s    FDFr   r'   c                     ] tR t^*tR9t]P                  P                  RR7      tR:R R llt	R R lt
R R	 ltR
 R ltR R ltR R ltR R ltR R ltR R ltR R ltR:R R lltR R ltR R ltR R ltR  R! ltR" R# ltR$ R% ltR& R' ltR( R) ltR* R+ ltR, R- ltR. R/ ltR0 R1 ltR2 R3 lt R4 R5 lt!R;R6 R7 llt"R8t#R# )<AsyncHTTP2ConnectionF)validate_inbound_headersNc               $    V ^8  d   QhRRRRRR/# )r   originr   streamr   keepalive_expiryzfloat | Noner   )r   s   "r   r   !AsyncHTTP2Connection.__annotate__.   s(     %7 %7%7 #%7 '	%7r   c                	   Wn         W n        W0n        \        P                  P                  V P                  R 7      V n        \        P                  V n
        RV n        ^ V n        \        4       V n        \        4       V n        \        4       V n        \        4       V n        RV n        RV n        RV n        / V n        RV n        RV n        RV n        R# ))configNF)_origin_network_stream_keepalive_expiryh2
connectionH2ConnectionCONFIG	_h2_stater'   r-   _state
_expire_at_request_countr   
_init_lock_state_lock
_read_lock_write_lock_sent_connection_init_used_all_stream_ids_connection_error_events_connection_terminated_read_exception_write_exception)selfr4   r5   r6   s   &&&&r   __init__AsyncHTTP2Connection.__init__.   s     %/?334;;3G)..(,#+$;#+$;%*"$)!!&  	 NR#1526r   c                    V ^8  d   QhRRRR/# )r   r   r	   r   r
   r   )r   s   "r   r   r7   U   s     f f' fh fr   c                	.  "   V P                  VP                  P                  4      '       g0   \        R VP                  P                   RV P                   24      hV P
                  ;_uu_4       GRj  xL
  V P                  \        P                  \        P                  39   d7   V ;P                  ^,          un
        RV n        \        P                  V n        M
\        4       hRRR4      GRj  xL
  V P                  ;_uu_4       GRj  xL
  V P                  '       g    RV/p\        R\         W4      ;_uu_4       GRj  xL
  V P"                  ! R/ VB G Rj  xL
  RRR4      GRj  xL
  RT n        ^T n        T P,                  P.                  P0                  p\3        T4      T n        \7        Y@P*                  ,
          4       F%  pT P4                  P9                  4       G Rj  xL
  K'  	  RRR4      GRj  xL
  V P4                  P9                  4       G Rj  xL
   V P,                  P;                  4       p. V P<                  V&    RTRT/p\        R\         Y4      ;_uu_4       GRj  xL
  T PG                  YR7      G Rj  xL
  RRR4      GRj  xL
  \        R	\         Y4      ;_uu_4       GRj  xL
  T PI                  YR7      G Rj  xL
  RRR4      GRj  xL
  \        R
\         Y4      ;_uu_4       GRj  xL
 pT PK                  YR7      G Rj  xL
 w  rY3Tn&        RRR4      GRj  xL
  \O        X	X
\Q        YTR7      RRRT PR                  RT/R7      #  EL EL  + GRj  xL 
 '       g   i     EL; i EL ELR EL; EL.  + GRj  xL 
 '       g   i     ELF; i  \$         dP   p\'        4       ;_uu_ 4        T P)                  4       G Rj  xL 
  RRR4       Th  + '       g   i     Th; iRp?ii ; i EL- EL  + GRj  xL 
 '       g   i     EL4; i EL  \>        P@                  PB                   d,    RT n"        T ;P                  ^,          un
        \        4       hi ; i EL EL  EL  + GRj  xL 
 '       g   i     EL; i EL EL EL  + GRj  xL 
 '       g   i     EL; i EL EL EL  + GRj  xL 
 '       g   i     EL; i  \$         Ed   p\'        4       ;_uu_ 4        RT/p\        R\         Y4      ;_uu_4       GRj  xL 
  T PU                  TR7      G Rj  xL 
  RRR4      GRj  xL 
  M  + GRj  xL 
 '       g   i     M; iRRR4       M  + '       g   i     M; i\W        T\>        P@                  PX                  4      '       d3   T PZ                  '       d   \]        T PZ                  4      h\_        T4      hThRp?ii ; i5i)zAttempted to send request to z on connection to Nr   send_connection_initT	stream_idsend_request_headersr   rV   send_request_bodyreceive_response_headersrV   http_versions   HTTP/2network_stream)statusr$   content
extensionsresponse_closedr   )0can_handle_requesturlr4   RuntimeErrorr:   rF   rB   r'   r,   r-   rD   rC   r   rE   rI   r   logger_send_connection_initBaseExceptionr   aclose_max_streamsrA   local_settingsmax_concurrent_streamsr   _max_streams_semaphorerangeacquireget_next_available_stream_idrL   r=   
exceptionsNoAvailableStreamIDErrorrJ   _send_request_headers_send_request_body_receive_responsereturn_valuer
   HTTP2ConnectionByteStreamr;   _response_closed
isinstanceProtocolErrorrM   r   r   )rP   r   
sci_kwargsexclocal_settings_max_streams_rV   kwargstracer^   r$   s   &&         r   handle_async_request)AsyncHTTP2Connection.handle_async_requestU   s    &&w{{'9'9::
 /0B0B/C Dll^% 
 ####{{299;N;S;STT##q(#"&188,.. $# ????---	"+W!5J$.      #88F:FFF    .2* %&! NN11HH + /==W.X+9<M<MMNA55==??? O1 #?6 ))11333	+CCEI&(DLL#.	+yAF3VWMMM000VVV NM0&'JJJ--g-SSS KJ*FG  (,(>(># )? ) # '-%6"  1$9U"I$d&:&:		 	w $### #  G        % 022"kkm++ 3I 32I" @3 #???6 	4
 }}55 	+(,D%1$(**	+ NV NMMMJS KJJJ#   $  	(**%y1 !2FGLLL//)/DDD MLLLLL +***
 #r}}::;; ...-d.I.IJJ )--I-	s  A3X5M66X9A0M<)X4M95XNXP%)!O
NON%	$N%N%	)O4N"5O9A9P%2P
3P%;XP"!X(Q)X.)Q #T ;R<T ?RRRT %R&!T R8T S!R;"S&T 1R>2!T ST S'-S!.S'<T S$-T 5X9X<N	N
N	N	
XON%	"O%N?+N.,
N?7N?9O=P%?OPPP3O64P9
PP	PPP%"X%P?	+P.,
P?	7P?	9
XA
RXT RT R5	!R$"
R5	-R5	/
T ;S>T S	S

S	S	
T !S'$T 'T	-S0.
T	9T	;	T XX""VUV	U7U" U7%V0U3
1V7V=V >
V	VV	XV,'AX+"XXXc                    V ^8  d   QhRRRR/# r   r   r	   r   Noner   )r   s   "r   r   r7      s     1 17 1t 1r   c           	     X  "   \         P                  P                  R\         P                  P                  P                  ^ \         P                  P                  P
                  ^d\         P                  P                  P                  R/R7      V P                  n        V P                  P                  \         P                  P                  P                   V P                  P                  4        V P                  P                  R4       V P                  V4      G Rj  xL
  R#  L5i)zx
The HTTP/2 connection requires some initial setup before we can start
using individual request/response streams on it.
T   )clientinitial_valuesN   )r=   settingsSettingsSettingCodesENABLE_PUSHMAX_CONCURRENT_STREAMSMAX_HEADER_LIST_SIZErA   rj   ENABLE_CONNECT_PROTOCOLinitiate_connectionincrement_flow_control_window_write_outgoing_data)rP   r   s   &&r   rf   *AsyncHTTP2Connection._send_connection_init   s      )+(<(< ((44a((??((==u )= 
)
% NN))KK$$<<
 	**,44U;''000s   DD*!D("D*c               $    V ^8  d   QhRRRRRR/# r   r   r	   rV   intr   r   r   )r   s   "r   r   r7      s!     1 17 1s 1t 1r   c                  "   \        V4      '       * pVP                   UUu. uF  w  rEVP                  4       R8X  g   K  VNK   	  upp^ ,          pRVP                  3RV3RVP                  P
                  3RVP                  P                  3.VP                   UUu. uF.  w  rEVP                  4       R	9  g   K  VP                  4       V3NK0  	  upp,           pV P                  P                  W'VR7       V P                  P                  R
VR7       V P                  V4      G Rj  xL
  R# u uppi u uppi  L5i)z0
Send the request headers to a given stream ID.
   hosts   :methods
   :authoritys   :schemes   :path)
end_streamr[   N)r   r   r   )r%   r$   r   methodrc   schemetargetrA   send_headersr   r   )rP   r   rV   r   r   r    	authorityr$   s   &&&     r   rr   *AsyncHTTP2Connection._send_request_headers   s      *'22
 $+??K?41aggi76JQQ?KAN	 (I&++,w{{))*	
  
'wwy QWWYN'

 	##I:#N44Ui4P''000' L
 	1s6    E D2 D2AE D8=D8AE +D>,E c               $    V ^8  d   QhRRRRRR/# r   r   )r   s   "r   r   r7      s!     
8 
8 
8C 
8D 
8r   c                .  "   \        V4      '       g   R# \        VP                  \        P                  4      '       g   Q hVP                    Rj  xL
  pV P                  WV4      G Rj  xL
  K&   L! LD$T P                  Y4      G Rj  xL 
  R# 5i)z@
Iterate over the request body sending it to a given stream ID.
N)r%   rx   r5   typingAsyncIterable_send_stream_data_send_end_stream)rP   r   rV   datas   &&& r   rs   'AsyncHTTP2Connection._send_request_body   s       (('..&*>*>????!.. 	C 	C$((TBBB	CB )##G777sH   ABA8A4A8B-A6.B4A86B8BBBc               (    V ^8  d   QhRRRRRRRR/# )	r   r   r	   rV   r   r   bytesr   r   r   )r   s   "r   r   r7   	  s,     5 55+.56;5	5r   c                   "   V'       dm   V P                  W4      G Rj  xL
 p\        \        V4      V4      pVRV W5R r6V P                  P	                  W&4       V P                  V4      G Rj  xL
  Kt  R#  LY L
5i)z9
Send a single chunk of data in one or more data frames.
N)_wait_for_outgoing_flowminlenrA   	send_datar   )rP   r   rV   r   max_flow
chunk_sizechunks   &&&&   r   r   &AsyncHTTP2Connection._send_stream_data	  ss      !99'MMHSY1J{
+T+->4NN$$Y6++G444 M 5s'   A=A=A9AA=0A;1	A=;A=c               $    V ^8  d   QhRRRRRR/# r   r   )r   s   "r   r   r7     s!     1 1g 1# 1$ 1r   c                z   "   V P                   P                  V4       V P                  V4      G Rj  xL
  R#  L5i)zP
Send an empty data frame on on a given stream ID with the END_STREAM flag set.
N)rA   r   r   )rP   r   rV   s   &&&r   r   %AsyncHTTP2Connection._send_end_stream  s-      	!!),''000s   0;9;c               $    V ^8  d   QhRRRRRR/# )r   r   r	   rV   r   r   z%tuple[int, list[tuple[bytes, bytes]]]r   )r   s   "r   r   r7     s$     & &&+.&	.&r   c                  "    V P                  W4      G Rj  xL
 p\        V\        P                  P                  4      '       g   KF   ^p. pTP
                  f   Q hTP
                   FU  w  rgTR8X  d   \        TP                  RRR7      4      pK*  TP                  R4      '       d   KC  TP                  Yg34       KW  	  YE3#  L5i)zD
Return the response status code and headers for a given stream ID.
Ns   :statusasciiignore)errors   :)
_receive_stream_eventrx   r=   eventsResponseReceivedr$   r   decode
startswithappend)rP   r   rV   eventstatus_coder$   r   r    s   &&&     r   rt   &AsyncHTTP2Connection._receive_response  s      44WHHE%!;!;<<}}(((MMDAJ!!((78("DE\\$''v&	 " %% Is   CC+C	AC-Cc               $    V ^8  d   QhRRRRRR/# )r   r   r	   rV   r   r   typing.AsyncIterator[bytes]r   )r   s   "r   r   r7   5  s$      +.	$r   c                 "    V P                  W4      G Rj  xL
 p\        V\        P                  P                  4      '       dr   VP
                  f   Q hVP                  f   Q hVP
                  pV P                  P                  WB4       V P                  V4      G Rj  xL
  VP                  5x  K  \        V\        P                  P                  4      '       g   K  R#  L LE5i)zM
Iterator that returns the bytes of the response body for a given stream ID.
N)r   rx   r=   r   DataReceivedflow_controlled_lengthr   rA   acknowledge_received_datar   StreamEnded)rP   r   rV   r   amounts   &&&  r   _receive_response_body+AsyncHTTP2Connection._receive_response_body5  s      44WHHE%!7!78833???zz---5588K//888jj E299#8#899 I 9s(   C*C&B	C*"C(#<C*$C*(C*c               $    V ^8  d   QhRRRRRR/# )r   r   r	   rV   r   r   zKh2.events.ResponseReceived | h2.events.DataReceived | h2.events.StreamEndedr   )r   s   "r   r   r7   G  s$      +.	Tr   c                8  "   V P                   P                  V4      '       g   V P                  W4      G Rj  xL
  K<  V P                   V,          P                  ^ 4      p\	        V\
        P                  P                  4      '       d   \        V4      hV#  L_5i)zk
Return the next available event for a given stream ID.

Will read more data from the network if required.
N)	rL   get_receive_eventspoprx   r=   r   StreamResetr   )rP   r   rV   r   s   &&& r   r   *AsyncHTTP2Connection._receive_stream_eventG  su      ,,""9--&&w:::Y'++A.eRYY2233%e,,	 ;s   !BBBA Bc               $    V ^8  d   QhRRRRRR/# )r   r   r	   rV   z
int | Noner   r   r   )r   s   "r   r   r7   V  s$     .1 .1.1+5.1	.1r   c                  "   V P                   ;_uu_4       GRj  xL
  V P                  ee   V P                  P                  pV'       d2   V'       d*   W#8  d$   V ;P                  ^,          un        \	        4       h\        V P                  4      hVe#   V P                  P                  V4      '       Eg   V P                  V4      G Rj  xL
 pV EFw  p\        V\        P                  P                  4      '       dT   \        R\        V4      ;_uu_4       GRj  xL
 pV P                  V4      G Rj  xL
  WVn        RRR4      GRj  xL
  K  \        V\        P                  P"                  \        P                  P$                  \        P                  P&                  \        P                  P(                  34      '       dN   VP*                  V P                  9   d0   V P                  VP*                  ,          P-                  V4       EKA  EKD  \        V\        P                  P.                  4      '       g   EKq  WPn        EKz  	  RRR4      GRj  xL
  V P1                  V4      G Rj  xL
  R#  EL_ EL ELb ELL EL9  + GRj  xL 
 '       g   i     EK  ; i LL  + GRj  xL 
 '       g   i     Lc; i LQ5i)zX
Read some data from the network until we see one or more events
for a given stream ID.
Nreceive_remote_settings)rG   rM   last_stream_idrD   r   r   rL   r   _read_incoming_datarx   r=   r   RemoteSettingsChangedr   re   _receive_remote_settings_changeru   r   r   r   r   rV   r   ConnectionTerminatedr   )rP   r   rV   r   r   r   r   s   &&&    r   r   $AsyncHTTP2Connection._receive_eventsV  s     ????**6!%!<!<!K!KI4N''1,'022)$*E*EFF  (8(8(C(C#77@@#E!%)H)HII#(5vw$ $ $""&"F"Fu"MMM16.	$ $ $ $II66II22II11II11	  !??dll: LL9@@G ; $E299+I+IJJ6;3+ $! #?N ''000O # A$ N$ $ $ $% #???N 	1s   KI:K,J)J)A#J)8J)I=AJ)J J)"J	7J8
J	J)J
C0J)J)KJ'K3K4K=J) J)J	J)	J$J
J$J$
J)'K)K	/J20
K	;K	=	Kc                    V ^8  d   QhRRRR/# )r   r   zh2.events.RemoteSettingsChangedr   r   r   )r   s   "r   r   r7     s     + +4+	+r   c                	x  "   VP                   P                  \        P                  P                  P
                  4      pV'       d   \        VP                  V P                  P                  P                  4      pV'       d   W0P                  8w  d   W0P                  8  d>   V P                  P                  4       G R j  xL
  V ;P                  ^,          un        KM  W0P                  8  d>   V P                  P                  4       G R j  xL
  V ;P                  ^,          un        KM  R # R # R # R #  Lt L)5iN)changed_settingsr   r=   r   r   r   r   	new_valuerA   rj   rk   ri   rl   releasern   )rP   r   rk   new_max_streamss   &&  r   r   4AsyncHTTP2Connection._receive_remote_settings_change  s      "'!7!7!;!;KK$$;;"
 "!&00--DDO ?6G6G#G%(9(9955==???%%*%%(9(9955==???%%*% :	 $H " @ @s%   B?D:D6AD:D8(D:8D:c                    V ^8  d   QhRRRR/# )r   rV   r   r   r   r   )r   s   "r   r   r7     s     ( ( ( (r   c                	  "   V P                   P                  4       G R j  xL
  V P                  V V P                  ;_uu_4       GR j  xL
  V P                  '       d,   V P                  '       g   V P                  4       G R j  xL
  MV P                  \        P                  8X  d   V P                  '       gz   \        P                  V n        V P                  e-   \        P                  ! 4       pW P                  ,           V n        V P                  '       d   V P                  4       G R j  xL
  R R R 4      GR j  xL
  R #  EL( EL L L L  + GR j  xL 
 '       g   i     R # ; i5ir   )rl   r   rL   rF   rM   rh   rB   r'   r,   r-   r<   time	monotonicrC   rJ   )rP   rV   nows   && r   rw   %AsyncHTTP2Connection._response_closed  s     ))11333LL#####***4<<<kkm## 3 : ::4<<<166))5..*C&),B,B&BDO,,,++-'' $## 	4## ( $###s   E1E)E1
EE1$E3EE5E=A EE1E2E6E1EE1E1EEE1E.	E
E.	&E.	(	E1c                   V ^8  d   QhRR/# r   r   r   r   )r   s   "r   r   r7     s     , ,d ,r   c                	   "   V P                   P                  4        \        P                  V n        V P
                  P                  4       G R j  xL
  R #  L5ir   )rA   close_connectionr'   r.   rB   r;   rh   rP   s   &r   rh   AsyncHTTP2Connection.aclose  s<      	''))00""))+++s   AAAAc                    V ^8  d   QhRRRR/# )r   r   r	   r   zlist[h2.events.Event]r   )r   s   "r   r   r7     s       =R r   c                	  "   VP                   P                  R / 4      pVP                  RR4      pV P                  e   V P                  h V P                  P	                  V P
                  V4      G Rj  xL
 pVR8X  d   \        R4      h T P                  P                  T4      pT#  L4  \         d   pYPn        RT n        ThRp?ii ; i5i)timeoutreadNr   zServer disconnectedT)r`   r   rN   r;   r   READ_NUM_BYTESr   	ExceptionrK   rA   receive_data)rP   r   timeoutsr   r   r{   r   s   &&     r   r   (AsyncHTTP2Connection._read_incoming_data  s     %%)))R8,,vt,+&&&	--2243F3FPPDs{)*?@@  )-(C(CD(I% Q  	 $' %)D"I	s<   A	C)B, 5B*6B, C*B, ,C7CCCc                    V ^8  d   QhRRRR/# r   r   )r   s   "r   r   r7     s      ' d r   c                	  "   VP                   P                  R / 4      pVP                  RR4      pV P                  ;_uu_4       GRj  xL
  V P                  P	                  4       pV P
                  e   V P
                  h V P                  P                  WC4      G Rj  xL
  RRR4      GRj  xL
  R#  Ln L  \         d   pYPn        RT n	        ThRp?ii ; i L,  + GRj  xL 
 '       g   i     R# ; i5i)r   writeNT)
r`   r   rH   rA   data_to_sendrO   r;   r   r   rK   )rP   r   r   r   r   r{   s   &&    r   r   )AsyncHTTP2Connection._write_outgoing_data  s     %%)))R8,,w-####>>668L$$0+++**00GGG $## H  ),%)-&	 $###s~   AC=	B8
C=5C B<!B:"B<&C=1C2C=:B<<CCCC C= C:	&C)'
C:	2C:	4	C=c               $    V ^8  d   QhRRRRRR/# )r   r   r	   rV   r   r   r   )r   s   "r   r   r7     s"      W  QT r   c                F  "   V P                   P                  V4      pV P                   P                  p\        W44      pV^ 8X  dX   V P	                  V4      G Rj  xL
  V P                   P                  V4      pV P                   P                  p\        W44      pK^  V#  LD5i)z
Returns the maximum allowable outgoing flow for a given stream.

If the allowable flow is zero, then waits on the network until
WindowUpdated frames have increased the flow rate.
https://tools.ietf.org/html/rfc7540#section-6.9
N)rA   local_flow_control_windowmax_outbound_frame_sizer   r   )rP   r   rV   
local_flowmax_frame_sizeflows   &&&   r   r   ,AsyncHTTP2Connection._wait_for_outgoing_flow  s      ..BB9M
"nnDD:.ai&&w///AA)LJ!^^CCNz2D	 0s   AB!BAB!c                    V ^8  d   QhRRRR/# )r   r4   r   r   r   r   )r   s   "r   r   r7     s     & & &D &r   c                	    WP                   8H  # r   )r:   rP   r4   s   &&r   rb   'AsyncHTTP2Connection.can_handle_request  s    %%r   c                   V ^8  d   QhRR/# r   r   r   r   )r   s   "r   r   r7     s     	
 	
d 	
r   c                	>   V P                   \        P                  8g  ;'       dz    V P                  '       * ;'       da    V P                  '       * ;'       dH    V P
                  P                  P                  \        P                  P                  P                   8X  * # r   )rB   r'   r.   rK   rJ   rA   state_machinestater=   r>   ConnectionStater   s   &r   is_available!AsyncHTTP2Connection.is_available  s    KK.555  *** ---  ,,22==00778		
r   c                   V ^8  d   QhRR/# r  r   )r   s   "r   r   r7   
  s     E ET Er   c                	t    \         P                  ! 4       pV P                  R J;'       d    WP                  8  # r   )r   r   rC   )rP   r   s   & r   has_expired AsyncHTTP2Connection.has_expired
  s,    nnd*DDs__/DDr   c                   V ^8  d   QhRR/# r  r   )r   s   "r   r   r7     s     7 7 7r   c                	<    V P                   \        P                  8H  # r   )rB   r'   r-   r   s   &r   is_idleAsyncHTTP2Connection.is_idle  s    {{16666r   c                   V ^8  d   QhRR/# r  r   )r   s   "r   r   r7     s     9 94 9r   c                	<    V P                   \        P                  8H  # r   )rB   r'   r.   r   s   &r   	is_closedAsyncHTTP2Connection.is_closed  s    {{18888r   c                   V ^8  d   QhRR/# r   r   strr   )r   s   "r   r   r7     s     
 
c 
r   c                	~    \        V P                  4      pV: R V P                  P                   RV P                   2# )z
, HTTP/2, , Request Count: )r$  r:   rB   namerD   r  s   & r   infoAsyncHTTP2Connection.info  sA    T\\"j
4;;#3#3"4 5"1124	
r   c                   V ^8  d   QhRR/# r#  r   )r   s   "r   r   r7     s     
 
# 
r   c           	     	    V P                   P                  p\        V P                  4      pR V RV: RV P                  P
                   RV P                   R2	# )<z [z, r&  z]>)	__class__r(   r$  r:   rB   r'  rD   )rP   
class_namer4   s   &  r   __repr__AsyncHTTP2Connection.__repr__  sZ    ^^,,
T\\"
|2fZr$++*:*:); <"112"6	
r   c                   V ^8  d   QhRR/# )r   r   r1   r   )r   s   "r   r   r7   &  s      "6 r   c                	   "   V # 5ir   r   r   s   &r   
__aenter__AsyncHTTP2Connection.__aenter__&  s
     s   c               (    V ^8  d   QhRRRRRRRR/# )	r   exc_typeztype[BaseException] | None	exc_valuezBaseException | None	tracebackztypes.TracebackType | Noner   r   r   )r   s   "r   r   r7   )  s2      , ( .	
 
r   c                	B   "   V P                  4       G R j  xL
  R #  L5ir   )rh   )rP   r6  r7  r8  s   &&&&r   	__aexit__AsyncHTTP2Connection.__aexit__)  s      kkms   )rK   rM   rL   rC   rA   rE   r<   ri   rl   r;   r:   rN   rG   rD   rI   rB   rF   rJ   rO   rH   r   r   )NNN)$r(   r)   r*   r+   r   r=   r9   H2Configurationr@   rQ   r   rf   rr   rs   r   r   rt   r   r   r   r   rw   rh   r   r   r   rb   r  r  r  r   r(  r/  r3  r:  r/   r   r   r   r1   r1   *   s    NYY&&&FF%7NfP1B1>
851&,$.1`+&(,86(&	
E79

 r   r1   c                  :    ] tR tRtR R ltR R ltR R ltRtR	# )
rv   i2  c               (    V ^8  d   QhRRRRRRRR/# )	r   r>   r1   r   r	   rV   r   r   r   r   )r   s   "r   r   &HTTP2ConnectionByteStream.__annotate__3  s,      .9@MP	r   c                	8    Wn         W n        W0n        R V n        R# )FN)_connection_request
_stream_id_closed)rP   r>   r   rV   s   &&&&r   rQ   "HTTP2ConnectionByteStream.__init__3  s     &#r   c                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   r?  ;  s      !< r   c               	B  "   R V P                   RV P                  /p \        R\        V P                   V4      ;_uu_4       GRj  xL
  V P                  P                  V P                   V P                  R7        Rj  xL
  pV5x  K   LF LDRRR4      GRj  xL 
  R#   + GRj  xL 
 '       g   i     R# ; i  \         dP   p\        4       ;_uu_ 4        T P                  4       G Rj  xL 
  RRR4       Th  + '       g   i     Th; iRp?ii ; i5i)r   rV   receive_response_bodyNrX   )	rB  rC  r   re   rA  r   rg   r   rh   )rP   r~   r   r{   s   &   r   	__aiter__#HTTP2ConnectionByteStream.__aiter__;  s     T]]KI	4fdmmVTTT#'#3#3#J#J MMT__ $K $    %  K	 U  $ UTTTTT
  	 )**kkm## +I +*I	s   D(C BC 
2B%<B B
B	B%C BB%C B C #D%B?	+B.,
B?	7B?	9C =D?C DDD3C6
4D9
DD	DDDc                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r?  K  s     S Sd Sr   c                	|  "   V P                   '       g   R V n         RV P                  /p\        R\        V P                  V4      ;_uu_4       GRj  xL
  V P
                  P                  V P                  R7      G Rj  xL
  RRR4      GRj  xL
  R# R#  LF L L  + GRj  xL 
 '       g   i     R# ; i5i)TrV   ra   Nr[   )rD  rC  r   re   rB  rA  rw   )rP   r~   s   & r   rh    HTTP2ConnectionByteStream.acloseK  s     |||DL!4??3F.vNNN&&77$//7RRR ONN  OR ONNNs`   AB<BB<*B BBB<B	B<BB<B9	%B(&
B9	1B9	3	B<)rD  rA  rB  rC  N)r(   r)   r*   r+   rQ   rI  rh   r/   r   r   r   rv   rv   2  s     S Sr   rv   )&
__future__r   enumloggingr   typesr   	h2.configr=   h2.connection	h2.eventsh2.exceptionsh2.settings_backends.baser   _exceptionsr   r   r   _modelsr   r	   r
   _synchronizationr   r   r   _tracer   
interfacesr   	getLoggerre   r%   IntEnumr'   r1   rv   r   r   r   <module>r_     s    "           / 
 0 / Q Q  0			+	,$,, E3 EPS Sr   