Struct AsyncTaskManager

pub struct AsyncTaskManager { /* private fields */ }

Async task manager

Implementations

impl AsyncTaskManager

pub fn new() -> Self

pub fn spawn_task<F>(&mut self, name: &str, future: F) -> &TaskHandle

where F: Future<Output = ()> + Send + 'static,

pub fn get_active_task_count(&self) -> usize

pub fn is_task_running(&self, name: &str) -> bool

pub fn get_task_names(&self) -> Vec<String>

pub fn get_running_task_names(&self) -> Vec<String>

pub async fn cancel_task(&mut self, name: &str)

pub async fn wait_for_task_completion(&self, name: &str) -> Result<(), McpError>

pub async fn shutdown_all_tasks( &mut self, _timeout: Duration, ) -> Result<(), McpError>

Trait Implementations

impl Default for AsyncTaskManager

fn default() -> Self

Returns the “default value” for a type.