Struct ObserverBackpressureState 

pub struct ObserverBackpressureState { /* private fields */ }

Common observer-backpressure suffix.

Implementations

impl ObserverBackpressureState

pub const fn initial(observer_progress: DeliverySeq) -> Self

Constructs an initial refusal at the current observer-progress baseline.

An initial refusal epoch is exactly the progress value observed by the serialized operation.

pub const fn replay( backpressure_epoch: ObserverEpoch, observer_progress: DeliverySeq, ) -> Option<Self>

Reconstructs an exact-token replay refusal at its current baseline.

Pending replay at greater progress must drain or atomically rewrite the cell epoch to that progress before responding. It therefore returns None for any inequality.

pub const fn backpressure_epoch(self) -> ObserverEpoch

Refusal epoch serialized in the response.

pub const fn observer_progress(self) -> DeliverySeq

Observer progress captured by the refusal.

Trait Implementations

impl Clone for ObserverBackpressureState

fn clone(&self) -> ObserverBackpressureState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ObserverBackpressureState

impl Debug for ObserverBackpressureState

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

Formats the value using the given formatter.

impl Eq for ObserverBackpressureState

impl PartialEq for ObserverBackpressureState

fn eq(&self, other: &ObserverBackpressureState) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ObserverBackpressureState