Struct UtilitySessionFlowControl 

pub struct UtilitySessionFlowControl { /* private fields */ }

Producer-side credit and sequence state for one Utility session.

Implementations

impl UtilitySessionFlowControl

pub const fn new( initial_credits: u32, max_event_bytes: usize, ) -> Result<UtilitySessionFlowControl, UtilitySessionFlowError>

Creates a session with an explicit credit window and event-size limit.

pub fn emit( &mut self, kind: u32, payload: impl Into<Vec<u8>>, ) -> Result<UtilitySessionEvent, UtilitySessionFlowError>

Reserves one credit and creates the next ordered event.

pub fn acknowledge( &mut self, committed_sequence: u64, credits: u32, ) -> Result<(), UtilitySessionFlowError>

Acknowledges durably committed events and replenishes producer credits.

Credits cannot exceed the number of newly acknowledged events. This prevents a consumer from accidentally expanding the negotiated window.

pub const fn close(&mut self) -> u64

Closes the producer and returns the final emitted sequence.

pub const fn available_credits(&self) -> u32

Returns currently available event credits.

pub const fn committed_sequence(&self) -> u64

Returns the highest sequence acknowledged as durably committed.

Trait Implementations

impl Debug for UtilitySessionFlowControl

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

Formats the value using the given formatter.