Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

Backpressure control for streams.

Implementations

impl BackpressureController

pub fn new(max_buffer_size: usize) -> Self

Create a new backpressure controller.

pub fn update(&mut self, buffer_size: usize) -> BackpressureState

Update buffer size and return new state.

pub fn state(&self) -> BackpressureState

Get current state.

pub fn should_throttle(&self) -> bool

Check if should throttle.

pub fn should_drop(&self) -> bool

Check if should drop messages.