Struct BufferedReassembler 

pub struct BufferedReassembler { /* private fields */ }

Available on crate feature reassembler only.

Built-in: drop OOO segments, accumulate in-order bytes into a Vec<u8> per direction. Drain via take.

Sync, no channel dep. Users who want a channel send via std::sync::mpsc themselves, or use netring’s TokioChannelReassembler for tokio integration.

Optionally bounded via with_max_buffer. When the cap is reached the OverflowPolicy decides whether to rotate bytes out (sliding window) or poison the reassembler so the driver can tear the flow down on the next tick.

Implementations

impl BufferedReassembler

pub fn new() -> Self

pub fn with_max_buffer(self, max_bytes: usize) -> Self

Set a maximum in-flight buffer size in bytes. When new in-order segments would push buffered_len() past this cap, the configured OverflowPolicy kicks in.

Default policy is OverflowPolicy::SlidingWindow. Pair with with_overflow_policy to switch to OverflowPolicy::DropFlow for framed binary protocols.

pub fn with_overflow_policy(self, policy: OverflowPolicy) -> Self

Override the overflow policy. Has no effect unless with_max_buffer is also called.

pub fn take(&mut self) -> Vec<u8>

Drain accumulated in-order bytes, leaving the buffer empty. expected_seq is preserved so subsequent in-order segments keep accumulating.

pub fn dropped_segments(&self) -> u64

Number of segments dropped because they were out of order.

pub fn bytes_dropped_oversize(&self) -> u64

Number of payload bytes dropped because the per-side buffer cap was exceeded. Zero when no cap is set or when the cap has not yet been hit.

pub fn buffered_len(&self) -> usize

Bytes currently buffered (not yet drained).

pub fn is_poisoned(&self) -> bool

True after an OverflowPolicy::DropFlow overflow. The driver checks this once per tick; true triggers an Ended { reason: BufferOverflow } event for the flow.

Trait Implementations

impl Debug for BufferedReassembler

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

Formats the value using the given formatter.

impl Default for BufferedReassembler

fn default() -> BufferedReassembler

Returns the “default value” for a type.

impl Reassembler for BufferedReassembler

fn segment(&mut self, seq: u32, payload: &[u8])

New segment arrived in this direction.

fn dropped_segments(&self) -> u64

Number of TCP segments dropped because they arrived out of order for this side. Default: 0.

fn bytes_dropped_oversize(&self) -> u64

Number of payload bytes dropped because the per-side buffer cap was exceeded. Default: 0.

fn is_poisoned(&self) -> bool

True after a fatal-style overflow (e.g. crate::OverflowPolicy::DropFlow). The driver checks this once per tick; true triggers synthesis of an Ended { reason: BufferOverflow } event for the flow. Default: false.

fn fin(&mut self)

FIN observed in this direction. Default: no-op.

fn rst(&mut self)

RST observed in this direction (or session aborted). Default: no-op.