Struct FragmentAssembler 

pub struct FragmentAssembler { /* private fields */ }

Implementations

impl FragmentAssembler

pub fn new() -> Self

pub fn process_chunk(&mut self, frame: CryptoFrame) -> Option<Vec<u8>>

Process a new CryptoFrame chunk. Returns Some(reassembled_packet) if this chunk completes the packet.

pub fn len(&self) -> usize

Number of in-flight (incomplete) assemblies currently tracked.

pub fn is_empty(&self) -> bool

Whether there are no in-flight assemblies.

pub fn get_nacks_and_evict(&mut self) -> Vec<([u8; 16], u32, Vec<u16>)>

Check for timed out assemblies and return a list of missing chunks (NACK) Also evicts purely dead assemblies (> 5000ms)

Trait Implementations

impl Default for FragmentAssembler

fn default() -> Self

Returns the “default value” for a type.