Struct DomainRuntime 

pub struct DomainRuntime<C> { /* private fields */ }

A start/stop controller around a shared core C.

C is the domain core the loop operates on; it is held as an Arc<C> so the controller can hand it to the spawned loop and to core callers.

Implementations

impl<C> DomainRuntime<C>

pub fn new(core: Arc<C>) -> Self

Wrap a core. The controller starts in the stopped state.

pub fn core(&self) -> Arc<C>

The shared core.

pub async fn start<F>(&self, mk: F) -> Result<bool, AlreadyRunning>

where F: FnOnce(CancellationToken) -> JoinHandle<()>,

Start the background loop.

mk is called with a fresh CancellationToken and must spawn the domain loop, returning its JoinHandle. On success the controller marks itself running and stores the token; a watcher task flips running back to false when the loop’s handle completes. Returns Ok(false) (a no-op) if already running.

pub async fn stop(&self) -> bool

Stop the background loop by cancelling its token.

Returns true if a token was present (i.e. the loop was running), false otherwise. Marks running = false immediately without waiting for the loop to wind down.

pub async fn status(&self) -> RuntimeStatus

Current running state.

Trait Implementations

impl<C> Clone for DomainRuntime<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.