Struct LinearizedExecutor 

pub struct LinearizedExecutor<M>
where
    M: Machine,
    M::Output: OutputEvidence,
    <M::Output as OutputEvidence>::Evidence: Clone,
{ /* private fields */ }

Transition-linearized execution with separately ordered output dispatch.

Implementations

impl<M> LinearizedExecutor<M>

where M: Machine, M::Output: OutputEvidence, <M::Output as OutputEvidence>::Evidence: Clone,

pub fn new(machine: M) -> Self

Construct an executor with an empty output queue.

pub fn submit(&self, input: M::Input) -> <M::Output as OutputEvidence>::Evidence

Advance and enqueue one output at the same linearization point.

Panics

Panics after synchronization poison or a transition panic that consumed the affine machine state.

pub fn evidence(&self) -> Option<<M::Output as OutputEvidence>::Evidence>

Clone the evidence installed by the latest linearized transition.

Panics

Panics if executor synchronization was poisoned.

pub fn dispatch_pending<H>(&self, handler: &H) -> DispatchOutcome

where H: OutputHandler<M::Output>,

Dispatch queued outputs until empty, or contribute them to another owner.

DispatchOutcome::OwnedElsewhere means another caller owns dispatch and this call is fire-and-forget; it does not mean the caller’s output completed. If a handler panics, its owned output is dropped exactly once and a later call resumes with the remaining queue.

Panics

Panics if executor synchronization was poisoned by a transition panic in LinearizedExecutor::submit.