Struct PrepublicationRealtimeFrame 

pub struct PrepublicationRealtimeFrame<T, C, H>
where
    H: RealtimeFrameHostObserver<T>,
{ /* private fields */ }

Scheduler transition which gates publication on exact completion and host observation.

Core schedulers call TransitionOutput::is_complete before committing the associated semantic-state branch. This wrapper returns true only after the native completion has validated and the family-blind observer has produced and cached the host output. Therefore an observation failure follows the scheduler’s ordinary failed-transition path and cannot publish the branch. The cached output is consumed only from the transition returned after commit.

Implementations

impl<T, C, H> PrepublicationRealtimeFrame<T, C, H>

where H: RealtimeFrameHostObserver<T>,

pub fn new(submitted: SubmittedRealtimeFrame<T, C>, observer: H) -> Self

Binds one submitted native frame to its mandatory prepublication observer.

pub fn into_host_output( self, ) -> Result<H::Output, RealtimeHostOutputUnavailable<H::Error>>

Consumes the cached host output after the scheduler returns this committed transition.

Calling this before TransitionOutput::is_complete succeeds reports that observation is still pending. A failed observation retains its original error for stable diagnostics.

Trait Implementations

impl<T, C, H> DistributedTransitionOutput for PrepublicationRealtimeFrame<T, C, H>

where C: Completion, C::Error: 'static, H: RealtimeFrameHostObserver<T>, H::Output: WorkDescriptor,

fn encode_distributed_output(&self, output: &mut Vec<u32>) -> Result<(), String>

Appends every portable output field in stable semantic order.

impl<T, C, H> TransitionOutput for PrepublicationRealtimeFrame<T, C, H>

where C: Completion, C::Error: 'static, H: RealtimeFrameHostObserver<T>,

type Error = RealtimePrepublicationError<<C as Completion>::Error, <H as RealtimeFrameHostObserver<T>>::Error>

Completion observation error.

fn is_complete(&self) -> Result<bool, Self::Error>

Nonblocking exact completion observation.

fn retained_resources(&self) -> usize

Explicitly retained resource count.

fn backend_name(&self) -> Option<String>

Stable backend name used only for capability telemetry.

fn physically_preemptible(&self) -> bool

Whether already executing work can be physically interrupted.