Skip to main content

ordered_batches

Function ordered_batches 

Source
pub fn ordered_batches(
    cursors: &mut TopicCursor,
    envelopes: Vec<ServerEnvelope>,
    limits: IncomingBatchLimits,
) -> Result<Vec<OrderedEnvelopeBatch>, EnvelopeError>
Expand description

Validate a complete ordered read without parsing or changing MLS bytes. Preserve each topic’s input cursor as after; sequence gaps are valid. Advance only these in-memory cursors on success, never durable receipt F.