Struct ContinuousDecoder 

pub struct ContinuousDecoder<const MAX_SYMBOL_SIZE: usize, const MAX_WINDOW_SYMBOLS: usize, const MAX_EQUATIONS: usize> { /* private fields */ }

Stateful, bounded RFC 8681 decoder and ordered CopperList assembler.

Recovered records are delivered to the caller immediately and are never retained in an ever-growing history. Exact gap reporting assumes the sender serializes CopperLists in increasing identifier order, as generated Copper runtimes do. Assembly buffers grow on demand up to receiver limits and are recycled after delivery or expiry. Once buffer sizes and concurrency have warmed up, record assembly and borrowed delivery need no heap allocations.

Implementations

impl<const MAX_SYMBOL_SIZE: usize, const MAX_WINDOW_SYMBOLS: usize, const MAX_EQUATIONS: usize> ContinuousDecoder<MAX_SYMBOL_SIZE, MAX_WINDOW_SYMBOLS, MAX_EQUATIONS>

pub fn new( identity: StreamIdentity, lane: Lane, config: RlcConfig, equation_capacity: usize, first_object_id: u64, limits: ReceiverLimits, ) -> Result<Self>

pub fn enable_feedback(&mut self)

Enable bounded finalized-loss accounting on the receiver worker.

pub fn source_outcomes(&self) -> SourceOutcomes

pub const fn next_object_id(&self) -> u64

pub const fn stats(&self) -> ContinuousRecoveryStats

pub fn occupancy(&self) -> ReceiverOccupancy

pub fn drain_events<E>( &mut self, emit: impl FnMut(ContinuousReceiveEvent<'_>) -> Result<(), E>, ) -> Result<(), ReceiveError<E>>

Retries delivery of ordered records or gaps already ready in receiver state.

This is useful after a consumer error and when shutting down a transport after its final datagram. A consumer failure leaves the current event pending so a later call can retry it.

pub fn finish_through<E>( &mut self, last_object_id: u64, emit: impl FnMut(ContinuousReceiveEvent<'_>) -> Result<(), E>, ) -> Result<(), ReceiveError<E>>

Finalizes ordered delivery through an inclusive CopperList identifier.

Any unresolved record or wholly absent identifier through last_object_id is emitted as a terminal gap. Calling this method is an explicit promise that no more useful repair symbols for that range will arrive.

pub fn receive_datagram<E>( &mut self, datagram: &[u8], emit: impl FnMut(ContinuousReceiveEvent<'_>) -> Result<(), E>, ) -> Result<(), ReceiveError<E>>

Validates and submits one carrier-verified datagram. Malformed or foreign packets are counted and ignored before they can contaminate the FEC decoder. Recovered records and definitive gaps are emitted in CopperList-id order. Callers must uphold the packet integrity contract of crate::CuStreamRx.