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 + Clone + 'static, M: RuntimeModel,

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

pub fn with_prefetch(self, lead: u32) -> Self

Enable async inference: a group asks for its next action chunk while lead (or fewer) replay frames of the current one remain, so the forward overlaps the env steps. The chunk sees an observation up to lead steps stale, so results are NOT comparable to the synchronous loop — callers must label runs accordingly. lead == 0 leaves it off.

pub fn with_scheduler(self, scheduler: Box<dyn PredictScheduler>) -> Self

Replace the predict scheduling policy (default: EagerScheduler).

pub fn with_relay_policy(self, relay_policy: Arc<dyn RelayPolicy>) -> Self

Replace the relay policy (default: RefusingRelayPolicy).

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 ReleaseAdapter 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.