pub struct Inflights { /* private fields */ }
Expand description
A buffer of inflight messages.
Implementations§
source§impl Inflights
impl Inflights
sourcepub fn set_cap(&mut self, incoming_cap: usize)
pub fn set_cap(&mut self, incoming_cap: usize)
Adjust inflight buffer capacity. Set it to 0
will disable the progress.
sourcepub fn free_to(&mut self, to: u64)
pub fn free_to(&mut self, to: u64)
Frees the inflights smaller or equal to the given to
flight.
sourcepub fn free_first_one(&mut self)
pub fn free_first_one(&mut self)
Frees the first buffer entry.
sourcepub fn maybe_free_buffer(&mut self)
pub fn maybe_free_buffer(&mut self)
Free unused memory