Struct Reassembler 

pub struct Reassembler { /* private fields */ }

Implementations

impl Reassembler

pub fn new() -> Self

Holds up to DEFAULT_MAX_PENDING incomplete messages.

pub fn with_max_pending(max: usize) -> Self

Holds up to max incomplete messages (at least 1).

pub fn max_pending(&self) -> usize

The cap on incomplete messages.

pub fn push( &mut self, key: Key, seq: u8, fragment: Fragment, now: u64, ) -> Option<Message>

Add part seq (1-based) of key. Returns the message once every part is in. A repeated seq replaces the earlier copy; seq outside 1..=total is ignored. A part of a new message when Self::max_pending are held evicts the oldest.

pub fn push_tpdu(&mut self, tpdu: &Tpdu, now: u64) -> Option<Message>

Feed a decoded TPDU. Messages without a valid concatenation IE complete at once.

pub fn expire_before(&mut self, cutoff: u64) -> Vec<Key>

Drop incomplete messages whose newest part arrived before cutoff; returns their keys.

pub fn pending(&self) -> usize

Number of incomplete messages held.

Trait Implementations

impl Default for Reassembler

fn default() -> Self

Returns the “default value” for a type.