Struct ReassemblyBuffer 

pub struct ReassemblyBuffer { /* private fields */ }

Per-peer reassembly buffer for NDNLPv2 fragments.

Tracks incomplete reassemblies keyed by sequence number. When all fragments of a packet arrive, process() returns the reassembled packet.

Implementations

impl ReassemblyBuffer

pub fn new(timeout: Duration) -> Self

pub fn process( &mut self, seq: u64, frag_index: u64, frag_count: u64, fragment: Bytes, ) -> Option<Bytes>

Feed a decoded LpPacket fragment.

Returns Some(complete_packet) when all fragments of the original packet have been received. Returns None if fragments are still missing or if the packet has no fragmentation fields.

pub fn purge_expired(&mut self)

Drop incomplete reassemblies older than the configured timeout.

pub fn pending_count(&self) -> usize

Number of in-progress reassemblies.

Trait Implementations

impl Default for ReassemblyBuffer

fn default() -> Self

Returns the “default value” for a type.