Struct StreamPressure 

pub struct StreamPressure { /* private fields */ }

Tracks protocol-level pressure counters for one application stream.

Implementations

impl StreamPressure

pub fn new(max_in_flight: u32) -> Result<Self, ProtocolError>

Create pressure tracking for a subscription capacity declaration.

Errors

Returns ProtocolError::CodecError when max_in_flight is zero.

pub const fn outstanding_count(&self) -> u32

Return messages delivered on this stream but not yet accepted.

pub const fn max_in_flight(&self) -> u32

Return consumer-declared in-flight capacity from the Subscribe frame.

pub const fn state(&self) -> PressureState

Return the current pressure state for the stream.

pub fn record_delivery( &mut self, buffer_capacity: u32, ) -> Result<PressureState, ProtocolError>

Record delivery of one message and recompute state using caller capacity.

buffer_capacity is supplied by the bus/subscription layer; the protocol state machine does not define or hardcode that threshold.

Errors

Returns ProtocolError::CodecError when the outstanding counter or capacity threshold overflows.

pub fn record_accept( &mut self, buffer_capacity: u32, ) -> Result<PressureState, ProtocolError>

Record acceptance of one outstanding message and recompute state using caller capacity.

buffer_capacity is supplied by the bus/subscription layer; the protocol state machine does not define or hardcode that threshold.

Errors

Returns ProtocolError::CodecError when no messages are outstanding or the capacity threshold overflows.

Trait Implementations

impl Clone for StreamPressure

fn clone(&self) -> StreamPressure

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamPressure

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

Formats the value using the given formatter.

impl Eq for StreamPressure

impl PartialEq for StreamPressure

fn eq(&self, other: &StreamPressure) -> 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 StreamPressure