Struct Reassembler 

pub struct Reassembler { /* private fields */ }

A stateful reassembler that tracks fragmented messages from multiple clients.

Implementations

impl Reassembler

pub fn new() -> Self

Creates a new reassembler with a default timeout of 5 seconds.

pub fn with_timeout(self, timeout: Duration) -> Self

Sets a custom timeout for message reassembly.

pub fn add( &mut self, client_id: ClientId, event: FragmentedEvent, ) -> Option<Vec<u8>>

Adds a fragment to the reassembler.

Returns the full reassembled message if this was the last fragment, otherwise returns None.

pub fn cleanup(&mut self)

Discards messages that have haven’t been completed within the timeout.

Trait Implementations

impl Clone for Reassembler

fn clone(&self) -> Reassembler

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Reassembler

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

Formats the value using the given formatter.

impl Default for Reassembler

fn default() -> Reassembler

Returns the “default value” for a type.