Struct OastPollPermit 

pub struct OastPollPermit<'a> { /* private fields */ }

Move-only authority to prepare one atomic poll commit.

The exclusive registration borrow prevents concurrent permits. Events stay local to the permit until consuming completion validates the entire batch.

Implementations

impl OastPollPermit<'_>

pub const fn poll_ordinal(&self) -> u16

Returns the one-based poll ordinal.

pub const fn remaining_polls(&self) -> u16

Returns remaining polls after this permit was issued.

pub fn staged_events(&self) -> usize

Returns the number of locally staged events.

pub fn stage_event( &mut self, correlation_id: &OastCorrelationId, event: OastEvent, observed_at: OastMonotonicTime, ) -> Result<(), OastError>

Stages one callback without mutating committed event state.

pub fn finish( self, completed_at: OastMonotonicTime, ) -> Result<OastPollReceipt, OastError>

Validates and commits the staged batch atomically.

Trait Implementations

impl Debug for OastPollPermit<'_>

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

Formats the value using the given formatter.

impl Drop for OastPollPermit<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.