Struct Reassembler 

pub struct Reassembler { /* private fields */ }

Receiver-side: collect chunks for the same message_id until the full set arrives, then return the reassembled payload.

Implementations

impl Reassembler

pub fn new() -> Self

pub fn push(&mut self, chunk: Chunk) -> Result<Option<Vec<u8>>, ChunkError>

Feed one chunk. Returns Some(payload) when the message is complete, None while still waiting for siblings.

pub fn pending_message_count(&self) -> usize

pub fn gc_expired(&mut self, older_than: Duration) -> usize

Discard partial reassemblies older than older_than. Returns the count of entries swept. Call on a low-frequency tick to keep the reassembler bounded against peers that fall silent mid-message.

Trait Implementations

impl Default for Reassembler

fn default() -> Reassembler

Returns the “default value” for a type.