Struct StreamWindow 

pub struct StreamWindow {
    pub stream_id: u64,
    pub total_consumed: u64,
    pub ack_seq: u64,
}

Receiver → sender credit grant. Authoritative: total_consumed is the receiver’s cumulative bytes-consumed count on the named stream since it was opened. The sender uses this to recompute tx_credit_remaining = tx_window - (tx_bytes_sent - total_consumed), making the mechanism self-healing against lost grants.

Consumer-side validation

The codec accepts any total_consumed: u64. Pre-fix the doc- comment’s “self-healing” framing implied no further validation was needed, but the formula tx_credit_remaining = tx_window - (tx_bytes_sent - total_consumed) underflows if a malformed or hostile peer sends total_consumed > tx_bytes_sent. The consumer MUST clamp total_consumed to its local tx_bytes_sent watermark before applying. StreamState::apply_authoritative_grant (adapter/net/session.rs:1153-1154) does this today; any future consumer of this codec must do the same. The codec layer cannot do the clamp itself because it doesn’t know the sender’s local state.

Fields

stream_id: u64

Stream the grant applies to.

total_consumed: u64

Receiver’s cumulative consumed-byte count on this stream.

Consumers MUST clamp this to the local tx_bytes_sent watermark before deriving credit.

ack_seq: u64

Receiver’s cumulative reliable ack — the lowest sequence not yet contiguously received (next_expected). The sender prunes its retransmit window of everything below this (H-9). 0 for non-reliable receive streams (nothing to prune).

Implementations

impl StreamWindow

pub fn encode(&self) -> [u8; 24]

Encode to a fixed 16-byte buffer.

pub fn decode(data: &[u8]) -> Result<Self, StreamWindowCodecError>

Decode a fixed-size message. Returns an error on truncated or oversize input.

Trait Implementations

impl Clone for StreamWindow

fn clone(&self) -> StreamWindow

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for StreamWindow

impl Debug for StreamWindow

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

Formats the value using the given formatter.

impl Eq for StreamWindow

impl PartialEq for StreamWindow

fn eq(&self, other: &StreamWindow) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for StreamWindow