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

Trait Implementations

impl Default for Reassembler

fn default() -> Reassembler

Returns the “default value” for a type.