Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

A simple pending-count-based backpressure controller.

try_submit returns true only when the number of in-flight items is strictly below max_pending. complete_one decrements the counter.

Implementations

impl BackpressureController

pub fn new(max_pending: usize) -> Self

Create a controller with the given maximum pending count.

pub fn try_submit(&self) -> bool

Attempt to submit a new item.

Returns true and increments the pending counter if the limit has not been reached. Returns false without modifying state if the queue is full.

pub fn complete_one(&self)

Decrement the pending counter when an item completes.

Will not decrement below zero (saturating).

pub fn pending_count(&self) -> usize

Current number of in-flight items.

pub fn max_pending(&self) -> usize

Maximum allowed pending count.

Trait Implementations

impl Debug for BackpressureController

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

Formats the value using the given formatter.