Struct TypedChain 

pub struct TypedChain<F, D, Ops>
where
    F: RecFamily,
{ /* private fields */ }

A concrete chain: deserializer + statically composed operator stack, erased behind RunnableChain. Ops must accept the family’s record type at every buffer lifetime — the HRTB is what makes borrowed records legal behind the erased boundary.

Trait Implementations

impl<F, D, Ops> Debug for TypedChain<F, D, Ops>

where F: RecFamily,

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

Formats the value using the given formatter.

impl<F, D, Ops> RunnableChain for TypedChain<F, D, Ops>

where F: RecFamily, D: Deserializer<F>, Ops: for<'buf> Collector<<F as RecFamily>::Rec<'buf>> + StageLifecycle + Send,

fn push_batch<'buf>( &mut self, batch: &mut dyn PayloadBatch<'buf>, from: usize, ) -> PushOutcome

Push payloads from.. of batch through the chain.

fn flush(&mut self) -> PushOutcome

Flush terminal-stage state (parked records, partial encoder buffers) downstream. Called by the driver on drain, on linger deadlines, and before commit ticks.

fn abandon_batch(&mut self)

Discard any per-batch replay/resume state after the driver failed the current batch’s acknowledgement (a shutdown-time abandonment of a batch blocked mid-push). Terminal parked chunks — which carry their own acks — are unaffected; only the chain’s own mid-batch cursor and any stashed not-ready payload are cleared, so the next push_batch of a fresh batch starts clean instead of tripping the resume-cursor asserts or replaying the stale payload under the new batch’s ack.