Method ensure_started_async

packages/server/src/simulators/session.rs:173–178

(&self)

    }

    pub async fn ensure_started_async(&self) -> Result<(), AppError> {
        let session = self.clone();
        task::spawn_blocking(move || session.ensure_started())
            .await
            .map_err(|error| AppError::internal(format!("Failed to join start task: {error}")))?
    }

    pub fn subscribe(&self) -> FrameSubscription {
        *self.inner.state.lock().unwrap() = SessionState::Streaming;