Struct TaskSpawner 

pub struct TaskSpawner { /* private fields */ }

Spawns and manages the lifecycle of a task

Implementations

impl TaskSpawner

pub async fn start_direct( &mut self, event_tx: Sender<TaskEvent>, ) -> Result<u32, TaskError>

impl TaskSpawner

pub fn new(task_name: String, config: TaskConfig) -> Self

Create a new task spawner for the given task name and configuration

pub fn set_stdin(self, stdin_rx: Receiver<String>) -> Self

Set the stdin receiver for the task, enabling asynchronous input

Has no effect if enable_stdin is false in the configuration

pub async fn get_state(&self) -> TaskState

Get the current state of the task

pub async fn is_running(&self) -> bool

Check if the task is currently running

pub async fn is_ready(&self) -> bool

Check if the task is currently ready

pub fn uptime(&self) -> Duration

Get the uptime of the task since creation

pub async fn get_task_info(&self) -> TaskInfo

Get information about the task, including name, state, and uptime

pub async fn send_terminate_signal( &self, reason: TaskTerminateReason, ) -> Result<(), TaskError>

Send a termination signal to the running task

Returns an error if the signal cannot be sent

Trait Implementations

impl Debug for TaskSpawner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.