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 ingest( &mut self, client_id: ClientId, event: FragmentedEvent, ) -> Option<Vec<u8>>

Ingests a fragment into the reassembler.

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

pub fn prune(&mut self)

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

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

👎Deprecated since 0.2.4:

Renamed to ingest() for consistency

DEPRECATED: Use ingest() instead.

pub fn cleanup(&mut self)

👎Deprecated since 0.2.4:

Renamed to prune() for consistency

DEPRECATED: Use prune() instead.

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.