Struct MultipathReceiver 

pub struct MultipathReceiver { /* private fields */ }

A reordering buffer for packets received on multiple paths.

Packets may arrive out of order when using multipath — this buffer holds them and releases them in sequence order.

Implementations

impl MultipathReceiver

pub fn new() -> Self

Create a new receiver with default buffer size (256).

pub fn with_buffer_size(max_buffer: usize) -> Self

Create a receiver with a custom reorder buffer size.

pub fn add( &mut self, seq: u64, path_id: &str, data: Vec<u8>, ) -> Option<(String, Vec<u8>)>

Add a received packet.

Returns Some((path_id, data)) if this completes an in-order sequence, or None if the packet is buffered waiting for earlier packets.

Duplicate packets (same seq already seen) are silently dropped.

pub fn drain_ordered(&mut self) -> Vec<(u64, String, Vec<u8>)>

Try to drain buffered packets that are now in order.

Call after add() returns Some(...) to flush any buffered packets. Returns packets in sequence order.

pub fn next_seq(&self) -> u64

Returns the next expected sequence number.

pub fn pending_count(&self) -> usize

Returns the number of packets currently buffered.

pub fn clear(&mut self)

Clear all buffered packets.

pub fn total_received(&self) -> u64

Total packets received (including duplicates and out-of-order).

pub fn total_delivered(&self) -> u64

Total packets delivered in order.

pub fn total_duplicates(&self) -> u64

Total duplicate packets dropped.

Trait Implementations

impl Default for MultipathReceiver

fn default() -> Self

Returns the “default value” for a type.