ó
    %Äãgkâ  ã                  óœ  • S r SSKJr  SSKJrJr  SSKJrJr  SSK	J
r
  SSKJrJrJrJrJrJrJrJr  SSKJrJr  SS	KJrJrJrJrJrJrJrJrJ r J!r!J"r"J#r#J$r$J%r%J&r&  SS
K'J(r(J)r)J*r*J+r+  SSK,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5J6r6  SSK7J8r8  \(       a  SSK9J:r:J;r;  SSK<J=r=  SSK>J?r?J@r@  SSKAJBrB   " S S\5      rC " S S\5      rD " S S\5      rE\F" \G" \C5      5       V s/ s H  n SPM     sn rHS\H\CR’                  '   S\H\CR”                  '   S\H\CR–                  '    " S S5      rL0 \CRš                  \DRœ                  4\LRž                  \CR’                  4_\CRš                  \DR                   4\LR¢                  \CR’                  4_\CRš                  \DR¤                  4\LR¦                  \CR¨                  4_\CRš                  \DRª                  4\LR¬                  \CR®                  4_\CRš                  \DR°                  4\LR²                  \CR´                  4_\CRš                  \DR¶                  4S\CRš                  4_\CRš                  \DR¸                  4\LRž                  \CR”                  4_\CRš                  \DRº                  4\LR¢                  \CR–                  4_\CR®                  \DRœ                  4\LR¼                  \CR–                  4_\CR®                  \DR¤                  4\LR¦                  \CR¨                  4_\CR®                  \DR¾                  4S\CR®                  4_\CR®                  \DRÀ                  4\LRÂ                  \CR®                  4_\CR®                  \DRÄ                  4\LRÆ                  \CR¨                  4_\CR®                  \DRÈ                  4\LRÊ                  \CR¨                  4_\CR®                  \DRÌ                  4\LRÎ                  \CR®                  4_\CR®                  \DR¶                  4S\CR®                  4_\CR´                  \DR                   4\LRÐ                  \CR”                  4_0 \CR´                  \DR¤                  4\LR¦                  \CR¨                  4_\CR´                  \DR¾                  4S\CR´                  4_\CR´                  \DRÀ                  4\LRÂ                  \CR´                  4_\CR´                  \DRÄ                  4\LRÆ                  \CR¨                  4_\CR´                  \DRÈ                  4\LRÊ                  \CR¨                  4_\CR´                  \DR¶                  4\LRÒ                  \CR´                  4_\CR’                  \DRœ                  4\LR¼                  \CR’                  4_\CR’                  \DR                   4\LRÐ                  \CR’                  4_\CR’                  \DRÔ                  4S\CR’                  4_\CR’                  \DR¤                  4\LRÖ                  \CR’                  4_\CR’                  \DRØ                  4S\CR”                  4_\CR’                  \DRÚ                  4\LRÜ                  \CR–                  4_\CR’                  \DR¾                  4S\CR’                  4_\CR’                  \DRÀ                  4\LRÂ                  \CR’                  4_\CR’                  \DRÄ                  4\LRÆ                  \CR¨                  4_\CR’                  \DRÈ                  4\LRÊ                  \CR¨                  4_\CR’                  \DRª                  4\LRÞ                  \CR’                  4_E0 \CR’                  \DR°                  4\LRà                  \CR’                  4_\CR’                  \DRâ                  4\LRä                  \CR’                  4_\CR’                  \DRæ                  4\LRè                  \CR’                  4_\CR’                  \DRÌ                  4\LRÎ                  \CR’                  4_\CR’                  \DR¶                  4\LRÒ                  \CR’                  4_\CR–                  \DRœ                  4\LR¼                  \CR–                  4_\CR–                  \DR                   4\LR¦                  \CR¨                  4_\CR–                  \DRÔ                  4S\CR–                  4_\CR–                  \DR¤                  4\LR¦                  \CR¨                  4_\CR–                  \DRØ                  4\LRê                  \CR¨                  4_\CR–                  \DR¾                  4S\CR–                  4_\CR–                  \DRÀ                  4\LRÂ                  \CR–                  4_\CR–                  \DRÄ                  4\LRÆ                  \CR¨                  4_\CR–                  \DRÈ                  4\LRÊ                  \CR¨                  4_\CR–                  \DRª                  4\LRÞ                  \CR–                  4_\CR–                  \DR°                  4\LR¦                  \CR¨                  4_\CR–                  \DRâ                  4\LRä                  \CR–                  4_E0 \CR–                  \DRÌ                  4\LRÎ                  \CR–                  4_\CR–                  \DR¶                  4\LRÒ                  \CR–                  4_\CR”                  \DR                   4\LRÐ                  \CR”                  4_\CR”                  \DR¤                  4\LRÖ                  \CR”                  4_\CR”                  \DRÚ                  4\LRì                  \CR¨                  4_\CR”                  \DR¾                  4S\CR”                  4_\CR”                  \DRÀ                  4\LRÂ                  \CR”                  4_\CR”                  \DRÄ                  4\LRÆ                  \CR¨                  4_\CR”                  \DRÈ                  4\LRÊ                  \CR¨                  4_\CR”                  \DR°                  4\LRà                  \CR”                  4_\CR”                  \DRæ                  4\LRè                  \CR”                  4_\CR”                  \DRÌ                  4\LRÎ                  \CR”                  4_\CR”                  \DR¶                  4\LRÒ                  \CR”                  4_\CR¨                  \DRÚ                  4S\CR¨                  4_\CR¨                  \DR¶                  4S\CR¨                  4_\CR¨                  \DR                   4\LRî                  \CR¨                  4_\CR¨                  \DR¤                  4\LRî                  \CR¨                  4_E\CR¨                  \DRÀ                  4S\CR¨                  4\CR¨                  \DRÈ                  4S\CR¨                  4\CR¨                  \DR°                  4\LRð                  \CR¨                  4\CR¨                  \DRœ                  4\LRò                  \CR¨                  4\CR¨                  \DRª                  4\LRô                  \CR¨                  4\CR¨                  \DRÄ                  4\LRò                  \CR¨                  4\CR¨                  \DRÔ                  4\LRò                  \CR¨                  4\CR¨                  \DR¾                  4\LRò                  \CR¨                  4\CR¨                  \DRØ                  4\LRò                  \CR¨                  40	Er{ " S S5      r|SS jr}gs  sn f ) z<
h2/stream
~~~~~~~~~

An implementation of a HTTP/2 stream.
é    )Úannotations)ÚEnumÚIntEnum)ÚTYPE_CHECKINGÚAny)ÚHeaderTuple)ÚAltSvcFrameÚContinuationFrameÚ	DataFrameÚFrameÚHeadersFrameÚPushPromiseFrameÚRstStreamFrameÚWindowUpdateFrameé   )Ú
ErrorCodesÚ_error_code_from_int)ÚAlternativeServiceAvailableÚDataReceivedÚEventÚInformationalResponseReceivedÚPushedStreamReceivedÚRequestReceivedÚResponseReceivedÚStreamEndedÚStreamResetÚTrailersReceivedÚWindowUpdatedÚ_PushedRequestSentÚ_RequestSentÚ_ResponseSentÚ_TrailersSent)ÚFlowControlErrorÚInvalidBodyLengthErrorÚProtocolErrorÚStreamClosedError)
ÚHeaderValidationFlagsÚauthority_from_headersÚextract_method_headerÚguard_increment_windowÚis_informational_responseÚnormalize_inbound_headersÚnormalize_outbound_headersÚutf8_encode_headersÚvalidate_headersÚvalidate_outbound_headers)ÚWindowManager)Ú	GeneratorÚIterable)ÚEncoder)ÚHeaderÚHeaderWeaklyTyped)ÚH2Configurationc                  ó0   • \ rS rSrSrSrSrSrSrSr	Sr
S	rg
)ÚStreamStateé9   r   r   é   é   é   é   é   © N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__ÚIDLEÚRESERVED_REMOTEÚRESERVED_LOCALÚOPENÚHALF_CLOSED_REMOTEÚHALF_CLOSED_LOCALÚCLOSEDÚ__static_attributes__r@   ó    Ú+/usr/lib/python3/dist-packages/h2/stream.pyr9   r9   9   s'   † Ø€DØ€OØ€NØ€DØÐØÐØƒFrM   r9   c                  ó`   • \ rS rSrSrSrSrSrSrSr	Sr
S	rS
rSrSrSrSrSrSrSrSrSrSrSrg)ÚStreamInputséC   r   r   r;   r<   r=   r>   r?   é   é   é	   é
   é   é   é   é   é   é   é   é   r@   N)rA   rB   rC   rD   ÚSEND_HEADERSÚSEND_PUSH_PROMISEÚSEND_RST_STREAMÚ	SEND_DATAÚSEND_WINDOW_UPDATEÚSEND_END_STREAMÚRECV_HEADERSÚRECV_PUSH_PROMISEÚRECV_RST_STREAMÚ	RECV_DATAÚRECV_WINDOW_UPDATEÚRECV_END_STREAMÚRECV_CONTINUATIONÚSEND_INFORMATIONAL_HEADERSÚRECV_INFORMATIONAL_HEADERSÚSEND_ALTERNATIVE_SERVICEÚRECV_ALTERNATIVE_SERVICEÚUPGRADE_CLIENTÚUPGRADE_SERVERrL   r@   rM   rN   rP   rP   C   sj   † Ø€LØÐØ€OØ€IØÐØ€OØ€LØÐØ€OØ€IØÐØ€OØÐØ!#ÐØ!#ÐØ!ÐØ!ÐØ€NØƒNrM   rP   c                  ó$   • \ rS rSrSrSrSrSrSrg)ÚStreamClosedByéY   r   r   r;   r<   r@   N)	rA   rB   rC   rD   rc   ri   r`   rf   rL   r@   rM   rN   rr   rr   Y   s   † Ø€OØ€OØ€OØƒOrM   rr   FTc                  ó  • \ rS rSrSrSS jrS S jrS!S jrS!S jrS!S jr	S!S jr
