Struct Inflights 

pub struct Inflights { /* private fields */ }

A buffer of inflight messages.

Implementations

impl Inflights

pub fn new(cap: usize) -> Inflights

Creates a new buffer for inflight messages.

pub fn set_cap(&mut self, incoming_cap: usize)

Adjust inflight buffer capacity. Set it to 0 will disable the progress.

pub fn full(&self) -> bool

Returns true if the inflights is full.

pub fn add(&mut self, inflight: u64)

Adds an inflight into inflights

pub fn free_to(&mut self, to: u64)

Frees the inflights smaller or equal to the given to flight.

pub fn free_first_one(&mut self)

Frees the first buffer entry.

pub fn reset(&mut self)

Frees all inflights.

pub fn maybe_free_buffer(&mut self)

Free unused memory

Trait Implementations

impl Clone for Inflights

fn clone(&self) -> Inflights

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Inflights

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

Formats the value using the given formatter.

impl PartialEq for Inflights

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

impl StructuralPartialEq for Inflights