Struct TurnMachine 

pub struct TurnMachine<M = UnitTurnProtocol>
where
    M: TurnProtocol,
{ /* private fields */ }

Sans-IO state machine for a single session run (multi-turn).

Implementations

impl<M> TurnMachine<M>

where M: TurnProtocol,

pub fn new( config: TurnMachineConfig<M>, messages: Vec<Message>, events: Arc<Vec<SessionEventRecord<<M as TurnProtocol>::Event>>>, protocol_run_offset: usize, ) -> TurnMachine<M>

Create a new machine in PrepareIteration state.

pub fn new_shared( config: TurnMachineConfig<M>, messages: MessageSequence, events: Arc<Vec<SessionEventRecord<<M as TurnProtocol>::Event>>>, protocol_run_offset: usize, ) -> TurnMachine<M>

pub fn new_shared_with_turn_causes( config: TurnMachineConfig<M>, messages: MessageSequence, events: Arc<Vec<SessionEventRecord<<M as TurnProtocol>::Event>>>, protocol_run_offset: usize, turn_causes: Vec<TurnCause>, ) -> TurnMachine<M>

pub fn is_done(&self) -> bool

Whether the machine has finished.

pub fn messages(&self) -> Arc<Vec<Message>>

pub fn events(&self) -> Arc<Vec<SessionEventRecord<<M as TurnProtocol>::Event>>>

pub fn message_sequence(&self) -> MessageSequence

pub fn protocol_iteration(&self) -> usize

pub fn checkpoint(&self) -> TurnCheckpoint<M>

pub fn restore_from_checkpoint( config: TurnMachineConfig<M>, checkpoint: TurnCheckpoint<M>, ) -> TurnMachine<M>

pub fn fail_turn(&mut self, event: SessionEvent)

pub fn finish_with_outcome(&mut self, outcome: TurnOutcome)

pub fn poll_effect(&mut self) -> Option<Effect<M>>

Drain the next pending effect. Returns None when the host must call handle_response() before more effects become available.

pub fn apply_actions(&mut self, actions: Vec<DriverAction<M>>)

pub fn handle_response(&mut self, response: Response)

Feed a response to a previously emitted effect.