Struct SpeculativeOutputRuntime 

pub struct SpeculativeOutputRuntime<S, C, P> { /* private fields */ }

Canonical speculative sampler, sequence, constraint, and output sink.

Implementations

impl<S, C, P> SpeculativeOutputRuntime<S, C, P>

where S: SpeculativeSampling, C: SpeculativeConstraint, P: SpeculativePublisher<C>,

pub fn new( sampler: S, sequence: GenerationSequence, constraint: C, publisher: P, cancellation: GenerationCancellationToken, ) -> Self

Creates one canonical output runtime.

pub fn with_lifecycle_observer( self, observer: Arc<dyn SpeculativeLifecycleObserver>, ) -> Self

Installs explicit production lifecycle observation for this lane.

pub fn observe_lifecycle( &self, stage: SpeculativeLifecycleStage, ) -> Result<(), SpeculativeOutputError>

Observes one lifecycle boundary before its associated work.

pub const fn sampler(&self) -> &S

Canonical sampling state.

pub const fn sampler_mut(&mut self) -> &mut S

Mutable canonical sampling state.

pub const fn sequence(&self) -> &GenerationSequence

Canonical committed sequence.

pub const fn sequence_mut(&mut self) -> &mut GenerationSequence

Mutable canonical committed sequence.

pub const fn constraint(&self) -> &C

Transactional semantic constraint.

pub const fn constraint_mut(&mut self) -> &mut C

Mutable transactional semantic constraint.

pub const fn cancellation(&self) -> &GenerationCancellationToken

Cooperative cancellation token.

pub fn cancel(&mut self) -> Result<(), SpeculativeOutputError>

Applies cancellation and publishes its terminal semantic state.

pub fn install_committed_state( &mut self, sampler: S, constraint: C, sequence: GenerationSequence, )

Installs logical state only after its matching backend boundary committed.

pub fn publish_committed( &mut self, tokens: &[u32], ) -> Result<bool, SpeculativeOutputError>

Publishes tokens only after their backend cache transaction committed.