Enum BackpressureSignal 

pub enum BackpressureSignal {
    Ok,
    SlowDown,
    Pause,
}

Signal indicating client’s receive buffer state for backpressure control

Clients send backpressure signals to inform the server about their processing capacity. The server uses these signals to throttle or pause frame transmission.

Variants

Ok

Client is ready for more data, no throttling needed

SlowDown

Client’s buffer is filling up, server should slow down transmission

Pause

Client’s buffer is full, server must pause transmission

Implementations

impl BackpressureSignal

pub fn should_pause(&self) -> bool

Returns true if this signal indicates the server should pause

pub fn should_throttle(&self) -> bool

Returns true if this signal indicates the server should slow down

pub fn suggested_delay_ms(&self) -> u64

Get suggested delay in milliseconds based on backpressure signal

Trait Implementations

impl Clone for BackpressureSignal

fn clone(&self) -> BackpressureSignal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressureSignal

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

Formats the value using the given formatter.

impl Default for BackpressureSignal

fn default() -> BackpressureSignal

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BackpressureSignal

fn deserialize<__D>( __deserializer: __D, ) -> Result<BackpressureSignal, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for BackpressureSignal

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

Formats the value using the given formatter.

impl PartialEq for BackpressureSignal

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

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for BackpressureSignal

impl Eq for BackpressureSignal

impl StructuralPartialEq for BackpressureSignal