Struct SequenceBarrier 

pub struct SequenceBarrier { /* private fields */ }

A barrier that waits for a specific sequence number to be reached. It handles out-of-order completions by buffering them and advancing the publicly visible “finished” sequence monotonically.

Implementations

impl SequenceBarrier

pub fn new(start: u64) -> Self

pub async fn wait_for(&self, seq: u64)

Wait until the barrier reaches at least seq.

pub fn complete(&self, seq: u64)

Mark a specific sequence number as complete. If this completes the next expected sequence, the barrier advances.

pub fn current(&self) -> u64

Trait Implementations

impl Debug for SequenceBarrier

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

Formats the value using the given formatter.