Struct Reassembler 

pub struct Reassembler { /* private fields */ }

Tracks incoming fragments and reassembles complete messages.

Each fragment_id is tracked independently. Once all fragments for a message arrive, Reassembler::add returns Some(data).

Old incomplete messages are evicted when Reassembler::cleanup is called.

Implementations

impl Reassembler

pub fn new() -> Self

Create a new reassembler with a default max of 256 pending messages.

pub fn with_max_pending(max_pending: usize) -> Self

Create a new reassembler with a custom max pending messages limit.

pub fn add(&mut self, fragment: Fragment) -> Option<Vec<u8>>

Add a fragment. Returns Some(data) when all fragments are received.

Returns None if more fragments are still expected. Silently drops duplicate fragments.

pub fn pending_count(&self) -> usize

Returns the number of incomplete messages currently being tracked.

pub fn cleanup(&mut self)

Remove all pending incomplete messages.

Trait Implementations

impl Default for Reassembler

fn default() -> Self

Returns the “default value” for a type.