Struct H2FlowControl 

pub struct H2FlowControl { /* private fields */ }

Tracks HTTP/2 flow-control receive windows at connection and stream level.

The receiver (server) decrements windows when DATA frames arrive and sends WINDOW_UPDATE frames when enough data has been consumed to keep the sender from stalling.

Implementations

impl H2FlowControl

pub fn new() -> Self

Create a new flow-control tracker with the RFC default initial window.

pub fn set_initial_window_size(&mut self, size: u32)

Update the initial window size (from SETTINGS_INITIAL_WINDOW_SIZE). This only affects future streams; the connection-level window is independent of this setting per RFC 7540 §6.9.2.

pub fn data_received_connection(&mut self, n: u32) -> u32

Record that n bytes of DATA payload were received on the connection. Returns the connection-level WINDOW_UPDATE increment to send, or 0 if no update is needed yet.

pub fn stream_window_update(&self, total_received: u32) -> u32

Compute a stream-level WINDOW_UPDATE increment after total_received bytes have been received for a stream. Returns the increment to send, or 0 if no update is needed.

For simplicity, the server sends a stream-level WINDOW_UPDATE when the consumed bytes exceed the threshold. Since streams are short-lived request bodies, we track this per-call rather than storing per-stream state.

pub fn initial_window_size(&self) -> u32

The initial window size for new streams.

pub fn set_peer_initial_window_size(&mut self, size: u32)

Set the peer’s initial window size (from peer’s SETTINGS_INITIAL_WINDOW_SIZE). This determines the send window for new streams.

pub fn peer_initial_window_size(&self) -> u32

The peer’s initial window size for new streams (send window).

pub fn send_conn_window(&self) -> i64

The maximum number of bytes we can send on the connection right now.

pub fn peer_window_update_connection(&mut self, increment: u32)

Record a WINDOW_UPDATE received from the peer for the connection (stream_id == 0). Increases the connection-level send window.

pub fn consume_send_conn_window(&mut self, n: u32)

Consume n bytes of the connection-level send window.

Trait Implementations

impl Debug for H2FlowControl

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for H2FlowControl

fn default() -> Self

Returns the “default value” for a type.