Struct Reassembler 

pub struct Reassembler { /* private fields */ }

Reassembles fragmented mesh payloads.

Call Reassembler::insert for each received FragmentFrame. When the last required fragment arrives the complete packet is returned. Call Reassembler::expire_stale periodically (e.g. once per second) to free memory for timed-out incomplete buffers.

Implementations

impl Reassembler

pub fn new() -> Self

Create a reassembler with the default 10-second timeout.

pub fn with_timeout(timeout: Duration) -> Self

Create a reassembler with a custom timeout (useful in tests).

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

Feed a FragmentFrame to the reassembler.

Returns Some(packet) when the complete packet is ready, otherwise None. Duplicate fragments are silently ignored.

pub fn expire_stale(&mut self)

Discard all reassembly buffers that have been waiting longer than the configured timeout.

pub fn buffer_count(&self) -> usize

Number of in-progress reassembly buffers currently held.

Trait Implementations

impl Default for Reassembler

fn default() -> Self

Returns the “default value” for a type.