Struct SequenceCounter 

pub struct SequenceCounter(/* private fields */);

Monotonically increasing per-run counter for event ordering.

Each run() or run_turn() call creates a fresh counter starting at 0. The counter is Arc-wrapped so it can be shared across tasks (e.g., subagent progress events sent from child tokio tasks).

Ordering::Relaxed is sufficient because the mpsc channel provides the happens-before ordering guarantee between sender and receiver.

Implementations

impl SequenceCounter

pub fn new() -> SequenceCounter

Create a new counter starting at 0.

pub fn with_offset(start: u64) -> SequenceCounter

Create a counter starting at the given offset.

Used by server mode to resume sequencing across turns within the same thread — the server seeds the counter with the last known sequence value so numbering is continuous.

pub fn next(&self) -> u64

Get the next sequence number, incrementing the counter.

Trait Implementations

impl Clone for SequenceCounter

fn clone(&self) -> SequenceCounter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SequenceCounter

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

Formats the value using the given formatter.

impl Default for SequenceCounter

fn default() -> SequenceCounter

Returns the “default value” for a type.