Struct ChunkReassembler 

pub struct ChunkReassembler { /* private fields */ }

Reassembles chunks into complete messages

Implementations

impl ChunkReassembler

pub fn new() -> Self

Create a new reassembler

pub fn process( &mut self, chunk: SyncChunk, current_time_ms: u64, ) -> Option<Vec<u8>>

Process a received chunk

Returns the complete message if all chunks received

pub fn cleanup(&mut self, current_time_ms: u64)

Clean up timed-out partial messages

pub fn pending_count(&self) -> usize

Get number of messages being assembled

Trait Implementations

impl Debug for ChunkReassembler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ChunkReassembler

fn default() -> Self

Returns the “default value” for a type.