Struct FastReceiver 

pub struct FastReceiver<const WIN: usize, const MTU: usize, const REASM: usize, const TOTAL: usize> { /* private fields */ }

Fastest backend — O(1) insert and O(1) delivery.

Use when CPU budget is tight and you can afford the extra memory: both buffering an out-of-order segment and delivering a run of consecutive segments are constant-time per packet.

Stores out-of-order segments in WIN fixed MTU-sized slots indexed by seq % WIN. Each slot reserves a full MTU even for shorter payloads.

Static memory: WIN × MTU (reorder) + REASM (reassembly).

• WIN — receive window (number of slots)
• MTU — maximum segment payload size
• REASM — reassembly buffer size
• TOTAL — total slot storage (WIN * MTU)

Trait Implementations

impl<const WIN: usize, const MTU: usize, const REASM: usize, const TOTAL: usize> ReceiverBackend for FastReceiver<WIN, MTU, REASM, TOTAL>

fn new() -> Self

Create a new backend with empty buffers.

fn handle_data( &mut self, seq: SequenceCount, flags: SequenceFlag, payload: &[u8], ) -> Result<DataOutcome, ReceiverError>

Process a received data packet.

fn skip_gap(&mut self) -> Result<GapOutcome, ReceiverError>

Skip the current gap (advance past missing packets).

fn take_message(&mut self) -> Option<&[u8]>

Take the complete message.

fn reassembly_data(&self, len: usize) -> &[u8]

Returns a slice of the reassembly buffer.

fn has_message(&self) -> bool

Check if there’s a complete message ready.

fn message_len(&self) -> Option<usize>

Returns the length of the pending message, if any.

fn consume_message<Ret>(&mut self, f: impl FnOnce(&[u8]) -> Ret) -> Option<Ret>

Pass the pending message to f and mark it consumed.

fn expected_seq(&self) -> SequenceCount

Get the current expected sequence number.

fn recv_bitmap(&self) -> u16

Get the selective ACK bitmap.