S!S	 jrS!S
 jrS!S jrS!S jrS!S jrS!S jrS!S jrS!S jrS!S jrS"S jrS"S jrS"S jrS"S jrS"S jrS"S jrS"S jrS!S jrS!S jrS!S jrS"S jrSrg)#ÚH2StreamStateMachineék   zé
A single HTTP/2 stream state machine.

This stream object implements basically the state machine described in
RFC 7540 section 5.1.

:param stream_id: The stream ID of this stream. This is stored primarily
    for logging purposes.
c                óŽ   • [         R                  U l        Xl        S U l        S U l        S U l        S U l        S U l        S U l	        g )N)
r9   rE   ÚstateÚ	stream_idÚclientÚheaders_sentÚtrailers_sentÚheaders_receivedÚtrailers_receivedÚstream_closed_by)Úselfry   s     rN   Ú__init__ÚH2StreamStateMachine.__init__v   sI   € Ü ×%Ñ%ˆŒ
Ø"Œð $(ˆŒð *.ˆÔØ*.ˆÔØ-1ˆÔØ.2ˆÔð 8<ˆÕrM   c                óè  • [        U[        5      (       d  Sn[        U5      e [        U R                  U4   u  p4U R                  nX@l        Ub	   U" X5      $ / $ ! [
         a    [        R                  U l        e [         a&  n[        R                  U l        [        U5      UeSnAff = f! [         a:  nU R                  n[        R                  U l        SU SU 3n[        U5      UeSnAff = f)z0
Process a specific input in the state machine.
z)Input must be an instance of StreamInputsNzInvalid input z
 in state )
Ú
isinstancerP   Ú
ValueErrorÚ_transitionsrx   r%   r9   rK   ÚAssertionErrorÚKeyError)r€   Úinput_ÚmsgÚfuncÚtarget_stateÚprevious_stateÚerrÚ	old_states           rN   Úprocess_inputÚ"H2StreamStateMachine.process_input†   sò   € ô ˜&¤,×/Ñ/Ø=ˆCÜ˜S“/Ð!ð	Ü!-¨t¯z©z¸6Ð.BÑ!CÑˆDð "ŸZ™ZˆNØ%ŒJØÑð6Ù Ó5Ð5ð ˆIøô %ó Ü!,×!3Ñ!3�D”JØÜ%ó 6Ü!,×!3Ñ!3�D”JÜ'¨Ó,°#Ð5ûð6ûô ó 	.ØŸ
™
ˆIÜ$×+Ñ+ˆDŒJØ" 6 (¨*°Y°KÐ@ˆCÜ Ó$¨#Ð-ûð		.ús/   ¤B- ÁA Á)B*Â!B%Â%B*Â-
C1Â75C,Ã,C1c                ó8   • SU l         SU l        [        5       nU/$ )z
Fires when a request is sent.
T)rz   r{   r    ©r€   r�   Úevents      rN   Úrequest_sentÚ!H2StreamStateMachine.request_sent¤   s!   € ð ˆŒØ ˆÔÜ“ˆàˆwˆrM   c                óä   • U R                   (       d;  U R                  SL d  U R                  c  Sn[        U5      eSU l         [        5       /$ U R                  (       a   eSU l        [        5       /$ )zc
Fires when something that should be a response is sent. This 'response'
may actually be trailers.
TzClient cannot send responses.)r{   rz   r%   r!   r|   r"   ©r€   r�   rŠ   s      rN   Úresponse_sentÚ"H2StreamStateMachine.response_sent®   sg   € ð
 × × Ø�{‰{˜dÒ" d§k¡kÑ&9Ø5�Ü# CÓ(Ð(Ø $ˆDÔÜ!“OÐ$Ð$Ø×%×%Ð%Ð%Ø!ˆÔÜ“Ð Ð rM   c                ó¦   • U R                   (       a   eU R                  (       a   eSU l        SU l         [        5       nU R                  Ul        U/$ )z#
Fires when a request is received.
FT)r}   r~   rz   r   ry   r“   s      rN   Úrequest_receivedÚ%H2StreamStateMachine.request_received½   sK   € ð ×(×(Ð(Ð(Ø×)×)Ð)Ð)àˆŒØ $ˆÔÜÓ!ˆØŸ.™.ˆŒØˆwˆrM   c                óÚ   • U R                   (       d#  U R                  SL d   eSU l         [        5       nO$U R                  (       a   eSU l        [	        5       nU R
                  Ul        U/$ )zW
Fires when a response is received. Also disambiguates between responses
and trailers.
T)r}   rz   r   r~   r   ry   r“   s      rN   Úresponse_receivedÚ&H2StreamStateMachine.response_receivedÊ   s`   € ð ×$×$Ø—;‘; $Ò&Ð&Ð&Ø$(ˆDÔ!Ü$Ó&‰Eà×-×-Ð-Ð-Ø%)ˆDÔ"Ü$Ó&ˆEàŸ.™.ˆŒØˆwˆrM   c                óz   • U R                   (       d  Sn[        U5      e[        5       nU R                  Ul        U/$ )z
Fires when data is received.
z"cannot receive data before headers)r}   r%   r   ry   ©r€   r�   rŠ   r”   s       rN   Údata_receivedÚ"H2StreamStateMachine.data_receivedÜ   s6   € ð ×$×$Ø6ˆCÜ Ó$Ð$Ü“ˆØŸ.™.ˆŒØˆwˆrM   c                ó>   • [        5       nU R                  Ul        U/$ )z/
Fires when a window update frame is received.
)r   ry   r“   s      rN   Úwindow_updatedÚ#H2StreamStateMachine.window_updatedç   s   € ô “ˆØŸ.™.ˆŒØˆwˆrM   c                ó>   • [        5       nU R                  Ul        U/$ )zw
Fires when an END_STREAM flag is received in the OPEN state,
transitioning this stream to a HALF_CLOSED_REMOTE state.
)r   ry   r“   s      rN   Ústream_half_closedÚ'H2StreamStateMachine.stream_half_closedï   s   € ô
 “ˆØŸ.™.ˆŒØˆwˆrM   c                óh   • [         R                  U l        [        5       nU R                  Ul        U/$ )z'
Fires when a stream is cleanly ended.
)rr   ri   r   r   ry   r“   s      rN   Ústream_endedÚ!H2StreamStateMachine.stream_endedø   ó+   € ô !/× >Ñ >ˆÔÜ“ˆØŸ.™.ˆŒØˆwˆrM   c                óh   • [         R                  U l        [        5       nU R                  Ul        U/$ )z*
Fired when a stream is forcefully reset.
)rr   rf   r   r   ry   r“   s      rN   Ústream_resetÚ!H2StreamStateMachine.stream_reset  r®   rM   c                ó@   • U R                   b   eSU l         SU l        / $ )z�
Fires on the newly pushed stream, when pushed by the local peer.

No event here, but definitionally this peer must be a server.
FT)rz   r}   ©r€   r�   s     rN   Úsend_new_pushed_streamÚ+H2StreamStateMachine.send_new_pushed_stream
  s(   € ð �{‰{Ñ"Ð"Ð"ØˆŒØ $ˆÔØˆ	rM   c                ó@   • U R                   b   eSU l         SU l        / $ )z‚
Fires on the newly pushed stream, when pushed by the remote peer.

No event here, but definitionally this peer must be a client.
T)rz   r{   r³   s     rN   Úrecv_new_pushed_streamÚ+H2StreamStateMachine.recv_new_pushed_stream  s(   € ð �{‰{Ñ"Ð"Ð"ØˆŒØ ˆÔØˆ	rM   c                óT   • U R                   SL a  Sn[        U5      e[        5       nU/$ )z�
Fires on the already-existing stream when a PUSH_PROMISE frame is sent.
We may only send PUSH_PROMISE frames if we're a server.
Tz&Cannot push streams from client peers.)rz   r%   r   r¢   s       rN   Úsend_push_promiseÚ&H2StreamStateMachine.send_push_promise   s/   € ð
 �;‰;˜$ÒØ:ˆCÜ Ó$Ð$ä"Ó$ˆØˆwˆrM   c                óš   • U R                   (       d  U R                   c  SnOSn[        U5      e[        5       nU R                  Ul        U/$ )z­
Fires on the already-existing stream when a PUSH_PROMISE frame is
received. We may only receive PUSH_PROMISE frames if we're a client.

Fires a PushedStreamReceived event.
z"Idle streams cannot receive pushesz)Cannot receive pushed streams as a server)rz   r%   r   ry   Úparent_stream_idr¢   s       rN   Úrecv_push_promiseÚ&H2StreamStateMachine.recv_push_promise,  sE   € ð �{�{Ø�{‰{Ñ"Ø:‘àA�Ü Ó$Ð$ä$Ó&ˆØ!%§¡ˆÔØˆwˆrM   c                ó.   • [         R                  U l        g)zT
Called when an attempt is made to send END_STREAM in the
HALF_CLOSED_REMOTE state.
N)rr   rc   r   r³   s     rN   Úsend_end_streamÚ$H2StreamStateMachine.send_end_stream>  ó   € ô
 !/× >Ñ >ˆÕrM   c                ó.   • [         R                  U l        g)zQ
Called when an attempt is made to send RST_STREAM in a non-closed
stream state.
N)rr   r`   r   r³   s     rN   Úsend_reset_streamÚ&H2StreamStateMachine.send_reset_streamE  rÃ   rM   c                óØ   • [         R                  U l        [        U R                  5      n[        5       nU R                  Ul        [        R                  Ul        SUl	        U/Ul
        Ue)aK  
Called when we need to forcefully emit another RST_STREAM frame on
behalf of the state machine.

If this is the first time we've done this, we should also hang an event
off the StreamClosedError so that the user can be informed. We know
it's the first time we've done this if the stream is currently in a
state other than CLOSED.
F)rr   r`   r   r&   ry   r   r   ÚSTREAM_CLOSEDÚ
error_codeÚremote_resetÚ_events)r€   r�   Úerrorr”   s       rN   Úreset_stream_on_errorÚ*H2StreamStateMachine.reset_stream_on_errorL  sV   € ô !/× >Ñ >ˆÔä! $§.¡.Ó1ˆä“ˆØŸ.™.ˆŒÜ%×3Ñ3ˆÔØ"ˆÔØ˜ˆŒØˆrM   c                ó,   • [        U R                  5      e)a?  
Called when an unexpected frame is received on an already-closed
stream.

An endpoint that receives an unexpected frame should treat it as
a stream error or connection error with type STREAM_CLOSED, depending
on the specific frame. The error handling is done at a higher level:
this just raises the appropriate error.
©r&   ry   r³   s     rN   Úrecv_on_closed_streamÚ*H2StreamStateMachine.recv_on_closed_streama  ó   € ô   §¡Ó/Ð/rM   c                ó,   • [        U R                  5      e)a#  
Called when an attempt is made to send data on an already-closed
stream.

This essentially overrides the standard logic by throwing a
more-specific error: StreamClosedError. This is a ProtocolError, so it
matches the standard API of the state machine, but provides more detail
to the user.
rÐ   r³   s     rN   Úsend_on_closed_streamÚ*H2StreamStateMachine.send_on_closed_streamm  rÓ   rM   c                ó    • U R                   c   eU R                   [        R                  :X  a  [        U R                  5      eSn[        U5      e)aÌ  
Called when a PUSH_PROMISE frame is received on a full stop
stream.

If the stream was closed by us sending a RST_STREAM frame, then we
presume that the PUSH_PROMISE was in flight when we reset the parent
stream. Rathen than accept the new stream, we just reset it.
Otherwise, we should call this a PROTOCOL_ERROR: pushing a stream on a
naturally closed stream is a real problem because it creates a brand
new stream that the remote peer now believes exists.
ú#Attempted to push on closed stream.)r   rr   r`   r&   ry   r%   r˜   s      rN   Úrecv_push_on_closed_streamÚ/H2StreamStateMachine.recv_push_on_closed_streamy  sI   € ð ×$Ñ$Ñ0Ð0Ð0à× Ñ ¤N×$BÑ$BÓBÜ# D§N¡NÓ3Ð3Ø3ˆÜ˜CÓ Ð rM   c                ó   • Sn[        U5      e)ac  
Called when an attempt is made to push on an already-closed stream.

This essentially overrides the standard logic by providing a more
useful error message. It's necessary because simply indicating that the
stream is closed is not enough: there is now a new stream that is not
allowed to be there. The only recourse is to tear the whole connection
down.
rØ   )r%   r˜   s      rN   Úsend_push_on_closed_streamÚ/H2StreamStateMachine.send_push_on_closed_streamŒ  s   € ð 4ˆÜ˜CÓ Ð rM   c                óX   • U R                   (       a  Sn[        U5      e[        5       nU/$ )z´
Called when an informational header block is sent (that is, a block
where the :status header has a 1XX value).

Only enforces that these are sent *before* final headers are sent.
z)Information response after final response)r{   r%   r!   r¢   s       rN   Úsend_informational_responseÚ0H2StreamStateMachine.send_informational_response™  s+   € ð ××Ø=ˆCÜ Ó$Ð$ä“ˆØˆwˆrM   c                óz   • U R                   (       a  Sn[        U5      e[        5       nU R                  Ul        U/$ )zt
Called when an informational header block is received (that is, a block
where the :status header has a 1XX value).
z+Informational response after final response)r}   r%   r   ry   r¢   s       rN   Úrecv_informational_responseÚ0H2StreamStateMachine.recv_informational_response§  s7   € ð
 × × Ø?ˆCÜ Ó$Ð$ä-Ó/ˆØŸ.™.ˆŒØˆwˆrM   c                ó`   • U R                   SL a  / $ U R                  (       a  / $ [        5       /$ )aÅ  
Called when receiving an ALTSVC frame.

RFC 7838 allows us to receive ALTSVC frames at any stream state, which
is really absurdly overzealous. For that reason, we want to limit the
states in which we can actually receive it. It's really only sensible
to receive it after we've sent our own headers and before the server
has sent its header block: the server can't guarantee that we have any
state around after it completes its header block, and the server
doesn't know what origin we're talking about before we've sent ours.

For that reason, this function applies a few extra checks on both state
and some of the little state variables we keep around. If those suggest
an unreasonable situation for the ALTSVC frame to have been sent in,
we quietly ignore it (as RFC 7838 suggests).

This function is also *not* always called by the state machine. In some
states (IDLE, RESERVED_LOCAL, CLOSED) we don't bother to call it,
because we know the frame cannot be valid in that state (IDLE because
the server cannot know what origin the stream applies to, CLOSED
because the server cannot assume we still have state around,
RESERVED_LOCAL because by definition if we're in the RESERVED_LOCAL
state then *we* are the server).
F)rz   r}   r   r³   s     rN   Úrecv_alt_svcÚ!H2StreamStateMachine.recv_alt_svc´  s3   € ð6 �;‰;˜%ÒØˆIð
 × × ØˆIô ,Ó-Ð.Ð.rM   c                ó@   • U R                   (       a  Sn[        U5      eg)aˆ  
Called when sending an ALTSVC frame on this stream.

For consistency with the restrictions we apply on receiving ALTSVC
frames in ``recv_alt_svc``, we want to restrict when users can send
ALTSVC frames to the situations when we ourselves would accept them.

That means: when we are a server, when we have received the request
headers, and when we have not yet sent our own response headers.
z2Cannot send ALTSVC after sending response headers.N)r{   r%   r˜   s      rN   Úsend_alt_svcÚ!H2StreamStateMachine.send_alt_svcÜ  s"   € ð ××ØFˆCÜ Ó$Ð$ð rM   )rz   r}   r{   rx   r   ry   r~   r|   N)ry   ÚintÚreturnÚNone)r‰   rP   rë   r   )r�   r9   rë   zlist[Event])r�   r9   rë   rì   ) rA   rB   rC   rD   Ú__doc__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å   rè   rL   r@   rM   rN   ru   ru   k   sŠ   † ñô<ô ô<ô!ôôô$	ôôôôô	ô	ô
ôô$?ô?ôô*
0ô
0ô!ô&!ôôô&/÷P%rM   ru   Nc                  ó  • \ rS rSrSr          S#S jrS$S jr\S%S j5       r\S&S j5       r	\S&S j5       r
\S'S j5       rS(S	 jr S)       S*S
 jjr        S+S jrS,S jr  S-       S.S jjrS,S jrS/S jrS0S jr        S1S jrS2S jr        S3S jrS4S jrS5S jrS6S jrS7S jrS8S9S jjrS:S jrS;S jrS<S jr          S=S jr        S>S jr S?S jr!S@S  jr"SAS! jr#S"r$g)BÚH2Streamiý  aJ  
A low-level HTTP/2 stream object. This handles building and receiving
frames and maintains per-stream state.

This wraps a HTTP/2 Stream state machine implementation, ensuring that
frames can only be sent/received when the stream is in a valid state.
Attempts to create frames that cannot be sent will raise a
``ProtocolError``.
c                ó®   • [        U5      U l        Xl        S U l        S U l        X@l        [        U5      U l        S U l        SU l	        S U l
        X l        g )Nr   )ru   Ústate_machinery   Úmax_outbound_frame_sizeÚrequest_methodÚoutbound_flow_control_windowr1   Ú_inbound_window_managerÚ_expected_content_lengthÚ_actual_content_lengthÚ
_authorityÚconfig)r€   ry   rù   Úinbound_window_sizeÚoutbound_window_sizes        rN   r�   ÚH2Stream.__init__  sc   € ô
 2°)Ó<ˆÔØ"ŒØ37ˆÔ$Ø,0ˆÔð -AÔ)ô (5Ð5HÓ'IˆÔ$ð 59ˆÔ%ð '(ˆÔ#ð )-ˆŒð �rM   c                ó~   • S[        U 5      R                   SU R                   SU R                  R                  < S3$ )NÚ<z id:z state:Ú>)ÚtyperA   ry   rñ   rx   ©r€   s    rN   Ú__repr__ÚH2Stream.__repr__$  s;   € Ø”4˜“:×&Ñ&Ð' t¨D¯N©NÐ+;¸7À4×CUÑCU×C[ÑC[ÑB^Ð^_Ð`Ð`rM   c                ó.   • U R                   R                  $ )a  
The size of the inbound flow control window for the stream. This is
rarely publicly useful: instead, use :meth:`remote_flow_control_window
<h2.stream.H2Stream.remote_flow_control_window>`. This shortcut is
largely present to provide a shortcut to this data.
)rõ   Úcurrent_window_sizer  s    rN   Úinbound_flow_control_windowÚ$H2Stream.inbound_flow_control_window'  s   € ð ×+Ñ+×?Ñ?Ð?rM   c                ó<   • [         U R                  R                     $ )zq
Whether the stream is 'open' in any sense: that is, whether it counts
against the number of concurrent streams.
)ÚSTREAM_OPENrñ   rx   r  s    rN   ÚopenÚH2Stream.open1  s   € ô ˜4×-Ñ-×3Ñ3Ñ4Ð4rM   c                óP   • U R                   R                  [        R                  :H  $ )z
Whether the stream is closed.
)rñ   rx   r9   rK   r  s    rN   ÚclosedÚH2Stream.closed>  s!   € ð
 ×!Ñ!×'Ñ'¬;×+=Ñ+=Ñ=Ð=rM   c                ó.   • U R                   R                  $ )z>
Returns how the stream was closed, as one of StreamClosedBy.
)rñ   r   r  s    rN   Ú	closed_byÚH2Stream.closed_byE  s   € ð
 ×!Ñ!×2Ñ2Ð2rM   c                óø   • U R                   R                  R                  SU 5        U R                  S:X  d   eU(       a  [        R
                  O[        R                  nU R                  R                  U5        g)zŸ
Called by the connection to indicate that this stream is the initial
request/response of an upgraded connection. Places the stream into an
appropriate state.
zUpgrading %rr   N)	rù   ÚloggerÚdebugry   rP   ro   rp   rñ   r�   )r€   Úclient_sider‰   s      rN   ÚupgradeÚH2Stream.upgradeL  s_   € ð 	�‰×Ñ× Ñ  °Ô6à�~‰~ Ó"Ð"Ð"æ+6ŒL×'Ò'Ü×,Ñ,ð 	ð 	×Ñ×(Ñ(¨Õ0rM   c                óV  • U R                   R                  R                  SX5        [        R                  n[        U5      nU R                  R                  (       d4  [        U5      (       a$  U(       a  Sn[        U5      e[        R                  nU R                  R                  U5      n[        U R                  5      nU R                  U5      n	U R                  XRX‰5      n
U(       aG  U R                  R                  [        R                   5        U
S   R"                  R%                  S5        U R                  R&                  (       a  U(       d  Sn[        U5      eU R                  R                  (       a  U R(                  c  [+        U5      U l        [-        U5      U l        U
$ )zV
Returns a list of HEADERS/CONTINUATION frames to emit as either headers
or trailers.
zSend headers %s on %rz1Cannot set END_STREAM on informational responses.r   Ú
END_STREAMz"Trailers must have END_STREAM set.)rù   r  r  rP   r^   r.   rñ   rz   r+   r%   rk   r�   r   ry   Ú_build_hdr_validation_flagsÚ_build_headers_framesrc   ÚflagsÚaddr|   rø   r(   r)   ró   )r€   ÚheadersÚencoderÚ
end_streamr‰   Úbytes_headersrŠ   ÚeventsÚhfÚhdr_validation_flagsÚframess              rN   Úsend_headersÚH2Stream.send_headers]  sH  € ð 	�‰×Ñ× Ñ Ð!8¸'ÔHô ×*Ñ*ˆä+¨GÓ4ˆà×#Ñ#×*×*Ü)¨-×8Ñ8ÞØI�Ü# CÓ(Ð(ä!×<Ñ<ˆFà×#Ñ#×1Ñ1°&Ó9ˆä˜$Ÿ.™.Ó)ˆØ#×?Ñ?ÀÓGÐØ×+Ñ+Ø Bó
ˆö ð ×Ñ×,Ñ,¬\×-IÑ-IÔJØ�1‰I�O‰O×Ñ Ô-à×Ñ×+×+¶JØ6ˆCÜ Ó$Ð$à×Ñ×$×$¨¯©Ñ)@Ü4°]ÓCˆDŒOô 4°MÓBˆÔàˆrM   c                ó2  • U R                   R                  R                  SU 5        U R                  R	                  [
        R                  5      n[        U R                  5      nXl	        U R                  U5      n[        U5      nU R                  XsXV5      $ )z˜
Returns a list of PUSH_PROMISE/CONTINUATION frames to emit as a pushed
stream header. Called on the stream that has the PUSH_PROMISE frame
sent on it.
zPush stream %r)rù   r  r  rñ   r�   rP   r_   r   ry   Úpromised_stream_idr  r.   r  )r€   Úrelated_stream_idr  r  r"  Úppfr$  r!  s           rN   Úpush_stream_in_bandÚH2Stream.push_stream_in_band”  s‰   € ð 	�‰×Ñ× Ñ Ð!1°4Ô8ð
 ×#Ñ#×1Ñ1Ü×*Ñ*ó
ˆô ˜tŸ~™~Ó.ˆØ!2ÔØ#×?Ñ?ÀÓGÐä+¨GÓ4ˆà×)Ñ)Ø Có
ð 	
rM   c                ój   • U R                   R                  [        R                  5      nU(       a   e/ $ )z›
Mark this stream as one that was pushed by this peer. Must be called
immediately after initialization. Sends no frames, simply updates the
state machine.
)rñ   r�   rP   r_   )r€   r"  s     rN   Úlocally_pushedÚH2Stream.locally_pushed±  s2   € ð ×#Ñ#×1Ñ1Ü×*Ñ*ó
ˆö ÐˆzØˆ	rM   Nc                ó  • U R                   R                  R                  SX5        U R                  R	                  [
        R                  5        [        U R                  5      nXl	        U(       aD  U R                  R	                  [
        R                  5        UR                  R                  S5        Ub!  UR                  R                  S5        X4l        U =R                  UR                  -  sl        U R                  S:¼  d   eU/$ )zj
Prepare some data frames. Optionally end the stream.

.. warning:: Does not perform flow control checks.
z)Send data on %r with end stream set to %sr  ÚPADDEDr   )rù   r  r  rñ   r�   rP   ra   r   ry   Údatarc   r  r  Ú
pad_lengthrô   Úflow_controlled_length)r€   r3  r   r4  Údfs        rN   Ú	send_dataÚH2Stream.send_data¾  sÌ   € ð 	�‰×Ñ× Ñ Ø7¸ô	
ð 	×Ñ×(Ñ(¬×)?Ñ)?Ô@ä�t—~‘~Ó&ˆØŒÞØ×Ñ×,Ñ,¬\×-IÑ-IÔJØ�H‰H�L‰L˜Ô&ØÑ!Ø�H‰H�L‰L˜Ô"Ø&ŒMð 	×)Ò)¨R×-FÑ-FÑFÕ)Ø×0Ñ0°AÓ5Ð5Ð5àˆtˆrM   c                ó  • U R                   R                  R                  SU 5        U R                  R	                  [
        R                  5        [        U R                  5      nUR                  R                  S5        U/$ )z$
End a stream without sending data.
zEnd stream %rr  )rù   r  r  rñ   r�   rP   rc   r   ry   r  r  )r€   r6  s     rN   r   ÚH2Stream.end_streamÜ  s]   € ð 	�‰×Ñ× Ñ  °$Ô7à×Ñ×(Ñ(¬×)EÑ)EÔFÜ�t—~‘~Ó&ˆØ
�‰�‰�\Ô"ØˆtˆrM   c                óÜ   • U R                   R                  R                  SX5        U R                  R	                  [
        R                  5        [        U R                  5      nXl	        U/$ )zw
Advertise an RFC 7838 alternative service. The semantics of this are
better documented in the ``H2Connection`` class.
z*Advertise alternative service of %r for %r)
rù   r  r  rñ   r�   rP   rm   r	   ry   Úfield)r€   Úfield_valueÚasfs      rN   Úadvertise_alternative_serviceÚ&H2Stream.advertise_alternative_serviceç  sW   € ð
 	�‰×Ñ× Ñ Ø8¸+ô	
ð 	×Ñ×(Ñ(¬×)NÑ)NÔOÜ˜$Ÿ.™.Ó)ˆØŒ	ØˆuˆrM   c                ó  • U R                   R                  R                  SX5        U R                  R	                  [
        R                  5        U R                  R                  U5        [        U R                  5      nXl        U/$ )zC
Increase the size of the flow control window for the remote side.
z)Increase flow control window for %r by %d)rù   r  r  rñ   r�   rP   rb   rõ   Úwindow_openedr   ry   Úwindow_increment)r€   Ú	incrementÚwufs      rN   Úincrease_flow_control_windowÚ%H2Stream.increase_flow_control_windowô  sm   € ð 	�‰×Ñ× Ñ Ø7Øô	
ð 	×Ñ×(Ñ(¬×)HÑ)HÔIØ×$Ñ$×2Ñ2°9Ô=ä §¡Ó/ˆØ(ÔØˆuˆrM   c                ó  • U R                   R                  R                  SX5        U R                  R	                  [
        R                  5      nXS   l        U R                  U5      nU R                  X%U5      US   l
        / U4$ )z�
Receives a push promise frame sent on this stream, pushing a remote
stream. This is called on the stream that has the PUSH_PROMISE sent
on it.
z/Receive Push Promise on %r for remote stream %dr   )rù   r  r  rñ   r�   rP   re   Úpushed_stream_idr  Ú_process_received_headersr  )r€   r)  r  Úheader_encodingr"  r$  s         rN   Úreceive_push_promise_in_bandÚ%H2Stream.receive_push_promise_in_band  sˆ   € ð 	�‰×Ñ× Ñ Ø=Øô	
ð ×#Ñ#×1Ñ1Ü×*Ñ*ó
ˆð &8ˆq‰	Ô"à#×?Ñ?ÀÓGÐØ ×:Ñ:Ø¨?ó
ˆˆq‰	Ôð �6ˆzÐrM   c                óÈ   • U R                   R                  R                  SU 5        U R                  R	                  [
        R                  5      n[        U5      U l        / U4$ )z¡
Mark this stream as one that was pushed by the remote peer. Must be
called immediately after initialization. Sends no frames, simply
updates the state machine.
z%r pushed by remote peer)	rù   r  r  rñ   r�   rP   re   r(   rø   )r€   Úpushed_headersr"  s      rN   Úremotely_pushedÚH2Stream.remotely_pushed  sV   € ð 	�‰×Ñ× Ñ Ð!;¸TÔBØ×#Ñ#×1Ñ1Ü×*Ñ*ó
ˆô 1°Ó@ˆŒØ�6ˆzÐrM   c                ó  • [        U5      (       a%  U(       a  Sn[        U5      e[        R                  nO[        R                  nU R
                  R                  U5      nU(       a:  U R
                  R                  [        R                  5      nUS   US   l        Xg-  nU R                  U5        [        US   [        5      (       a  U(       d  Sn[        U5      eU R                  U5      nU R                  XU5      US   l        / U4$ )z)
Receive a set of headers (or trailers).
z0Cannot set END_STREAM on informational responsesr   z!Trailers must have END_STREAM set)r+   r%   rP   rl   rd   rñ   r�   ri   r¬   Ú_initialize_content_lengthr„   r   r  rJ  r  )	r€   r  r   rK  rŠ   r‰   r"  Ú	es_eventsr$  s	            rN   Úreceive_headersÚH2Stream.receive_headers(  sõ   € ô % W×-Ñ-ÞØH�Ü# CÓ(Ð(Ü!×<Ñ<‰Fä!×.Ñ.ˆFà×#Ñ#×1Ñ1°&Ó9ˆæØ×*Ñ*×8Ñ8Ü×,Ñ,óˆIð &/¨q¡\ˆF�1‰IÔ"ØÑˆFà×'Ñ'¨Ô0ä�f˜Q‘iÔ!1×2Ñ2¾:Ø5ˆCÜ Ó$Ð$à#×?Ñ?ÀÓGÐØ ×:Ñ:Ø¨?ó
ˆˆq‰	Ôð �6ˆzÐrM   c                óÖ  • U R                   R                  R                  SXU5        U R                  R	                  [
        R                  5      nU R                  R                  U5        U R                  [        U5      U5        U(       aG  U R                  R	                  [
        R                  5      nUS   US   l        UR                  U5        XS   l        X4S   l        / U4$ )z
Receive some data.
zGReceive data on %r with end stream %s and flow control length set to %dr   )rù   r  r  rñ   r�   rP   rg   rõ   Úwindow_consumedÚ_track_content_lengthÚlenri   r¬   Úextendr3  r5  )r€   r3  r   Úflow_control_lenr"  rT  s         rN   Úreceive_dataÚH2Stream.receive_dataL  sË   € ð 	�‰×Ñ× Ñ ðØÐ+;ô	
ð ×#Ñ#×1Ñ1´,×2HÑ2HÓIˆØ×$Ñ$×4Ñ4Ð5EÔFØ×"Ñ"¤3 t£9¨jÔ9æØ×*Ñ*×8Ñ8Ü×,Ñ,óˆIð &/¨q¡\ˆF�1‰IÔ"Ø�M‰M˜)Ô$àˆq‰	ŒØ+;ˆq‰	Ô(Ø�6ˆzÐrM   c                óÖ  • U R                   R                  R                  SX5        U R                  R	                  [
        R                  5      n/ nU(       a(  XS   l         [        U R                  U5      U l	        X24$ X24$ ! [         aZ    [        5       nU R                  Ul        [        R                  Ul        SUl        U/nU R#                  UR                  5      n X24$ f = f)z#
Handle a WINDOW_UPDATE increment.
z/Receive Window Update on %r for increment of %dr   F)rù   r  r  rñ   r�   rP   rh   Údeltar*   rô   r#   r   ry   r   ÚFLOW_CONTROL_ERRORrÉ   rÊ   Úreset_stream)r€   rD  r"  r%  r”   s        rN   Úreceive_window_updateÚH2Stream.receive_window_updatec  sç   € ð 	�‰×Ñ× Ñ Ø=Øô	
ð ×#Ñ#×1Ñ1Ü×+Ñ+ó
ˆð ˆö
 Ø'�1‰IŒOð=Ü4JØ×5Ñ5Øó5�Ô1ð ˆ~Ðˆvˆ~Ðøô $ó 	=ô $›�Ø"&§.¡.�”Ü#-×#@Ñ#@�Ô Ø%*�Ô"à˜�Ø×*Ñ*¨5×+;Ñ+;Ó<‘àˆ~Ðð	=ús   Á#B ÂAC(Ã'C(c                óº   • U R                   R                  R                  SU 5        U R                  R	                  [
        R                  5        Sn[        U5      e)zÍ
A naked CONTINUATION frame has been received. This is always an error,
but the type of error it is depends on the state of the stream and must
transition the state of the stream, so we need to handle it.
z Receive Continuation frame on %rzShould not be reachable)rù   r  r  rñ   r�   rP   rj   r‡   )r€   rŠ   s     rN   Úreceive_continuationÚH2Stream.receive_continuation‡  sN   € ð 	�‰×Ñ× Ñ Ð!CÀTÔJØ×Ñ×(Ñ(Ü×*Ñ*ô	
ð (ˆÜ˜SÓ!Ð!rM   c                ód  • U R                   R                  R                  SU 5        UR                  (       a  / / 4$ U R                  R                  [        R                  5      nU(       aB  [        US   [        5      (       d   eU R                  US   l        UR                  US   l        / U4$ )zv
An Alternative Service frame was received on the stream. This frame
inherits the origin associated with this stream.
z.Receive Alternative Service frame on stream %rr   )rù   r  r  Úoriginrñ   r�   rP   rn   r„   r   rø   r<  r=  ©r€   Úframer"  s      rN   Úreceive_alt_svcÚH2Stream.receive_alt_svc”  s™   € ð
 	�‰×Ñ× Ñ Ø<¸dô	
ð
 �<�<Ø�r�6ˆMà×#Ñ#×1Ñ1Ü×1Ñ1ó
ˆö Ü˜f Q™iÔ)D×EÑEÐEÐEØ#Ÿ™ˆF�1‰IÔØ$)§K¡KˆF�1‰IÔ!à�6ˆzÐrM   c                óÜ   • U R                   R                  R                  SX5        U R                  R	                  [
        R                  5        [        U R                  5      nXl	        U/$ )z@
Close the stream locally. Reset the stream with an error code.
z"Local reset %r with error code: %d)
rù   r  r  rñ   r�   rP   r`   r   ry   rÉ   )r€   rÉ   Úrsfs      rN   rb  ÚH2Stream.reset_stream¯  sW   € ð 	�‰×Ñ× Ñ Ø0°$ô	
ð 	×Ñ×(Ñ(¬×)EÑ)EÔFä˜TŸ^™^Ó,ˆØ#ŒØˆuˆrM   c                ó  • U R                   R                  R                  SXR                  5        U R                  R                  [        R                  5      nU(       a  [        UR                  5      US   l        / U4$ )z'
Handle a stream being reset remotely.
z#Remote reset %r with error code: %dr   )	rù   r  r  rÉ   rñ   r�   rP   rf   r   rj  s      rN   r°   ÚH2Stream.stream_reset¼  si   € ð 	�‰×Ñ× Ñ Ø1°4×9IÑ9Iô	
ð ×#Ñ#×1Ñ1´,×2NÑ2NÓOˆæä#7¸×8HÑ8HÓ#IˆF�1‰IÔ à�6ˆzÐrM   c                óÒ   • U R                   R                  R                  SX5        U R                  R	                  U5      nU(       a  [        U R                  5      nX#l        U/$ / $ )z¸
The user has informed us that they've processed some amount of data
that was received on this stream. Pass that to the window manager and
potentially return some WindowUpdate frames.
z,Acknowledge received data with size %d on %r)rù   r  r  rõ   Úprocess_bytesr   ry   rC  )r€   Úacknowledged_sizerD  Úfs       rN   Úacknowledge_received_dataÚ"H2Stream.acknowledge_received_dataË  sb   € ð 	�‰×Ñ× Ñ Ø:Øô	
ð ×0Ñ0×>Ñ>Øó
ˆ	ö Ü! $§.¡.Ó1ˆAØ!*ÔØ�3ˆJàˆ	rM   c                óô   • [        US   [        [        45      n[        US   [        [        [
        45      n[        US   [        [        45      n[        U R                  R                  =(       d    SUUUS9$ )zd
Constructs a set of header validation flags for use when normalizing
and validating header blocks.
r   F)Ú	is_clientÚ
is_trailerÚis_response_headerÚis_push_promise)r„   r"   r   r!   r   r   r   r   r'   rñ   rz   )r€   r"  r{  r|  r}  s        rN   r  Ú$H2Stream._build_hdr_validation_flagsß  s‡   € ô
  Ø�1‰IœÔ'7Ð8ó
ˆ
ô (Ø�1‰IäÜ Ü-ðó
Ðô %Ø�1‰IÔ,Ô.@ÐAó
ˆô %Ø×(Ñ(×/Ñ/×8°5Ø!Ø1Ø+ñ	
ð 	
rM   c                ó~  • U R                   R                  (       a"  U R                   R                  n[        XU5      nU R                   R                  (       a  [        X5      nUR	                  U5      n[        S[        U5      U R                  =(       d    S5       Vs/ s H  nXgXpR                  =(       d    S-    PM     nn/ n	US   Ul        U	R                  U5        USS  H/  n
[        U R                  5      nX«l        U	R                  U5        M1     U	S   R                  R                  S5        U	$ s  snf )z8
Helper method to build headers or push promise frames.
r   r   NéÿÿÿÿÚEND_HEADERS)rù   r-   Úsplit_outbound_cookiesr0   ÚencodeÚrangerZ  rò   r3  Úappendr
   ry   r  r  )r€   r  r  Úfirst_framer$  Úshould_split_outbound_cookiesÚencoded_headersÚiÚheader_blocksr%  ÚblockÚcfs               rN   r  ÚH2Stream._build_headers_framesú  s*  € ð �;‰;×1×1ð -1¯K©K×,NÑ,NÐ)ä0ØÐ/LóˆGð �;‰;×0×0Ü/ØóˆGð "Ÿ.™.¨Ó1ˆô Ø”3�Ó'¨$×*FÑ*F×*KÈ!ôó
ò�ð ˜a×!=Ñ!=×!BÀÑCÓDñð 	ð 
ð MOˆØ(¨Ñ+ˆÔØ�‰�kÔ"à" 1 2Ó&ˆEÜ" 4§>¡>Ó2ˆBØŒGØ�M‰M˜"Öñ 'ð
 	ˆr‰
×Ñ×Ñ˜]Ô+Øˆùò#
s   Â #D:c                óð   • U R                   R                  (       a  [        X5      nU R                   R                  (       a  [        X5      n[	        U[
        5      (       a  [        X5      n[        U5      $ )z 
When headers have been received from the remote peer, run a processing
pipeline on them to transform them into the appropriate form for
attaching to an event.
)rù   r,   Úvalidate_inbound_headersr/   r„   ÚstrÚ_decode_headersÚlist)r€   r  Úheader_validation_flagsrK  s       rN   rJ  Ú"H2Stream._process_received_headers*  sZ   € ð �;‰;×0×0Ü/ØóˆGð �;‰;×/×/Ü& wÓHˆGä�o¤s×+Ñ+Ü% gÓ?ˆGô �G‹}ÐrM   c                óÆ   • U R                   S:X  a  SU l        gU H  u  p#US:X  d  M   [        US5      U l          g   g! [         a  nSU< 3n[	        U5      UeSnAff = f)zª
Checks the headers for a content-length header and initializes the
_expected_content_length field from it. It's not an error for no
Content-Length header to be present.
s   HEADr   Ns   content-lengthrU   zInvalid content-length header: )ró   rö   rê   r…   r%   )r€   r  ÚnÚvrŽ   rŠ   s         rN   rS  Ú#H2Stream._initialize_content_lengthB  su   € ð ×Ñ 'Ó)Ø,-ˆDÔ)Øã‰DˆAØÐ%Õ%ð6Ü47¸¸2³J�DÔ1ñ
 ò øô "ó 6Ø;¸A¹5ÐA�CÜ'¨Ó,°#Ð5ûð6ús   ©?¿
A Á	AÁA c                ó¶   • U =R                   U-  sl         U R                   nU R                  nUb)  XC:  a  [        XC5      eU(       a  XC:w  a  [        XC5      eggg)ae  
Update the expected content length in response to data being received.
Validates that the appropriate amount of data is sent. Always updates
the received data, but only validates the length against the
content-length header if one was sent.

:param length: The length of the body chunk received.
:param end_stream: If this is the last body chunk received.
N)r÷   rö   r$   )r€   Úlengthr   ÚactualÚexpecteds        rN   rY  ÚH2Stream._track_content_lengthV  sa   € ð 	×#Ò# vÑ-Õ#Ø×,Ñ,ˆØ×0Ñ0ˆàÑØÓ Ü,¨XÓ>Ð>æ˜hÓ0Ü,¨XÓ>Ð>ð 1ˆzð	  rM   c                óŒ   • U R                   R                  U-   nU R                   R                  U5        X R                   l        g)a)  
We changed SETTINGS_INITIAL_WINDOW_SIZE, which means we need to
update the target window size for flow control. For our flow control
strategy, this means we need to do two things: we need to adjust the
current window size, but we also need to set the target maximum window
size to the new value.
N)rõ   Úmax_window_sizerB  )r€   r`  Únew_max_sizes      rN   Ú*_inbound_flow_control_change_from_settingsÚ3H2Stream._inbound_flow_control_change_from_settingsk  s:   € ð ×3Ñ3×CÑCÀeÑKˆØ×$Ñ$×2Ñ2°5Ô9Ø7C×$Ñ$Õ4rM   )
r÷   rø   rö   rõ   rù   rò   rô   ró   rñ   ry   )
ry   rê   rù   r7   rú   rê   rû   rê   rë   rì   )rë   r�  )rë   rê   )rë   Úbool)rë   zStreamClosedBy | None)r  r£  rë   rì   )F)r  úIterable[HeaderWeaklyTyped]r  r4   r   r£  rë   ú9list[HeadersFrame | ContinuationFrame | PushPromiseFrame])r*  rê   r  r¤  r  r4   rë   r¥  )rë   úlist[Frame])FN)r3  zbytes | memoryviewr   r£  r4  z
int | Nonerë   r¦  )r=  Úbytesrë   r¦  )rD  rê   rë   r¦  )r)  rê   r  úIterable[Header]rK  úbool | str | Nonerë   útuple[list[Frame], list[Event]])rO  r¨  rë   rª  )r  r¨  r   r£  rK  r©  rë   rª  )r3  r§  r   r£  r\  rê   rë   rª  )rD  rê   rë   rª  )rë   rì   )rk  r	   rë   rª  )r   )rÉ   zErrorCodes | intrë   r¦  )rk  r   rë   rª  )ru  rê   rë   r¦  )r"  r   rë   r'   )
r  r¨  r  r4   r†  zHeadersFrame | PushPromiseFramer$  r'   rë   r¥  )r  r¨  r“  r'   rK  r©  rë   r¨  )r  r¨  rë   rì   )rš  rê   r   r£  rë   rì   )r`  rê   rë   rì   )%rA   rB   rC   rD   rí   r�   r  Úpropertyr  r
  r  r  r  r&  r,  r/  r7  r   r?  rF  rL  rP  rU  r]  rc  rf  rl  rb  r°   rw  r  r  rJ  rS  rY  r¡  rL   r@   rM   rN   rï   rï   ý  s0  † ñðØðà(ðð '*ðð (+ð	ð 04ô	ô8að ó@ó ð@ð ó
5ó ð
5ð ó>ó ð>ð ó3ó ð3ô1ð( ).ð5Ø9ð5à%ð5ð "&ð5ð 3lõ5ðn
Ø/2ð
à%@ð
ð &-ð
ð 2kô
ô:ð &+Ø+/ðØ*ðà"ðð )ðð 5@õô<	ôôðØ9<ðà.>ðð 7Hðð Mlôô0ð"Ø!1ð"à$(ð"ð *;ð"ð @_ô"ôHô."ôH"ôö6ôôô(
ð6.Ø'7ð.à'.ð.ð ,Kð.ð 5Jð	.ð
 Iô.ð`Ø+;ðà;Pðð 4Eðð JZôô0ô(?÷*
DrM   rï   c              #  ó  #   • U  H�  n[        U[        5      (       d   eUu  p4[        U[        5      (       d   e[        U[        5      (       d   eUR                  U5      nUR                  U5      nUR	                  XV5      v •  Mƒ     g7f)zÍ
Given an iterable of header two-tuples and an encoding, decodes those
headers using that encoding while preserving the type of the header tuple.
This ensures that the use of ``HeaderTuple`` is preserved.
N)r„   r   r§  ÚdecodeÚ	__class__)r  ÚencodingÚheaderÚnameÚvaluer–  r—  s          rN   r‘  r‘  x  s€   é € ó ˆô ˜&¤+×.Ñ.Ð.Ð.à‰ˆÜ˜$¤×&Ñ&Ð&Ð&Ü˜%¤×'Ñ'Ð'Ð'à�K‰K˜Ó!ˆØ�L‰L˜Ó"ˆØ×Ñ˜qÓ$Ô$ò ùs   ‚B	B)r  r¤  r¯  r�  rë   z"Generator[HeaderTuple, None, None])~rí   Ú
__future__r   Úenumr   r   Útypingr   r   Úhpackr   Úhyperframe.framer	   r
   r   r   r   r   r   r   Úerrorsr   r   r"  r   r   r   r   r   r   r   r   r   r   r   r   r    r!   r"   Ú
exceptionsr#   r$   r%   r&   Ú	utilitiesr'   r(   r)   r*   r+   r,   r-   r.   r/   r0   Úwindowsr1   Úcollections.abcr2   r3   Úhpack.hpackr4   Úhpack.structr5   r6   rù   r7   r9   rP   rr   r„  rZ  r	  rH   rJ   rI   ru   rE   r^   r•   rd   rœ   rg   rÍ   rK   r_   r´   rG   re   r·   rF   rn   ro   rp   r™   rb   rh   r¦   r`   rÅ   rf   r°   rm   rè   rŸ   rå   ra   r£   rc   ri   r©   rº   r¾   rk   rß   rl   râ   rÁ   r¬   rÑ   rÙ   rÕ   rÜ   r†   rï   r‘  )Ú_s   0rN   Ú<module>rÀ     s…  ðñõ #ç ß %å ÷ Q÷  Qó  Qç 4÷÷ ÷ ÷ ñ ÷" cÓ b÷÷ ÷ õ #æß3å#ß6å'ô�'ô ô�4ô ô,�Tô ñ $¡C¨Ó$4Ô5Ó6Ò5˜‹uÑ5Ñ6€Ø $€ˆK×ÑÑ Ø-1€ˆK×)Ñ)Ñ *Ø.2€ˆK×*Ñ*Ñ +÷@%ñ @%ðRFà×Ñ�|×0Ñ0Ð1Ø	×	*Ñ	*¨K×,<Ñ,<Ð=ðFð ×Ñ�|×0Ñ0Ð1Ø	×	.Ñ	.°×0@Ñ0@ÐAðFð ×Ñ�|×-Ñ-Ð.Ø	×	3Ñ	3°[×5GÑ5GÐHðFð ×Ñ�|×5Ñ5Ð6Ø	×	4Ñ	4Ø×&Ñ&ð	(ðFð ×Ñ�|×5Ñ5Ð6Ø	×	4Ñ	4Ø×'Ñ'ð	)ðFð ×Ñ�|×<Ñ<Ð=Ø	ˆ{×ÑÐ ðFð  ×Ñ�|×2Ñ2Ð3Ø	×	*Ñ	*¨K×,IÑ,IÐJð#Fð$ ×Ñ�|×2Ñ2Ð3Ø	×	.Ñ	.Ø×*Ñ*ð	,ð'Fð. ×Ñ ×!:Ñ!:Ð;Ø	×	+Ñ	+¨[×-KÑ-KÐLð1Fð2 ×Ñ ×!7Ñ!7Ð8Ø	×	3Ñ	3°[×5GÑ5GÐHð5Fð6 ×Ñ ×!@Ñ!@ÐAØ	ˆ{×)Ñ)Ð*ð9Fð: ×Ñ ×!@Ñ!@ÐAØ	×	,Ñ	,¨k×.HÑ.HÐIð=Fð> ×Ñ ×!=Ñ!=Ð>Ø	×	/Ñ	/°×1CÑ1CÐDðAFðB ×Ñ ×!=Ñ!=Ð>Ø	×	*Ñ	*¨K×,>Ñ,>Ð?ðEFðF ×Ñ ×!FÑ!FÐGØ	×	*Ñ	*¨K×,FÑ,FÐGðIFðJ ×Ñ ×!FÑ!FÐGØ	ˆ{×)Ñ)Ð*ðMFðR × Ñ  ,×";Ñ";Ð<Ø	×	/Ñ	/Ø×)Ñ)ð	+ñUFðX × Ñ  ,×"8Ñ"8Ð9Ø	×	3Ñ	3°[×5GÑ5GÐHð[Fð\ × Ñ  ,×"AÑ"AÐBØ	ˆ{×*Ñ*Ð+ð_Fð` × Ñ  ,×"AÑ"AÐBØ	×	,Ñ	,¨k×.IÑ.IÐJðcFðd × Ñ  ,×">Ñ">Ð?Ø	×	/Ñ	/°×1CÑ1CÐDðgFðh × Ñ  ,×">Ñ">Ð?Ø	×	*Ñ	*¨K×,>Ñ,>Ð?ðkFðl × Ñ  ,×"GÑ"GÐHØ	×	*Ñ	*¨K×,GÑ,GÐHðoFðt ×Ñ�|×0Ñ0Ð1Ø	×	+Ñ	+¨[×-=Ñ-=Ð>ðwFðx ×Ñ�|×0Ñ0Ð1Ø	×	/Ñ	/°×1AÑ1AÐBð{Fð| ×Ñ�|×-Ñ-Ð.Ø	ˆ{×ÑÐ ðFð@ ×Ñ�|×-Ñ-Ð.Ø	×	+Ñ	+¨[×-=Ñ-=Ð>ðCFðD ×Ñ�|×3Ñ3Ð4Ø	ˆ{×,Ñ,Ð-ðGFðH ×Ñ�|×3Ñ3Ð4Ø	×	0Ñ	0Ø	×	'Ñ	'ð	)ðKFðN ×Ñ�|×6Ñ6Ð7Ø	ˆ{×ÑÐ ðQFðR ×Ñ�|×6Ñ6Ð7Ø	×	,Ñ	,¨k×.>Ñ.>Ð?ðUFðV ×Ñ�|×3Ñ3Ð4Ø	×	/Ñ	/°×1CÑ1CÐDðYFðZ ×Ñ�|×3Ñ3Ð4Ø	×	*Ñ	*¨K×,>Ñ,>Ð?ð]Fð^ ×Ñ�|×5Ñ5Ð6Ø	×	/Ñ	/°×1AÑ1AÐBòaFðb ×Ñ�|×5Ñ5Ð6Ø	×	/Ñ	/°×1AÑ1AÐBðeFðf ×Ñ�|×>Ñ>Ð?Ø	×	9Ñ	9¸;×;KÑ;KÐLðiFðj ×Ñ�|×>Ñ>Ð?Ø	×	9Ñ	9¸;×;KÑ;KÐLðmFðn ×Ñ�|×<Ñ<Ð=Ø	×	*Ñ	*¨K×,<Ñ,<Ð=ðqFðr ×Ñ�|×<Ñ<Ð=Ø	×	*Ñ	*¨K×,<Ñ,<Ð=ðuFðz ×#Ñ# \×%>Ñ%>Ð?Ø	×	+Ñ	+¨[×-KÑ-KÐLð}Fð~ ×#Ñ# \×%>Ñ%>Ð?Ø	×	3Ñ	3°[×5GÑ5GÐHðAFðB ×#Ñ# \×%;Ñ%;Ð<Ø	ˆ{×-Ñ-Ð.ðEFðF ×#Ñ# \×%;Ñ%;Ð<Ø	×	3Ñ	3°[×5GÑ5GÐHðIFðJ ×#Ñ# \×%AÑ%AÐBØ	×	-Ñ	-¨{×/AÑ/AÐBðMFðN ×#Ñ# \×%DÑ%DÐEØ	ˆ{×-Ñ-Ð.ðQFðR ×#Ñ# \×%DÑ%DÐEØ	×	,Ñ	,¨k×.LÑ.LÐMðUFðV ×#Ñ# \×%AÑ%AÐBØ	×	/Ñ	/°×1CÑ1CÐDðYFðZ ×#Ñ# \×%AÑ%AÐBØ	×	*Ñ	*¨K×,>Ñ,>Ð?ð]Fð^ ×#Ñ# \×%CÑ%CÐDØ	×	/Ñ	/Ø×*Ñ*ð	,ðaFðd ×#Ñ# \×%CÑ%CÐDØ	×	3Ñ	3°[×5GÑ5GÐHðgFðh ×#Ñ# \×%LÑ%LÐMØ	×	9Ñ	9Ø×*Ñ*ð	,òkFðn ×#Ñ# \×%JÑ%JÐKØ	×	*Ñ	*¨K×,JÑ,JÐKðqFðr ×#Ñ# \×%JÑ%JÐKØ	×	*Ñ	*¨K×,JÑ,JÐKðuFðz ×"Ñ" L×$=Ñ$=Ð>Ø	×	/Ñ	/Ø×)Ñ)ð	+ð}Fð@ ×"Ñ" L×$:Ñ$:Ð;Ø	×	+Ñ	+¨[×-JÑ-JÐKðCFðD ×"Ñ" L×$@Ñ$@ÐAØ	×	*Ñ	*¨K×,>Ñ,>Ð?ðGFðH ×"Ñ" L×$CÑ$CÐDØ	ˆ{×,Ñ,Ð-ðKFðL ×"Ñ" L×$CÑ$CÐDØ	×	,Ñ	,¨k×.KÑ.KÐLðOFðP ×"Ñ" L×$@Ñ$@ÐAØ	×	/Ñ	/°×1CÑ1CÐDðSFðT ×"Ñ" L×$@Ñ$@ÐAØ	×	*Ñ	*¨K×,>Ñ,>Ð?ðWFðX ×"Ñ" L×$BÑ$BÐCØ	×	/Ñ	/Ø×)Ñ)ð	+ð[Fð^ ×"Ñ" L×$KÑ$KÐLØ	×	9Ñ	9Ø×)Ñ)ð	+ðaFðd ×"Ñ" L×$IÑ$IÐJØ	×	*Ñ	*¨K×,IÑ,IÐJðgFðh ×"Ñ" L×$IÑ$IÐJØ	×	*Ñ	*¨K×,IÑ,IÐJðkFðp ×Ñ˜×5Ñ5Ð6Ø	ˆ{×!Ñ!Ð"ðsFðt ×Ñ˜×>Ñ>Ð?Ø	ˆ{×!Ñ!Ð"ðwFðJ ×Ñ˜×2Ñ2Ð3Ø	×	3Ñ	3°[×5GÑ5GÐHðMFðN ×Ñ˜×/Ñ/Ð0Ø	×	3Ñ	3°[×5GÑ5GÐHñQFð\ ×Ñ˜×8Ñ8Ð9Ø	ˆ{×!Ñ!Ð"Ø×Ñ˜×5Ñ5Ð6Ø	ˆ{×!Ñ!Ð"ð
 ×Ñ˜×7Ñ7Ð8Ø	×	8Ñ	8¸+×:LÑ:LÐMð ×Ñ˜×2Ñ2Ð3Ø	×	3Ñ	3°[×5GÑ5GÐHØ×Ñ˜×7Ñ7Ð8Ø	×	8Ñ	8¸+×:LÑ:LÐMØ×Ñ˜×5Ñ5Ð6Ø	×	3Ñ	3°[×5GÑ5GÐHØ×Ñ˜×/Ñ/Ð0Ø	×	3Ñ	3°[×5GÑ5GÐHØ×Ñ˜×8Ñ8Ð9Ø	×	3Ñ	3°[×5GÑ5GÐHØ×Ñ˜×5Ñ5Ð6Ø	×	3Ñ	3°[×5GÑ5GÐHñKF€÷Rx	Dñ x	Dõv%ùòg( 7s   Ã{	