Struct RuntimeDriver 

pub struct RuntimeDriver<E, M> { /* private fields */ }

Drives one ready model/env session through its reset -> predict -> step loop. Inert until a run* method is awaited.

Implementations

impl<E, M> RuntimeDriver<E, M>

where E: RuntimeEnv, M: RuntimeModel,

pub fn new( spec: RuntimeSessionSpec, env: E, model: M, hooks: Arc<dyn RuntimeHooks>, ) -> Self

pub async fn run(self) -> Result<RuntimeReport, RuntimeError>

pub async fn run_with_cancellation( self, cancellation: CancellationToken, ) -> Result<RuntimeReport, RuntimeError>

pub async fn run_with_cancellation_reason( self, cancellation: CancellationToken, reason: impl Into<String>, ) -> Result<RuntimeReport, RuntimeError>

Runs the session, attributing any cancellation of cancellation to reason.

The reason is carried into RuntimeError::RouteCancelled, the session_failed hook event, and the CloseRoute reason, so callers (e.g. an owner that cancels for Ctrl+C, a deadline, or a sibling-route failure) can supply an accurate cause instead of a hardcoded one.