Struct ObserverProjection 

pub struct ObserverProjection { /* private fields */ }

Observer-projection witness.

Implementations

impl ObserverProjection

pub const fn new(through_seq: DeliverySeq) -> Self

Creates an exact observer-projection witness.

pub const fn through_seq(self) -> DeliverySeq

Returns the exact projection boundary.

impl ObserverProjection

pub const fn apply_ordinary_binding_fate( self, resulting_debt: ClosureDebt, authority: OrdinaryBindingFate, ) -> PendingRecoveredCursorRelease

Applies ordinary no-marker binding fate while this OP remains current.

The opaque fate carries ordinary-attach and exact-terminal provenance; projection completion must retain its cursor-release suffix while debt remains.

pub fn apply_recovered_binding_fate( self, debt: ClosureDebt, resulting_debt: ClosureDebt, authority: RecoveredBindingFate, ) -> Result<RecoveredBindingFateTransition, RecoveredBindingFate>

Applies recovered binding fate while this exact OP remains incomplete.

OP is independent of binding fate, so nonzero debt preserves it and the returned opaque value retains the exact DetachedCursorRelease suffix until projection completion.

Errors

Returns the unconsumed authority unless it was derived for this exact OP and its exact post-attach debt.

pub fn complete_after_recovered_binding_fate( self, event: Event, resulting_debt: Option<ClosureDebt>, pending: PendingRecoveredCursorRelease, ) -> Result<ClosureState, PendingRecoveredCursorRelease>

Consumes a latent recovered cursor suffix on exact OP completion.

Errors

Returns the pending authority intact unless it belongs to this exact OP and the completion event reaches its exact boundary.

pub fn complete_after_ordinary_binding_fate( self, event: Event, resulting_debt: Option<ClosureDebt>, pending: PendingRecoveredCursorRelease, ) -> Result<ClosureState, PendingRecoveredCursorRelease>

Consumes a latent ordinary cursor suffix on exact OP completion.

Errors

Returns the pending authority intact unless it belongs to this exact OP and the completion event reaches the stored projection boundary.

pub const fn clear_after_completion( &self, event: &Event, ) -> Option<ProjectionCompactionSuccessor>

Validates clear selection after this exact projection completes.

pub const fn strict_after_completion( &self, event: &Event, debt: ClosureDebt, edge: StoredEdge, successor_boundary: DeliverySeq, ) -> Option<ProjectionCompactionSuccessor>

Validates a non-DCR strict suffix after this exact projection completes.

pub fn complete( self, debt: ClosureDebt, event: Event, successor: ProjectionCompactionSuccessor, ) -> Result<ClosureState, ClosureState>

Consumes exact projection completion and its predecessor-bound successor.

Errors

Returns the unchanged owed state when the event or successor authority was not built for this exact projection.

pub const fn later_projection_after_marker( &self, event: &Event, debt: ClosureDebt, successor: Self, ) -> Option<ProjectionCompactionSuccessor>

Validates the exact later OP selected by a preclaimed marker append.

pub fn marker_appended( self, debt: ClosureDebt, event: Event, successor: ProjectionCompactionSuccessor, ) -> Result<ClosureState, ClosureState>

Consumes the marker occurrence and atomically installs its exact later OP.

Errors

Returns the unchanged owed state when the event-bound successor was built for another projection or occurrence.

pub const fn later_projection_after_leave( &self, event: &Event, debt: ClosureDebt, successor: Self, ) -> Option<ProjectionCompactionSuccessor>

Validates the exact later OP selected atomically by a live or detached Leave.

pub fn leave_with_later_projection( self, debt: ClosureDebt, event: Event, successor: ProjectionCompactionSuccessor, ) -> Result<ClosureState, ClosureState>

Consumes exact Leave and atomically installs its predecessor-bound later OP.

Errors

Returns the unchanged owed state unless the successor was built for this exact OP and Leave occurrence.

pub const fn independent_event( self, debt: ClosureDebt, event: Event, resulting_debt: Option<ClosureDebt>, ) -> Result<ClosureState, ClosureState>

Consumes an independently valid cursor, marker, fate, or Leave event and preserves this exact OP while debt remains, or clears it with debt.

Errors

Returns the unchanged owed state for an event outside those independent invalidator classes.

pub const fn charged_binding_change( self, debt: ClosureDebt, episode_churn_used: u64, delta_cycles: u64, episode_churn_limit: u64, resulting_debt: Option<ClosureDebt>, ) -> Result<ClosureState, (ClosureState, DetachedAttachRefusal)>

Applies a binding change only after a positive charged churn preflight.

Errors

Returns the unchanged state and EpisodeChurnLimit when the delta is zero or would exceed the episode limit.

Trait Implementations

impl Clone for ObserverProjection

fn clone(&self) -> ObserverProjection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ObserverProjection

impl Debug for ObserverProjection

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

Formats the value using the given formatter.

impl Eq for ObserverProjection

impl PartialEq for ObserverProjection

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ObserverProjection