Struct CoherentScope 

pub struct CoherentScope { /* private fields */ }

State-Machine-Tracker fuer Coherent-Set auf Publisher-Seite.

Lifecycle:

1. begin_coherent_changes setzt active=true und merkt sich die naechste Sequence-Number als set_first_sn.
2. Jede write() waehrend des aktiven Sets traegt diesen Marker.
3. end_coherent_changes setzt active=false. Das naechste write ohne Marker oder mit neuem Marker signalisiert dem Reader das Set-Ende.

Implementations

impl CoherentScope

pub fn new() -> Arc<Self>

Neuer leerer Scope (in Arc, weil Caller den meist shared zwischen Publisher-Inner + write-Pfad halten muessen).

pub fn is_active(&self) -> bool

True wenn der Scope aktiv ist.

pub fn current_marker(&self) -> Option<CoherentSetMarker>

Liefert den aktuellen Marker, falls Scope aktiv ist.

pub fn begin(&self, next_sn: CoherentSequenceNumber) -> Result<()>

Beginnt einen neuen Coherent-Set mit der gegebenen next_sn als Set-First-SN. Spec: §2.2.2.4.1.8 Publisher::begin_coherent_changes.

Errors

PreconditionNotMet wenn ein Set bereits aktiv ist (Spec: nicht verschachtelbar aktuell).

pub fn end(&self) -> Result<CoherentSetMarker>

Beendet den aktiven Coherent-Set. Spec: §2.2.2.4.1.9 Publisher::end_coherent_changes.

Errors

PreconditionNotMet wenn kein Set aktiv ist.

Trait Implementations

impl Debug for CoherentScope

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

Formats the value using the given formatter.

impl Default for CoherentScope

fn default() -> Self

Returns the “default value” for a type.