+
    “°³j€]  ã                  ó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   "ÚV/home/luca/screen-checking/.venv/lib/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<   é € ð á#‰DˆAð 	
�‰‹	Ð&Ñ&×KÐK¨!¯'©'«)Ð7KÑ*KÔKÛ#ùs   ‚ ?£?TF)ÚanyÚheaders)r   s   &r   Úhas_body_headersr%      sE   € ß‹3ñ à—O’Oó�3Œ3ð Š3ð ˆ3ñ à—O’Oóó ð 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Ñ3¸4¿;¹;Ð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  ršYš3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×:Ò:ô
 Ø/°·±×0BÑ0BÐ/Cð DØ—l‘l�^ð%óð ð
 ×#×#×#Ó#Ø�{‰{Ô2×9Ñ9Ô;N×;SÑ;SÐTÔTØ×#Ò# qÕ(Õ#Ø"&�”Ü1×8Ñ8�•ä,Ó.Ð.÷ $×#ð —?—?—?“?Ø×-×-Ð-ð	Ø"+¨WÐ!5�JÜ$Ø.´¸÷ ÷  õ  ð #×8Ò8ÑF¸:ÑF×FÐF÷ ÷  ð .2�Ô*ð %&�Ô!ð —N‘N×1Ñ1×HÑHð +ô /=Ð=WÓ.X�Ô+äÐ9×<MÑ<MÕMÖN�AØ×5Ñ5×=Ñ=Ó?×?Ò?ñ O÷1 #—?ð6 ×)Ñ)×1Ñ1Ó3×3Ð3ð	+ØŸ™×CÑCÓEˆIØ&(ˆD�L‰L˜Ñ#ð.	Ø ¨+°yÐAˆFÜÐ3´V¸W×M×MÕMØ×0Ñ0¸Ð0ÓV×VÐV÷ N×MäÐ0´&¸'×J×JÕJØ×-Ñ-°gÐ-ÓS×SÐS÷ K×JäØ*¬F°G÷÷ ô àØ(,×(>Ñ(>Ø#ð )?ó )÷ #‘�ð '-Ð%6�Ô"÷÷ ô ØØÜ1°$È9ÔUà" IØ$ d×&:Ñ&:Ø ðô		ð 	÷w $×#×#×#úò #ò ò G÷ ÷  ÷  ô  ûô %ô Ü0×2Õ2Ø"Ÿk™k›m×+Ñ+÷ 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�Ü Ð!2´F¸G×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ñ 1°7ð 1¸tñ 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Ñ4°aä—‘×(Ñ(×?Ñ?ÀÜ—‘×(Ñ(×=Ñ=¸uðð )=ó 
)
ˆ�‰Ô%ð �N‰N×)Ñ)Ü�K‰K×$Ñ$×<Ñ<ð
ð 	�‰×*Ñ*Ô,Ø�‰×4Ñ4°UÔ;Ø×'Ñ'¨Ó0×0Ô0ùs   ‚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ñ 1°7ð 1Àsð 1Ètñ 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¡?™4˜1°a·g±g³iÀ7Ñ6J—Q�Q¡?ÒKÈAÕNˆ	ð ˜Ÿ™Ð(Ø˜IÐ&Ø˜Ÿ™×+Ñ+Ð,Ø�w—{‘{×)Ñ)Ð*ð	
ð  Ÿšô
á'‘�Ø�w‰w‹yðñô ˆQ�W‰W‹Y˜‹NÙ'ò
õ
ˆð 	�‰×#Ñ# IÀ:Ð#ÔNØ�‰×4Ñ4°UÀiÐ4ÔPØ×'Ñ'¨Ó0×0Ò0ùó' Lùó
ñ 	1ùs6   ‚ 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°ð 
8ÀCð 
8ÈDñ 
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Ó7ùsH   ‚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Ø+.ð5Ø6;ð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×MˆHÜœS ›Y¨Ó1ˆJØ˜{ 
Ð+¨T°+Ð->�4Ø�N‰N×$Ñ$ YÔ6Ø×+Ñ+¨GÓ4×4Ò4ñ ÙMñ 5ùs'   ‚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ñ 1¨gð 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Ô0ùs   ‚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#  L­5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Ñ4°WÓH×HˆEÜ˜%¤§¡×!;Ñ!;×<Ô<ØàˆØˆØ�}‰}Ò(Ð(Ð(Ø—M”M‰DˆAØ�JŒÜ! !§(¡(¨7¸8 (Ó"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Ñ4°WÓH×HˆEÜ˜%¤§¡×!7Ñ!7×8Ò8Ø×3Ñ3Ò?Ð?Ð?Ø—z‘zÒ-Ð-Ð-Ø×5Ñ5�Ø—‘×8Ñ8¸ÔKØ×/Ñ/°Ó8×8Ð8Ø—j‘jÕ Ü˜E¤2§9¡9×#8Ñ#8×9Ô9Ùñ Iñ 9ùs(   ‚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Ó.ˆÜ�eœRŸY™Y×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�ß§°IÔ4NØ×'Ò'¨1Õ,Õ'Ü0Ó2Ð2Ü)¨$×*EÑ*EÓFÐFð Ò ¨¯©×(8Ñ(8¸×(CÓ(CØ#×7Ñ7¸Ó@×@�Ü#�EÜ! %¬¯©×)HÑ)H×IÒIÜ#(Ø5´v¸w÷$÷ $ô $à"Ø"&×"FÑ"FÀuÓ"M×MÐMØ16Ô.÷	$÷ $ñ $ô $ØäŸI™I×6Ñ6ÜŸI™I×2Ñ2ÜŸI™I×1Ñ1ÜŸI™I×1Ñ1ð	÷ò ð !Ÿ?™?¨d¯l©lÔ:Ø ŸL™L¨¯©Õ9×@Ñ@À×Gò ;ô $ E¬2¯9©9×+IÑ+I×JÕJØ6;×3ñ+ $÷! #—?ðN ×'Ñ'¨Ó0×0Ò0òO #ò Aò$ò N÷$÷ $÷ $õ $ú÷% #—?—?’?úñN 	1ùsã   ‚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×!;Ñ!;Ü�K‰K×$Ñ$×;Ñ;ó"
Ð÷ "Ü!Ø&×0Ñ0Ø—‘×-Ñ-×DÑDóˆO÷  ?×6GÑ6GÔ#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
  MªV 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Ø�L‰L˜Ð#Ø×#×#×#Ó#Ø×*×*Ð*°4·<·<°<Ø—k‘k“m×#Ñ#à—‘Ô 3× :Ñ :Ô:À4Ç<Ç<À<Ü1×6Ñ6�”Ø×)Ñ)Ò5ÜŸ.š.Ó*�CØ&)×,BÑ,BÕ&B�D”OØ×,×,Ð,ØŸ+™+›-×'Ð'÷ $×#Ñ#ò 	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ˆØ—,‘,˜v tÓ,ˆà×ÑÒ+Ø×&Ñ&Ð&ð	Ø×-Ñ-×2Ñ2°4×3FÑ3FÈÓP×PˆDØ�sŒ{Ü)Ð*?Ó@Ð@ð ð )-¯©×(CÑ(CÀDÓ(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Ó8ˆLà×$Ñ$Ò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ÑBÀ9ÓMˆ
Ø"Ÿn™n×DÑDˆÜ�:Ó.ˆØ�aŒiØ×&Ñ& wÓ/×/Ð/ØŸ™×AÑAÀ)ÓLˆJØ!Ÿ^™^×CÑCˆNÜ�zÓ2ŠDØˆñ	 0ùs   ‚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‚   € à�K‰KÔ.×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,   € Ü�nŠnÓˆØ�‰ dÐ*×DÐD¨s·_±_Ñ/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ñ 9˜4ñ 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—\‘\Ó"ˆà�
ˆ|˜2˜f™Z r¨$¯+©+×*:Ñ*:Ð);ð <Ø"×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   é € ð �k‰k‹m×Ôù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Ø�Y‰Y×&Ñ&ÀÐ&ÓF€F÷%7õNfõP1õB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ˆð	ÜÐ4´f¸d¿m¹mÈV×T×TÕTØ#'×#3Ñ#3×#JÑ#JØ ŸM™M°T·_±_ð $Kô $÷  ð  ˜%ð  •Kñ	 Uñ ð $÷ U×T×T×T×TÔTûô
 ô 	ô )×*Õ*Ø—k‘k“m×#Ñ#÷ +àˆ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†   é € Ø�|�|ˆ|ØˆDŒLØ! 4§?¡?Ð3ˆFÜÐ.´¸¿¹Àv×N×NÕNØ×&Ñ&×7Ñ7À$Ç/Á/Ð7ÓR×RÐR÷ O×NÑNñ ñ OÙR÷ O×N×NÓNüs`   ‚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   