+ j*dRt^RIHtHt^RIHt^RIHt!RR]4t!RR4t RR.t R#) zd HTTP/2 stream state management. Each HTTP/2 stream represents a single request/response exchange. )Enumauto)BytesIO)HTTP2StreamErrorc|]tRt^tRt]!4t]!4t]!4t]!4t ]!4t ]!4t ]!4t Rt R#) StreamStatez8HTTP/2 stream states as defined in RFC 7540 Section 5.1.N)__name__ __module__ __qualname____firstlineno____doc__rIDLERESERVED_LOCALRESERVED_REMOTEOPENHALF_CLOSED_LOCALHALF_CLOSED_REMOTECLOSED__static_attributes__rJ/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/http2/stream.pyrrs8B 6DVNfO 6D VFrrca]tRt^toRtRt]R4t]R4t]R4t ]R4t RRlt RRlt R t RR ltRR ltR tRR ltRtRRltRtRtRtRtRtRtRtRtVtR#) HTTP2StreamzRepresents a single HTTP/2 stream. Manages stream state, headers, and body data for a single request/response exchange within an HTTP/2 connection. c >WnW n\PVn.Vn\ 4VnRVnRVn RVn RVn VPVn RVnRVn^Vn^VnRVn.VnRVnRVnR#)zInitialize an HTTP/2 stream. Args: stream_id: The unique stream identifier (odd for client-initiated) connection: The parent HTTP2ServerConnection FN) stream_id connectionrrstaterequest_headersr request_bodyrequest_completeresponse_startedresponse_headers_sentresponse_completeinitial_window_size window_sizetrailersresponse_trailerspriority_weightpriority_depends_onpriority_exclusive _body_chunks _body_event_body_complete)selfrrs&&&r__init__HTTP2Stream.__init__%s#$!%%  "#I %!&%*"!&&99 "& "#$ "'#rc .VP^,^8H#)z;Check if this is a client-initiated stream (odd stream ID).rr.s&ris_client_streamHTTP2Stream.is_client_streamO~~!Q&&rc .VP^,^8H#)zrrrrAr!r"_half_close_localr#rDs&&&r send_headersHTTP2Stream.send_headerssb}}}"/ /@A  !%%)"   " " $%)D " rc VP'g.\VPRVPP 24hV'dVP 4RVnR#R#)zMark data as sent. Args: data: Bytes to send end_stream: True if this completes the response Raises: HTTP2StreamError: If data cannot be sent in current state zCannot send data in state TN)r>rrrrArVr#rMs&&&r send_dataHTTP2Stream.send_datasR}}}",TZZ__,=>    " " $%)D " rc VP'g.\VPRVPP 24hWnVP 4RVnR#)zMark trailers as sent and close the stream. Args: trailers: List of (name, value) trailer tuples Raises: HTTP2StreamError: If trailers cannot be sent in current state zCannot send trailers in state TN)r>rrrrAr'rVr#rRs&&r send_trailersHTTP2Stream.send_trailerssP}}}"00AB "*  !%rc L\PVnRVnRVnR#)z^Reset this stream with RST_STREAM. Args: error_code: HTTP/2 error code (default: CANCEL) TNrrrr#r )r. error_codes&&rresetHTTP2Stream.resets! !'' !% $rc L\PVnRVnRVnR#)zClose this stream normally.TNr`r3s&rcloseHTTP2Stream.closes '' !% $rNc pVe\^\RV44VnVeW nVe W0nR#R#)zUpdate stream priority from PRIORITY frame. Args: weight: Priority weight (1-256), higher = more resources depends_on: Stream ID this stream depends on exclusive: Whether this is an exclusive dependency N)maxminr(r)r*)r.weight depends_on exclusives&&&&rupdate_priorityHTTP2Stream.update_prioritys=  #&q#c6*:#;D  !'1 $  &/ # !rc 4VP\P8Xd\PVnR#VP\P8Xd\P VnR#\ VPRVPP 24h)z(Transition to half-closed (local) state.z!Cannot half-close local in state N) rrrrrrrrrAr3s&rrVHTTP2Stream._half_close_local sg ::)) )$66DJ ZZ;99 9$++DJ"3DJJOO3DE rc 4VP\P8Xd\PVnR#VP\P8Xd\P VnR#\ VPRVPP 24h)z)Transition to half-closed (remote) state.z"Cannot half-close remote in state N) rrrrrrrrrAr3s&rrCHTTP2Stream._half_close_remotesg ::)) )$77DJ ZZ;88 8$++DJ"4TZZ__4EF rc 6VPP4#)zJGet the complete request body. Returns: bytes: The request body data )rgetvaluer3s&rget_request_bodyHTTP2Stream.get_request_body%s   ))++rc "^RIpVPfTVP4VnVP'gVP'dVPP 4VP'dVPP ^4#VP'dR#VPP4VPP4GRjxL KL5i)z~Read next body chunk asynchronously for streaming. Returns: bytes: Next chunk of body data, or None if body is complete. N) asyncior,Eventr+r-rKpopclearwait)r.rys& rread_body_chunkHTTP2Stream.read_body_chunk-s     #&}}D    D$7$7$7  $$&   ((,,Q//"""    " " $""'') ) )s(9C*C*,C*;,C*(9C*!C("C*c n/pVPF"wr#VPR4'gKW1V&K$ V#)zExtract HTTP/2 pseudo-headers from request headers. Returns: dict: Mapping of pseudo-header names to values (e.g., {':method': 'GET', ':path': '/'}) :r startswith)r.pseudorAvalues& rget_pseudo_headersHTTP2Stream.get_pseudo_headersJs8//KDs##$t 0 rc VPUUu.uF!wrVPR4'dKW3NK# upp#uuppi)ztGet regular (non-pseudo) headers from request. Returns: list: List of (name, value) tuples for regular headers rr)r.rArs& rget_regular_headersHTTP2Stream.get_regular_headersWsA $33 3 ??3' TM3   s;;c RVP RVPP RVP RVP R2 #)z)rrrAr r#r3s&r__repr__HTTP2Stream.__repr__csOt~~./ZZ__%& 1123!334A 7 r)r+r-r,rr)r*r(rr rr#r"r!r'rrr&r%)F))NNN)r r r r r r/propertyr4r8r;r>rGrOrSrWrZr]rbrernrVrCrvr~rrrr__classdictcell__) __classdict__s@rrrs ($T''''    )0'@% *.*(&$%% 0  ,*:     rrN) r enumrriorerrorsrrr__all__rrrrs:  $ $ K K \ - (r